RabbitMQ:使用python发布/订阅消息
在上一章节中,我们学习了RabbitMQ:基础,运行和管理,在本节中我们来学习一下如何发布和订阅rabbitmq消息,我们使用python来开发应用程序。
我们先来看一下发布/订阅rabbitmq消息的流程。先来看消息生产者Publisher如何发布消息流程:
接下来,我们先来开发一个带消息确认信息的消费者hello_world_consumer_with_ack.py:
测试:引用
# /opt/mq/rabbitmq/sbin/rabbitmq-server start &
# python ./hello_world_consumer_with_ack.py
# python ./hello_world_producer_with_comfirms.py 'hello-world'
对于上面的hello_world_producer_with_comfirms.py,本人调试了很长时间,期间总是在:引用
#将生产者创建的channel处于"publisher confirms"模式
channel.confirm_delivery(callback = confirm_handler)
报错,最后在重新下载pika-0.9.13.tar.gz并安装后才成功执行上述代码:引用
# wget https://pypi.python.org/packages/source/p/pika/pika-0.9.13.tar.gz --no-check-certificate
# chmod +x pika-0.9.13.tar.gz
# tar xzvf pika-0.9.13.tar.gz
# cd pika-0.9.13
# python setup.py install