首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 开发语言 > perl python >

RabbitMQ:施用python发布/订阅消息

2013-08-01 
RabbitMQ:使用python发布/订阅消息在上一章节中,我们学习了RabbitMQ:基础,运行和管理,在本节中我们来学习

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
       

热点排行