在上篇文章RabbitMQ消息队列（五）：Routing 消息路由 中，我们实现了一个简单的日志系统。Consumer可以监听不同severity（严重级别）的log。但是，这也是它之所以叫做简单日志系统的原因，因为是仅仅能够通过severity（严重级别）设定。不支持更多的标准。 比如syslog...
分类：
其他好文 时间：
2015-01-06 15:28:42
阅读次数：
135
上一篇文章使用的是Direct的Exchange，但是没有指定Queue的名字，这样只能是先运行Consumer之后，Producer在运行发消息Consumer才能收到，否则先运行Producer发送消息，在运行Consumer是收不到之前Producer发送的消息，因为Queue的名字像是这样的...
分类：
其他好文 时间：
2015-01-06 15:21:53
阅读次数：
166
上篇文章中，我们把每个Message都是deliver（提供）到某个Consumer。在这篇文章中，我们将会将同一个Message deliver（提供）到多个Consumer中。这个模式也被成为 "publish / subscribe"。 这篇文章中，我们将创建一个日志系统，它包含两个部分：第一...
分类：
其他好文 时间：
2015-01-06 13:43:50
阅读次数：
111
在上篇文章中，我们解决了从发送端（Producer）向接收端（Consumer）发送“Hello World”的问题。在实际的应用场景中，这是远远不够的。从本篇文章开始，我们将结合更加实际的应用场景来讲解更多的高级用法。 当有Consumer需要大量的运算时，RabbitMQ Server需要一定的...
分类：
其他好文 时间：
2015-01-06 13:21:35
阅读次数：
179
1 Producer-Consumer PatternProducer-Consumer Pattern主要就是在生产者与消费者之间建立一个“桥梁参与者”，用来解决生产者线程与消费者线程之间速度的不匹配。 当要从某个线程Produccer参与者将数据传输给其它线程Consumer参与者的时候，此时就...
分类：
编程语言 时间：
2015-01-04 19:16:06
阅读次数：
242
#-*- coding:utf-8 -*-import urllib2,sysimport hashlib# Calculate a non-truncated Drupal 7 compatible password hash.# The consumer of these hashes must...
分类：
数据库 时间：
2015-01-02 15:58:37
阅读次数：
287
生产者消费者问题
（英语：Producer-consumer
problem），也称有限缓冲问题（英语：Bounded-buffer
problem），是一个多线程同步问题的经典案例。该问题描述了两个共享固定大小缓冲区的线程——即所谓的“生产者”和“消费者”——在实际运行时会发生的问题。生产者的主要作用是生成一定量的数据放到缓冲区中，然后重复此过程。与此同时，消费者也在缓冲区消耗这...
分类：
数据库 时间：
2014-12-27 00:21:38
阅读次数：
246
在写celery后台任务时，使用redis作为broker，但是启用worker时一直报错，[2014-12-23 14:50:16,056: ERROR/MainProcess] consumer: Cannot connect to redis://localhost:6379/0: Error 111 connecting to loca...
分类：
系统相关 时间：
2014-12-23 17:49:26
阅读次数：
541
RabbitMQ是一个消息代理，核心原理：发送消息，接收消息。RabbitMQ主要用于组件之间的解耦，消息发送者无需知道消息使用者的存在，反之亦然。 单向解耦 双向解耦（如：RPC）例如一个日志系统，很容易使用RabbitMQ简化工作量，一个Consumer进行消息的正常处理，另一个Co...
分类：
其他好文 时间：
2014-12-19 15:40:47
阅读次数：
199
做kafka相关项目，需要用到监控的东东，找到了两个方法第一个：http://quantifind.com/KafkaOffsetMonitor/非常容易上手，效果也直观，可以显示各个topic consumer的offset broker存储log的长度不过发现一个bug就是当 consumer没...
分类：
其他好文 时间：
2014-12-17 17:55:21
阅读次数：
768
