上篇文章中,我们构建了一个简单的日志系统。接下来,我们将丰富它:能够使用不同的severity来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。1. Bindings绑定 上篇文章中我们是这么做的绑定:[python]view plaincopychannel.queue_b...
分类:
其他好文 时间:
2015-11-18 00:47:56
阅读次数:
201
在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成。那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会通过其它节点求来斐波纳契完成示例。1. 客户端接口 Client interface 为了展示一个R...
分类:
其他好文 时间:
2015-11-18 00:47:10
阅读次数:
406
在Windows上安装Rabbit MQ 指南,最好的是这篇《Rabbit MQ Windows Installation guide》,其中还包括了使用.NET RabbitMQ.Client Nuget 包访问Rabbit MQ的示例代码。安装Rabbit MQRabbit MQ 是建立在强大的...
分类:
其他好文 时间:
2015-11-18 00:44:13
阅读次数:
361
RabbitMQ、ActiveMQ和ZeroMQ都是极好的消息中间件,但是我们在项目中该选择哪个更适合呢?很多开发者面临这个烦恼。下面我会对这三个消息中间件做一个比较,看了后你们就心中有数了。RabbitMQ是AMQP协议领先的一个实现,它实现了代理(Broker)架构,意味着消息在发送到客户端之前...
分类:
其他好文 时间:
2015-11-18 00:39:19
阅读次数:
153
在上篇文章RabbitMQ消息队列(五):Routing 消息路由中,我们实现了一个简单的日志系统。Consumer可以监听不同severity的log。但是,这也是它之所以叫做简单日志系统的原因,因为是仅仅能够通过severity设定。不支持更多的标准。 比如syslogunix的日志工具,它可以...
分类:
其他好文 时间:
2015-11-18 00:37:11
阅读次数:
206
1. 历史 RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue )的开源实现。AMQP 的出现其实也是应了广大人民群众的需求,虽然在同步消息通讯的世界里有很多公开标准(如 COBAR的 IIOP ,或者是 SOAP 等),但是在异步消息处理中却不是这样,...
分类:
其他好文 时间:
2015-11-17 23:26:39
阅读次数:
213
在上篇文章中,我们解决了从发送端(Producer)向接收端(Consumer)发送“Hello World”的问题。在实际的应用场景中,这是远远不够的。从本篇文章开始,我们将结合更加实际的应用场景来讲解更多的高级用法。 当有Consumer需要大量的运算时,RabbitMQ Server需要一定的...
分类:
其他好文 时间:
2015-11-17 23:17:38
阅读次数:
205
利用RabbitMQ实现生产者和消费者的一个小Demo不做讲解直接上代码importcom.rabbitmq.client.Channel;
importcom.rabbitmq.client.Connection;
importcom.rabbitmq.client.ConnectionFactory;
/**
*单消息队列通道
*Createdbywangtfon2015/11/16.
*生产者
*/
publicclassProduc..
分类:
其他好文 时间:
2015-11-17 19:13:39
阅读次数:
426
1. RabbitMQ简介RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议2.安装与部署RabbitMQ的安装依赖Erlang语言开发包。2.1下载安装Erlang下载:http://www.erlang.org/down...
分类:
其他好文 时间:
2015-11-16 12:19:45
阅读次数:
179
在前面的教程中,我们对日志系统进行了功能强化。我们使用direct类型的交换器并且为之提供了可以选择接收日志的能力,替换了只能傻乎乎的广播消息的fanout类型的交换器。尽管使用direct类型的交换器强化了系统,但是它依然有一些限制,不能基于条件的进行路由。在日志系统中,我们或许希望不仅能根据严重...
分类:
其他好文 时间:
2015-11-15 09:42:13
阅读次数:
379