Python中RabbitMQ的操作图文代码详解

RabbitMQ

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

MQ

MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。
通过消息队列通信，让A，B两个服务指间保持低耦合，实现业务的灵活拓展。

pika

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

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

安装pika

pip install pika

Hello World

sender

# coding: utf-8import pika

cOnnection= pika.BlockingConnection(pika.ConnectionParameters(&＃39;localhost&＃39;))
channel = connection.channel()

channel.queue_declare(queue=&＃39;hello&＃39;)

channel.basic_publish(exchange=&＃39;&＃39;,
                      routing_key=&＃39;hello&＃39;,
                      body=&＃39;Hello, World!&＃39;)print &＃39;send msg: Hello World!&＃39;connection.close()

receiver

# coding: utf-8import pika

cOnnection= pika.BlockingConnection(pika.ConnectionParameters(&＃39;localhost&＃39;))
channel = connection.channel()

channel.queue_declare(queue=&＃39;hello&＃39;)def callback(ch, method, properties, body):
    print &＃39;receive msg: %s&＃39; % body

channel.basic_consume(callback,
                      queue=&＃39;hello&＃39;,
                      no_ack=False)print &＃39;waiting for msg...&＃39;channel.start_consuming()

运行结果：

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

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

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