RabbitMQ中rails向python传递问题

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的通通信?通信 时间长,频率高

谢谢!

阅读 2.6k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题