rabbitmq 消息持久化

2016-02-18 11:19 224人阅读 评论(0) 收藏 举报

 分类：

综合（15） 

版权声明：本文为博主原创文章，未经博主允许不得转载。

二：

任务分发 &消息持久化

启用多个接收端的时候如果某一个receive 关闭要保证消息有反馈是否收到

send端

#-*- coding: UTF-8 -*-import pikacred = pika.PlainCredentials(‘zxl‘,‘pwd‘) #账号密码params = pika.ConnectionParameters(host=‘192.168.110.233‘,port=5672,credentials=cred) #条件设置connection = pika.BlockingConnection(params) #给定条件channel = connection.channel()channel.queue_declare(queue=‘t_list‘,durable=True) #创建一个t_list 队列for i in range(0,100):    content = ‘ ni hao is hello‘+str(i)    channel.basic_publish(exchange=‘‘,                          routing_key=‘t_list‘,                          body=content,                          properties=pika.BasicProperties(delivery_mode=2) #确保消息持久                          )print(‘send hello‘)print(channel)connection.close()

receive 端

#-*- coding: UTF-8 -*-import pikaimport timecred = pika.PlainCredentials(‘zxl‘,‘pwd‘) #账号密码params = pika.ConnectionParameters(host=‘192.168.110.233‘,port=5672,credentials=cred) #条件设置connection = pika.BlockingConnection(params) #给定条件channel = connection.channel()channel.queue_declare(queue=‘t_list‘,durable=True)

def callback(ch,method,properties,body):   print " [x] Received %r" % (body,)   time.sleep(2)   ch.basic_ack(delivery_tag = method.delivery_tag)

channel.basic_consume(callback,queue = ‘t_list‘,no_ack = False) #no_ack 自动应答改为Falseprint("starting")channel.start_consuming()