RabbitMQ
我在rails后台接受数据后用消息队列传给python
Publisher.publish("mio_publisher", some_data)
但是每次对应的python接收方只能接收到一次消息,当有新消息发送时,需要关闭重新打开才可以接受.
connection = pika.BlockingConnection(pika.ConnectionParameters(
variables.MQ_CONNECTION_P))
channel = connection.channel()
channel.queue_declare(queue='mio_publisher', durable=True)
但是,我同时在python多个任务间传递消息,从未出现这样的问题。为什么呢?
如果无法解决,那么还有啥别的方法实现rails与python的通通信?通信 时间长,频率高
谢谢!