在上篇文章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
什么是ProtoBuf？ 一种轻便高效的结构化数据存储格式，可以用于结构化数据串行化，或者说序列化。它很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构数据格式。目前提供了 C++、Java、Python 三种语言的 API。 它可以作为...
分类：
其他好文 时间：
2015-01-06 15:19:30
阅读次数：
107
从AMQP协议可以看出，MessageQueue、Exchange和Binding构成了AMQP协议的核心，下面我们就围绕这三个主要组件 从应用使用的角度全面的介绍如何利用Rabbit MQ构建消息队列以及使用过程中的注意事项。1. 声明MessageQueue 在Rabbit MQ中，无论是生产....
分类：
其他好文 时间：
2015-01-06 15:03:10
阅读次数：
493
上篇文章中，我们构建了一个简单的日志系统。接下来，我们将丰富它：能够使用不同的severity（严重程度）来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。1. Bindings绑定 上篇文章中我们是这么做的绑定：channel.QueueBind(queueName, EX...
分类：
其他好文 时间：
2015-01-06 13:45:30
阅读次数：
144
上篇文章中，我们把每个Message都是deliver（提供）到某个Consumer。在这篇文章中，我们将会将同一个Message deliver（提供）到多个Consumer中。这个模式也被成为 "publish / subscribe"。 这篇文章中，我们将创建一个日志系统，它包含两个部分：第一...
分类：
其他好文 时间：
2015-01-06 13:43:50
阅读次数：
111
具体出错信息如下：[root@blockstorage ~]# rabbitmqctl change_password guest RABBIT_PASSChanging password for user "guest" ...Error: unable to connect to node .....
分类：
其他好文 时间：
2015-01-06 13:27:04
阅读次数：
184
在上篇文章中，我们解决了从发送端（Producer）向接收端（Consumer）发送“Hello World”的问题。在实际的应用场景中，这是远远不够的。从本篇文章开始，我们将结合更加实际的应用场景来讲解更多的高级用法。 当有Consumer需要大量的运算时，RabbitMQ Server需要一定的...
分类：
其他好文 时间：
2015-01-06 13:21:35
阅读次数：
179
2. Sending第一个program send.cs：发送Hello world 到queue。正如我们在上篇文章提到的，你程序的第9行就是建立连接，第12行就是创建channel，第14行创建名字为hello的queue。 1 using System; 2 using RabbitMQ.Cl...
分类：
其他好文 时间：
2015-01-06 11:53:32
阅读次数：
106
今天在搭建OpenStack的时候需要安装RabbitMQ，可是使用yum install rabbitmq-server安装之后，按照OpenStack官方提供的文档修改guest用户密码的时候却出现了如下错误：[root@controller ~]# rabbitmqctl change_p.....
分类：
其他好文 时间：
2015-01-04 21:21:12
阅读次数：
895
