首页 > 其他 > 详细

rabbitmq 消息持久化

时间:2016-12-26 21:25:30      阅读:169      评论:0      收藏:0      [点我收藏+]
 

rabbitmq 消息持久化

技术分享 分类:
二:
任务分发 &消息持久化
 
启用多个接收端的时候如果某一个receive 关闭要保证消息有反馈是否收到
 
send端
#-*- coding: UTF-8 -*-
import pika
cred = 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 pika
import time
cred = 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 自动应答改为False
print("starting")
channel.start_consuming()

 

rabbitmq 消息持久化

原文:http://www.cnblogs.com/weiman3389/p/6223468.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!