rabbitmq 消息持久化
2016-02-18 11:19
369 查看
二:
任务分发 &消息持久化
启用多个接收端的时候如果某一个receive 关闭要保证消息有反馈是否收到
send端
receive 端
任务分发 &消息持久化
启用多个接收端的时候如果某一个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()
相关文章推荐
- //判断当前是PC终端还是移动终端来跳转不同的路径
- 转:ObjectInputStream类和ObjectInputStream类的使用
- LeetCode :232. Implement Queue using Stacks(剑指offer面试题)
- JNI简介
- Android中打开扬声器关闭麦克风的代码实现
- JVM三种垃圾收集算法思想及发展过程
- JVM三种垃圾收集算法思想及发展过程
- MVC静态资源映射 <mvc:resources> 标签的使用
- 转: JaxbContext生成xml文件或java类对象转化注解
- swift里面!和?的作用
- nyoj746整数划分(四)【区间dp】
- 解决Android Studio加载第三方jar包,出现包重复加载的问题:
- 12306实时余票查询接口
- 保持专注,保持简单
- C#中的值类型和引用类型
- Mysql的lock tables和unlock tables
- sun.misc.BASE64Decoder报错
- Web页面右下角弹出窗口示例代码
- 防火墙工作模式简介
- 转:getContextPath、getServletPath、getRequestURI的区别