1、ActiveMQ服务器工作模型 通过ActiveMQ消息服务交换消息。消息生产者将消息发送至消息服务，消息消费者则从消息服务接收这些消息。这些消息传送操作是使用一组实现 ActiveMQ应用编程接口 (API) 的对象来执行的。 ActiveMQ客户端使用 ConnectionFactory 对 ...
分类：
其他好文 时间：
2016-08-19 12:51:10
阅读次数：
149
这里主要分析kafka 客户端实现 (代码分析以perl kafka实现为准) kafka客户端分为生产者和消费者,生产者发送消息,消费者获取消息. 在kafka协议里客户端通信中用到的最多的四个协议命令是fetch,fetchoffset,send,metadata.这四个分别是获取消息,获取of ...
分类：
其他好文 时间：
2016-08-12 19:54:20
阅读次数：
148
上篇文章讲了简单队列的使用，这其实就是RMQ给的demo，实际并没有什么用 本篇讲讲工作模式队列，也称之为任务队列 一个生产者发布了多条消息，消费者A可以接受消息，接受消息后该消息就消除，消费者B可以接受其他消息 使用场景，一些数据库操作比较缓慢的话可以分别给多个接口调用，降低压力，或者抢单场景也能 ...
分类：
其他好文 时间：
2016-05-22 15:19:33
阅读次数：
149
1.点对点传递消息模式： 点对点：必须有一个消息生产者和一个消息消费者。其中消费者可以设置一个监听器来监听生产者有没有生产出消息。 下面将代码贴出来： 生产者： 消费者： 消费者绑定的监听器： 2.发布/订阅者模式 上面的点对点只能有一个生产者和一个消费者，要是有两个消费者，这代表着一个消费者将收不 ...
分类：
其他好文 时间：
2016-05-03 00:12:25
阅读次数：
247
告警系统架构如下 1、 数据处理系统处理完原始数据并入库后，发送消息到kafka系统； 2、 告警生产者从kafka系统查询消息存入告警消息队列； 3、 告警消费者从告警消息队列查询消息进行处理。 这显然是生产者消费者模型，一个告警消息生产者，多个告警消息消费者。生产者生产消息过快会产生消息积压，生 ...
分类：
其他好文 时间：
2016-04-24 18:49:17
阅读次数：
139
前面讲过JMSCorrelationID主要是用来关联多个Message，例如需要回复一个消息的时候，通常把回复的消息的JMSCorrelationID设置为原来消息的ID。在下面这个例子中，创建了三个消息生产者A，B，C和三个消息消费者A，B，C。生产者A给消费者A发送一个消息，同时需要消费者A给 ...
分类：
其他好文 时间：
2016-04-09 09:12:27
阅读次数：
170
前面的例子中创建一个消息消费者使用的是: sesssion.createConsumer(destination) 另外，还提供了另一种方式： sesssion.createConsumer(destination, selector) 这里selector是一个字符串，用来过滤消息。也就是说，这种 ...
分类：
其他好文 时间：
2016-04-09 09:11:09
阅读次数：
166
简单说kafka是一个高吞吐的分部式消息系统kafka的架构? producer：消息生存者? consumer：消息消费者? broker：kafka集群的server，负责处理消息读、写请求，存储消息? topic：消息队列/分类? Queue里面有生产者消费者模型? broker就是代理，在k...
分类：
其他好文 时间：
2016-01-19 20:54:59
阅读次数：
245
rabbitMQ是一种高性能的消息队列，支持或者说它实现了AMQP协议（advanced message queue protocol高级消息队列协议）。下面简单讲一讲一个小例子。我们首先要部署好rabbitMQ，然后实现一个生产者—消费者，生产者向rabbit中发布一个消息，消费者去rabbit取...
分类：
其他好文 时间：
2016-01-14 00:50:55
阅读次数：
351
apache kafka参考http://kafka.apache.org/documentation.html消息队列方式：点对点：消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。这里要注意：消息被消费以后，queue中不再有存储，所以消息消费者不可能消费到已经...
分类：
其他好文 时间：
2016-01-08 00:22:22
阅读次数：
182
