1. 相关概念 1/kafka是一个分布式的消息缓存系统2/kafka集群中的服务器都叫做broker3/kafka有两类客户端，一类叫producer（消息生产者），一类叫做consumer（消息消费者），客户端和broker服务器之间采用tcp协议连接4/kafka中不同业务系统的消息可以通过t ...
分类：
其他好文 时间：
2017-03-27 10:48:27
阅读次数：
111
package cn.xiaojf.kafka.producer; import org.apache.kafka.clients.producer.*; import org.apache.kafka.common.Cluster; import org.apache.kafka.common.P... ...
分类：
其他好文 时间：
2017-03-23 03:06:04
阅读次数：
245
package cn.xiaojf.kafka.producer; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import or... ...
分类：
其他好文 时间：
2017-03-23 01:50:52
阅读次数：
249
RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。 RabbitMQ中间件分为服务端（RabbitMQ Server）和客户端（RabbitMQ Client），服务端可以理解为是一个消息的代理消费者，客户端又分为消息生产者（ ...
分类：
其他好文 时间：
2017-03-08 11:27:52
阅读次数：
154
fanout交换器会把发送给它的所有消息发送给绑定在它上面的队列，起到广播一样的效果。 本里使用实际业务中常见的例子， 订单系统：创建订单，然后发送一个事件消息 积分系统：发送订单的积分奖励 短信平台：发送订单的短信 消息生产者SenderWithFanoutExchange 消费消费者Receiv ...
分类：
其他好文 时间：
2016-10-22 23:31:26
阅读次数：
369
1，Rabbitmq工作流程 消息生产者（即下图中的ClientA，ClientB）生产message并交给交换机Exchange，Exchange将消息按照RoutingKey分发到相应的队列Queue中，而我们的消费者（即下图中的Client1，Client2，Client3）需要做的事情就是监 ...
分类：
编程语言 时间：
2016-10-21 07:49:40
阅读次数：
258
这是一个反序列化的过程，也就是对象数据流转换为一个实例的过程，其运行后的输出结果为“混世魔王”。这太easy了,是的，这就是序列化和反序列化的典型Demo。但此处藏着一个问题：如果消息的生产者和消息的消费者（Person类）有差异，会出现何种神奇事件呢？比如：消息生产者中的Person类添加一个年龄... ...
分类：
其他好文 时间：
2016-09-10 17:43:44
阅读次数：
187
RabbitMQ是一个消息代理，从“生产者”接收消息并传递消息至“消费者”，期间可根据规则路由、缓存、持久化消息。“生产者”也即message发送者以下简称P，相对应的“消费者”乃message接收者以下简称C，message通过queue由P到C，queue存在于RabbitMQ，可存储尽可能多的 ...
分类：
其他好文 时间：
2016-08-27 20:44:33
阅读次数：
455
