username = 'xxxxxxxx' pwd = 'xxxxxxxx' user_pwd = pika.PlainCredentials(username, pwd) s_conn = pika.BlockingConnection(pika.ConnectionParameters('110... ...
分类：
编程语言 时间：
2019-06-20 09:33:48
阅读次数：
137
https://github.com/pika/pika/blob/03542ef616a2a849e8bfb0845427f50e741ea0c6/docs/examples/using_urlparameters.rst https://github.com/pika/pika/blob/411 ...
分类：
其他好文 时间：
2019-06-12 19:28:17
阅读次数：
99
RabbitMQ消息队列 !!! 注意，保证服务器的内存足够，磁盘足够，以及删除/etc/hosts中没有用的dns解析 no-ack机制 不确定机制,就是每次消费者接收完数据后,不管是否处理完毕,rabbitmq-server都会把这个消息标记完成,从队列中删除 生产者已经有了,这时候准备一个消费 ...
分类：
其他好文 时间：
2019-04-14 16:32:20
阅读次数：
185
一、模式介绍 路由模式，与发布-订阅模式一样，消息发送到exchange中，消费者把队列绑定到exchange上。 这种模式在exchange上添加添加了一个路由键（routing-key），生产者发布消息的时候添加路由键（routing-key），消费者绑定队列到交换机时添加键值（routing- ...
分类：
编程语言 时间：
2019-01-13 02:00:08
阅读次数：
232
import pika connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost')) channel = connection.channel() #声明queue channel.queue_declar ...
分类：
编程语言 时间：
2019-01-06 20:05:59
阅读次数：
306
rabbitmq作为消息队列可以有消息消费确认机制，redis的list结构可以简单充当消息队列，但不具备消费确认机制，随意关停程序，会丢失一部分正在程序中处理但还没执行完的消息。 使用rabbitmq的最常用库pika ...
分类：
编程语言 时间：
2018-12-19 15:54:26
阅读次数：
887
使用pika库操作rabbit 查找whereis rabbitmq-server 启动/usr/sbin/rabbitmq-server & 打印了一些rabbitmq服务状态信息，包括内存，硬盘，和使用erlong的版本信息rabbitmqctl -q status 查看所有队列消息rabbit ...
分类：
其他好文 时间：
2018-12-19 15:38:57
阅读次数：
145
消息也可以理解为任务，消息发送者可以理解为任务分配者，消息接收者可以理解为工作者，当工作者接收到一个任务，还没完成的时候，任务分配者又发一个任务过来，那就忙不过来了，于是就需要多个工作者来共同处理这些任务，这些工作者，就称为工作队列。 RabbitMQ会默认把p发的消息依次分发给各个消费者(c),跟 ...
分类：
编程语言 时间：
2018-11-13 18:07:00
阅读次数：
221
一、RabbitMQ简介： 二、简单的示例： import pika # 相当于建立最基本的socket connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) # 声明一个管道 channel = c ...
分类：
其他好文 时间：
2018-11-07 23:10:36
阅读次数：
173
一、常见使用方式 Redis的几种常见使用方式包括： Redis单副本； Redis多副本（主从）； Redis Sentinel（哨兵）； Redis Cluster； Redis自研。 Redis单副本； Redis多副本（主从）； Redis Sentinel（哨兵）； Redis Clust ...
分类：
其他好文 时间：
2018-11-03 14:41:01
阅读次数：
149
