笔者使用ActiveMQ作为系统中消息分发的服务器，由Java Web程序读取数据库实时记录作为Producer，接收端为C++Builder开发的客户端程序，常驻客户端右下角，弹窗显示实时消息。
测试时发现，当客户端断网（网线拔掉）或者服务器重启等连接中断时，客户端会直接退出，windows也没有报程序崩溃的问题，很是费解。
Debug调试代码发现问题出在自定义的Concumer...
分类：
其他好文 时间：
2014-11-12 11:50:25
阅读次数：
364
1 #include 2 #include 3 #include 4 #include 5 #include 6 7 #define NumOf_Producer 5 //the max num of producer 8 #define NumOf_Consumer 10 ...
分类：
编程语言 时间：
2014-11-11 22:31:26
阅读次数：
296
PartitionManager算是storm-kafka核心的代码了，主要负责message读取、发送、容错处理等等...
分类：
其他好文 时间：
2014-11-09 22:18:01
阅读次数：
435
Linux 进程间通信（posix消息队列 简单）实例详情见： http://www.linuxidc.com/Linux/2011-10/44828.htm编译：gcc -o consumer consumer.c -lrtgcc -o producer producer.c -lrt/* * *...
分类：
系统相关 时间：
2014-11-08 23:33:06
阅读次数：
364
详细介绍如何自定义KafkaSpout发射的message...
分类：
其他好文 时间：
2014-11-08 15:21:19
阅读次数：
174
详细分析了KafkaSpout的一些代码，希望能够帮助一下人，同时也是自己看代码的一个总结。...
分类：
Web程序 时间：
2014-11-08 15:20:40
阅读次数：
518
详细介绍了Storm-Kafka模块中Config的相关配置信息，就是扫盲的一篇介绍而已...
分类：
其他好文 时间：
2014-11-08 15:19:54
阅读次数：
220
上一节介绍了config的相关信息，这一节说下如何创建一个KafkaSpout而已...
分类：
Web程序 时间：
2014-11-08 15:19:01
阅读次数：
311
threading
time
Producer(threading.Thread):
run(self):
count
True:
con.acquire():
count>1000:
con.wait()
:
count=count+100
msg=self.name++str(count)
msg
con.notify()
con.release()
time.sleep(1)
Consumer(threading.Thread):
run(self):
count
True:
con.acqu..
分类：
编程语言 时间：
2014-11-06 17:47:36
阅读次数：
239
http://stackoverflow.com/questions/23228222/running-into-leadernotavailableexception-when-using-kafka-0-8-1-with-zookeeper-3
Kafka uses an external coordination framework (by default Zookeeper) t...
分类：
Web程序 时间：
2014-11-06 13:09:23
阅读次数：
1423
