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

黄舟
Freigeben: 2017-05-07 10:47:01
Original
1379 Leute haben es durchsucht


知识准备

RabbitMQ

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

MQ

MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。
这里写图片描述
消息队列使用发布订-阅模式工作。消息发送者是消息源,在对消息进行处理后将消息发送至分布式消息队列,消息接受者从分布式消息队列获取该消息后继续进行处理。可以看到,消息发送者和消息接受者之间没有直接耦合,消息发送者将消息发送至分布式消息队列即结束对消息的处理,而消息接受者只需要从分布式消息队列获取消息后进行处理,不需要知道该消息从何而来。
通过消息队列通信,让A,B两个服务指间保持低耦合,实现业务的灵活拓展。

pika

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

安装启动

$ brew install rabbitmq$ usr/local/sbin/rabbitmq-server
Nach dem Login kopieren

安装pika

pip install pika
Nach dem Login kopieren

操作实例

Hello World

sender

# coding: utf-8import pika connection = 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()
Nach dem Login kopieren

receiver

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

运行结果:

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

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

Das obige ist der detaillierte Inhalt vonPython中RabbitMQ的操作图文代码详解. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Verwandte Etiketten:
Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage
Über uns Haftungsausschluss Sitemap
Chinesische PHP-Website:Online-PHP-Schulung für das Gemeinwohl,Helfen Sie PHP-Lernenden, sich schnell weiterzuentwickeln!