【http://www.ylzx8.cn/ruanjiangongcheng/software-architecture-design/11922.html】AcitveMQ：消息存储和分发组件，涉及到client与broker端数据交互的方方面面，它不仅要担保消息的存储安全性，还要提供额外的手段来...
分类：
其他好文 时间：
2015-07-07 12:24:51
阅读次数：
1264
一个、整体外观Kafka我们知道。Kafka系统有三大组件：Producer、Consumer、broker 。producers 生产(produce)消息(message)并推(push)送给brokers，consumers从brokers把消息提取(pull)出来消费(consume)。二、...
分类：
其他好文 时间：
2015-07-05 09:28:08
阅读次数：
158
RabbitMQ是一个消息broker。它的主要概念就是接受和转发消息。可以把它当作一个邮局：当向邮箱投递一封邮件时，你确信邮差最终会将这封邮件投递到收件人。使用这个比喻，RabbitMQ就是邮箱，邮局和邮差。RabbitMQ和邮局最大的区别就是它不处理纸质信件而是处理二进制数据--消息R..
分类：
其他好文 时间：
2015-07-04 16:53:06
阅读次数：
105
Trader Dealer Broker 职责和含义 假设你要买100股中石油，而你又没有马仔给你操作，那么你就是那个trader了。 在quote-driven market里，deal都是由dealer发单完成的，他们与你可以理解为对立关系，你希望以低价买，而他们希望以高价卖。他们最担心你是比他...
分类：
其他好文 时间：
2015-07-03 18:54:24
阅读次数：
267
在上面两篇关于mqtt的broker的启动和mqtt的服务端发布主题信息之后，我们客户端需要订阅相关的信息并接收相关的主题信息。Java代码packagecom.etrip.mqtt;importjava.net.URISyntaxException;importorg.fusesource.mqt...
在MQTT官网（http://mqtt.org/software）中有众多MQTT的实现方式。具体参看官网，Moquette是基于Apache Mina 的模型的一个Java MQTT broker。使用过Mina的同学发现其实broker的启动过程就是一个Mina应用的启动。在MQTT moqu....
分类：
其他好文 时间：
2015-07-01 18:04:41
阅读次数：
143
接着上一篇的moquette-mqtt 的使用之broker启动之后，我们需要启动moquette-mqtt 的服务端发布消息。在moquette-mqtt 的mqtt-client中三种方式实现发布消息的方式： 1.采用阻塞式的连接的（BlockingConnection） 2.采用回调式的连接 ...
分类：
其他好文 时间：
2015-07-01 17:52:25
阅读次数：
119
最近学习MQTT协议，选择了当前比较流行的MQTT Broker “mosquitto”，但是在阅读代码过程中发现其网络底层库封装的相当差劲。对于MQTT协议的变长头长度的读取上，基本上采取每次一个byte的方式进行读取判断，对于系统调用read的高代价来讲，真的是相当的浪费，也难怪其不能作为高并发...
分类：
其他好文 时间：
2015-06-18 13:09:01
阅读次数：
512
因现ESB项目都加入了动态配置，接到一需求，通过配置文件或者数据库配置，在一个消息流程定义上动态指定多个输出节点。
以下做了一个简单的小示例。
先定义了一个简单的消息流，MQ输入节点到MQ输出节点。
1.MQ输入节点指定队列名称：XML.IN
2.Compute 计算节点指定输出 队列XML.OUT 、WA.OUT
SET OutputLocalEnvironment.D...
分类：
Web程序 时间：
2015-06-17 15:26:34
阅读次数：
290
Kafka为broker,producer和consumer提供了很多的配置参数。 了解并理解这些配置参数对于我们使用kafka是非常重要的。本文列出了一些重要的配置参数。官方的文档Configuration比较老了，很多参数有所变动， 有些名字也有所改变。我在整理的过程中根据0.8.2的代码也做了...
分类：
其他好文 时间：
2015-06-13 20:09:26
阅读次数：
113
