python队列通信:rabbitMQ的使用(实例讲解)

（一）、前言

为什么引入消息队列？

1.程序解耦

2.提升性能

3.降低多业务逻辑复杂度

（二）、python操作rabbit mq

rabbitmq配置安装基本使用参见上节文章，不再复述。

若想使用python操作rabbitmq，需安装pika模块，直接pip安装：

pip install pika

1.最简单的rabbitmq producer端与consumer端对话：

producer：

#Author :ywqimport pikaauth=pika.PlainCredentials('ywq','qwe') #save auth indoconnection = pika.BlockingConnection(pika.ConnectionParameters(  '192.168.0.158',5672,'/',auth)) #connect to rabbitchannel = connection.channel() #create channelchannel.queue_declare(queue='hello') #declare queue#n RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.channel.basic_publish(exchange='',   routing_key='hello',   body='Hello World!') #the body is the msg contentprint(" [x] Sent 'Hello World!'")connection.close()

consumer：

#Author :ywqimport pikaauth=pika.PlainCredentials('ywq','qwe') #auth infoconnection = pika.BlockingConnection(pika.ConnectionParameters(  '192.168.0.158',5672,'/',auth)) #connect to rabbitchannel = connection.channel()  #create channelchannel.queue_declare(queue='hello') #decalre queuedef callback(ch, method, properties, body): print(" [x] Received %r" % body)channel.basic_consume(callback,   queue='hello',   no_ack=True)print(' [*] Waiting for messages. To exit press CTRL+C')channel.start_consuming()

消息传递消费过程中，可以在rabbit web管理页面实时查看队列消息信息。

2.持久化的消息队列，避免宕机等意外情况造成消息队列丢失。

consumer端无需改变，在producer端代码内加上两个属性，分别使消息持久化、队列持久化，只选其一还是会出现消息丢失，必须同时开启：

delivery_mode=2 #make msg persisdentdurable=True

属性插入位置见如下代码（producer端）：

#Author :ywqimport pika,sysauth_info=pika.PlainCredentials('ywq','qwe')connection=pika.BlockingConnection(pika.ConnectionParameters(  '192.168.0.158',5672,'/',auth_info ))channel=connection.channel()channel.queue_declare(queue='test1',durable=True) #durable=Ture, make queue persistentmsg=''.join(sys.argv[1:]) or 'Hello'channel.basic_publish( exchange='', routing_key='test1', body=msg, properties=pika.BasicProperties(  delivery_mode=2 #make msg persisdent ))print('Send done:',msg)connection.close()

3.公平分发

在多consumer的情况下，默认rabbit是轮询发送消息的，但有的consumer消费速度快，有的消费速度慢，为了资源使用更平衡，引入ack确认机制。consumer消费完消息后会给rabbit发送ack，一旦未ack的消息数量超过指定允许的数量，则不再往该consumer发送，改为发送给其他consumer。