文章目录[隐藏]

知识准备

RabbitMQ

RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。

MQ

MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。

消息队列使用发布订-阅模式工作。消息发送者是消息源，在对消息进行处理后将消息发送至分布式消息队列，消息接受者从分布式消息队列获取该消息后继续进行处理。可以看到，消息发送者和消息接受者之间没有直接耦合，消息发送者将消息发送至分布式消息队列即结束对消息的处理，而消息接受者只需要从分布式消息队列获取消息后进行处理，不需要知道该消息从何而来。
通过消息队列通信，让A，B两个服务指间保持低耦合，实现业务的灵活拓展。

pika

pika是RabbitMQ团队编写的官方Python AMQP库。

安装启动**本文来源gaodai#ma#com搞@@代~&码*网/**

$ brew install rabbitmq$ usr/local/sbin/rabbitmq-server

安装pika

pip install pika

操作实例

Hello World

sender

# coding: utf-8import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))channel = connection.channel()channel.queue_declare(queue='hello')channel.basic_publish(exchange='',                      routing_key='hello',                      body='Hello, World!')print 'send msg: Hello World!'connection.close()

receiver

# coding: utf-8import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))channel = connection.channel()channel.queue_declare(queue='hello')def callback(ch, method, properties, body):    print 'receive msg: %s' % bodychannel.basic_consume(callback,                      queue='hello',                      no_ack=False)print 'waiting for msg...'channel.start_consuming()

运行结果：

# sender.py 运行2次send msg: Hello World!# receiverwaiting for msg...receive msg: Hello, World!receive msg: Hello, World!

消费者处理消息后，并没有退出，仍然可以处理后续的消息。

以上就是Python中RabbitMQ的操作图文代码详解的详细内容，更多请关注搞代码gaodaima其它相关文章！

搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]‍，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：Python中RabbitMQ的操作图文代码详解