准备开始 高级消息队列协议(AMQP1)是一个异步消息传递所使用的应用层协议规范。作为线路层协议,而不是API(例如JMS2),AMQP客户端能够无视消息的来源任意发送和接受信息。现在,已经有相当一部分不同平台的服...
分类:
其他好文 时间:
2015-01-07 13:22:49
阅读次数:
340
线上服务器清理的差不多了,准备做一下服务器分层架构,就是将LNMP环境分离开,用到了LB集群,先来点理论吧。负载均衡LB集群主要关注的是并发处理能力,常用的有:LVS、nginx、haproxy。LVS是基于四层的负载均衡,不支持复杂特性的负载均衡,转发效率比7层略高nginx、haproxy都..
分类:
其他好文 时间:
2015-01-06 18:11:34
阅读次数:
336
在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成。那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会通过其它节点求来斐波纳契完成示例。1. 客户端接口 Client interface 为了展示一个R...
分类:
其他好文 时间:
2015-01-06 15:30:25
阅读次数:
161
在上篇文章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