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