概念： 生产者（Producer，简写P），负责发布消息。 “交换机”（Exchange, 简写X）， 负责中转消息。 路由（Route， 简写R）， 即 X->Q的路线名。 消息队列 (Queue, 简写Q）， 负责临时存储消息。 消费者（Customer，简写C）， 负责处理消息。 完整关系图解 ...
分类：
其他好文 时间：
2016-08-24 12:42:26
阅读次数：
140
代理模式 使用代理模式可以在不改变原有对象的基础上对该对象的某些行为进行增强。 现实生活中有许多例子，比如说代理商，厂家批发给代理商，代理商负责给厂家销售，代理商作为中介完成了消费者和厂家进行交互的行为。 静态代理 UML类图如下所示： 说明：Producer是衣服厂家和衣服专卖店的一个抽象，Clo ...
分类：
其他好文 时间：
2016-08-20 16:25:59
阅读次数：
194
图示 其中P指producer，即生产者；C指consumer，即消费者。中间的红色表示消息队列，实例中表现为HELLO队列。 往队列里插入数据前，查看消息队列 插入消息队列代码 #in_queue.py 执行结果 此时查看消息队列 可以看到队列HELLO里面有10条数据。 读取消息队列数据 #ou ...
分类：
编程语言 时间：
2016-08-16 01:49:10
阅读次数：
311
kafka版本0.8.2.1 Java客户端版本0.9.0.0 为了更好的实现负载均衡和消息的顺序性，Kafka Producer可以通过分发策略发送给指定的Partition。Kafka保证在partition中的消息是有序的。Kafka Java客户端有默认的Partitioner。实现如下： ...
分类：
其他好文 时间：
2016-08-06 14:12:38
阅读次数：
524
Maven 依赖 GitHub https://github.com/rabbitmq/rabbitmq-java-client/archives/master 文档 http://www.rabbitmq.com/getstarted.html 基本概念理解 A producer a progra ...
分类：
编程语言 时间：
2016-08-06 08:25:33
阅读次数：
153
我使用的kafka版本是：0.7.2 jdk版本是：1.6.0_20 http://kafka.apache.org/07/quickstart.html官方给的示例并不是很完整，以下代码是经过我补充的并且编译后能运行的。 分布式发布订阅消息系统 Kafka 架构设计 http://www.linu ...
分类：
其他好文 时间：
2016-08-01 15:43:58
阅读次数：
128
线程使用 Queue队列 生产者消费模型 生产者消费者问题（英语：Producer-consumer problem），也称有限缓冲问题（英语：Bounded-buffer problem），是一个多线程同步问题的经典案例。该问题描述了两个共享固定大小缓冲区的线程——即所谓的“生产者”和“消费者”— ...
分类：
编程语言 时间：
2016-07-23 07:25:32
阅读次数：
594
之前感觉很简单，但是有一次面试让我在纸上写，居然没写对丢人啊。 生产者消费者问题（Producer-consumer problem）：生产者不断地生产产品，消费者取走生产者生产的产品。生产者生产出产品后将其放到一个区域之中，消费者从这个地方去除数据。 涉及的问题：要保证生产者不会在缓冲区满时加入数 ...
分类：
编程语言 时间：
2016-07-21 12:36:02
阅读次数：
198
kafka学习之路（二）——提高
消息发送流程
因为Kafka内在就是分布式的，一个Kafka集群通常包括多个代理。为了均衡负载，将话题分成多个分区，每个代理存储一或多个分区。多个生产者和消费者能够同时生产和获取消息。
过程：
1.Producer根据指定的partition方法（round-robin、hash等），将消息发布到指定topic的partition里...
分类：
其他好文 时间：
2016-07-17 17:17:48
阅读次数：
273
（可能会有很多错误，请谨慎阅读，如果本人发现会及时更新）。
最近在学习多线程编程，周末的时候用java写了一个生产者消费模型，这里做一些记录和总结。基本模板Producer
while(true)
data = generateData()
queue.enqueue(data)Consumer
while(true)
data = queue.dequeue()m...
分类：
其他好文 时间：
2016-07-17 17:04:58
阅读次数：
237
