queue.declare即申请队列，首先对队列名作处理，若未指定队列名则随机生成一个，然后查询数据库队列是否已经创建，若创建完成则会申请队列返回handle_method(#'queue.declare'{queue = QueueNameBin, ...
分类：
其他好文 时间：
2015-07-22 09:14:26
阅读次数：
91
最近一个项目用到rabbitmq，为了赶测试进度，只好自己搭建环境了。服务器是CentOS6.5，安装流程基本按官网文档流程，参见Rabbitmq安装。但也有几个步骤略有不同。首先是要安装erlangyuminstallerlang这个过程比较长，我的服务器总共安装了64个相关程序，具体干嘛用的也没弄清楚..
分类：
其他好文 时间：
2015-07-21 15:08:30
阅读次数：
110
1什么是RabbitMQ？RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然：单向解耦双向解耦（如：RPC...
分类：
其他好文 时间：
2015-07-20 19:14:59
阅读次数：
110
1、如果写错了host （如：factory.setHost("locathost"); ）报错：
Exception in thread "main" java.net.UnknownHostException: locathost
at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:195)
at java.net.S...
分类：
其他好文 时间：
2015-07-20 10:53:18
阅读次数：
1031
二、Remote procedure call (RPC)(using the Java client)三、Client interface（客户端接口）为了展示一个RPC服务是如何使用的，我们将创建一段很简单的客户端class。 它将会向外提供名字为call的函数，这个call会发送RPC请求并且...
分类：
其他好文 时间：
2015-07-19 18:02:47
阅读次数：
148
二、Routing(路由) (using the Java client) 在前面的学习中，构建了一个简单的日志记录系统，能够广播所有的日志给多个接收者，在该部分学习中，将添加一个新的特点，就是可以只订阅一个特定的消息源，也就是说能够直接把关键的错误日志消息发送到日志文件保存起来，不重要的日志信息文...
分类：
其他好文 时间：
2015-07-19 18:01:26
阅读次数：
232
一、基础概念详细介绍1、引言你是否遇到过两个（多个）系统间需要通过定时任务来同步某些数据？你是否在为异构系统的不同进程间相互调用、通讯的问题而苦恼、挣扎？如果是，那么恭喜你，消息服务让你可以很轻松地解决这些问题。消息服务擅长于解决多系统、异构系统间的数据交换（消息通知/通讯）问题，你也可以把它用于系...
分类：
其他好文 时间：
2015-07-19 17:59:46
阅读次数：
132
二、Topic(主题) (using the Java client)上一篇文章中，我们进步改良了我们的日志系统。我们使用direct类型转发器，使得接收者有能力进行选择性的接收日志,，而非fanout那样，只能够无脑的转发。为了在我们的系统中实现上述的需求，我们需要学习稍微复杂的主题类型的转发器（...
分类：
其他好文 时间：
2015-07-19 17:59:25
阅读次数：
143
柯南君：看大数据时代下的IT架构（4）消息队列之RabbitMQ--案例（Helloword起航） 二、起航 本章节，柯南君将从几个层面，用官网例子讲解一下RabbitMQ的实操经典程序案例，让大家重新回到经典“Hello world！”（The simplest thing that do...
分类：
其他好文 时间：
2015-07-19 17:57:25
阅读次数：
276
二、Publish/Subscribe（发布/订阅）（using the Java Client） 为了说明这个模式,我们将构建一个简单的日志系统。它将包括两个项目： 第一个将发出日志消息 第二个将接收并打印它们。 注：从本质上讲,发表日志消息广播给所有的接收者。 下面让我们脑中带几个问题，让我们一...
分类：
其他好文 时间：
2015-07-19 17:53:24
阅读次数：
183
