原文地址：http://www.aboutyun.com/thread-9938-1-1.html问题导读1.Kafka提供了Producer类作为java producer的api,此类有几种发送方式？2.总结调用producer.send方法包含哪些流程？3.Producer难以理解的在什么地方...
分类：
Web程序 时间：
2014-12-24 13:08:58
阅读次数：
189
一、工厂方法模式
简单工厂模式的缺陷就是类的创建太过于依赖工厂，一旦需要进行程序扩展，就必须修改工厂类的代码
这违背了背包原则。
而工厂方法模式针对这一问题进行了改进。
public interface Sender {
public void send();
}
public interface producer {
public Sender produce();
}
...
分类：
其他好文 时间：
2014-12-21 00:44:42
阅读次数：
186
In this tutorial, we show simple implementations of barriers and producer-consumer queues using ZooKeeper. We call the respective classes Barrier and ...
分类：
其他好文 时间：
2014-12-14 14:24:59
阅读次数：
385
1 class PCDemo 2 { 3 public static void main(String[] args) 4 { 5 Resource r = new Resource(); 6 Producer prd = new Produce...
分类：
其他好文 时间：
2014-12-11 20:37:02
阅读次数：
154
多线程： 生产与消费1.生产者Producer生产produce产品，并将产品放到库存inventory里；同时消费者Consumer从库存inventory里消费consume产品。2.库存inventory的总量（最大库存量100）是有限的。如果库存inventory满了，生产者不能在库存inv...
分类：
编程语言 时间：
2014-11-27 14:12:17
阅读次数：
225
总结一下几种ExchangeTypes。之前写发布/订阅模式时第一次提到了exchange type。即producer不是将消息直接放到队列中，而是先到exchange中，exchange主要用于控制消息到队列的路由,根据具体的exchange type将消息传给需要的队列或者直接废弃。在这一篇中...
分类：
其他好文 时间：
2014-11-23 20:13:14
阅读次数：
226
broker.id整数，建议根据ip区分 log.dirskafka存放消息文件的路径，默认/tmp/kafka-logsportbroker用于接收producer消息的端口 zookeeper.connnectzookeeper连接格式为 ip1:port,ip2:port,ip3:portme...
分类：
其他好文 时间：
2014-11-23 14:25:35
阅读次数：
210
问题现象RocketMQ3.2.2版本，测试时尝试发送消息时自动创建Topic，设置了队列数量为8：producer.setDefaultTopicQueueNums(8);同时设置broker服务器的配置文件broker.properties：defaultTopicQueueNums=16但实际创建后从控制台及后台打印代码观察到该Topic只创建了4个队列，反..
分类：
其他好文 时间：
2014-11-22 02:09:11
阅读次数：
9396
//Java Thread producer customerclass ThreadTest{ public static void main(String[] args) { Q q=new Q(); Producer p=ne...
分类：
编程语言 时间：
2014-11-21 01:26:41
阅读次数：
176
前言：昨天尝试用Java自行实现生产者消费者问题（Producer-Consumer Problem），在coding时，使用到了Condition的await和signalAll方法，然后顺便想起了wait和notify，在开发中遇到了一个问题：wait、notify等阻塞和恢复的时机分别是什么？...
分类：
编程语言 时间：
2014-11-19 18:19:32
阅读次数：
170
