从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
一、RaibbitMQ服务器配置1.准备工作。如果之前安装过RabbitMQ软件,若想重新安装,必须先把之前的RabbitMQ相关软件卸载。2.安装ERLANG语言包。首先到http://www.erlang.org/download.html这个页面下载ErlangWindowsBinaryFil...
进入命令行:C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.3.3\sbin运行下面命令来启用管理插件:rabbitmq-plugins enable rabbitmq_management可以看到下面的输出停止RabbitMQ服务:...
分类:
其他好文 时间:
2015-01-04 18:56:58
阅读次数:
166
MQ全称为Message Queue,消息队列(MQ)是一种应用程序对应用程序的通信方法RabbitMQ是流行的开源消息队列系统,用erlang语言开发几个概念说明:Broker:简单来说就是消息队列服务器实体。 Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。 Queu...
分类:
其他好文 时间:
2015-01-04 16:35:20
阅读次数:
295