一. Kafka中的相关概念的介绍
Kafka是一个scala实现的分布式消息中间件,其中涉及到的相关概念如下:
Kafka中传递的内容称为message(消息),message 是通过topic(话题)进行分组的 topic 和message 的关系是一对多的关系我们称发布message的进程为producer ,就是说producer生成message>对然...
分类：
其他好文 时间：
2014-11-13 22:37:11
阅读次数：
353
笔者使用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
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
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
#include #include "stdio.h"#include #include #define N_CONSUMER 3 //消费者数量#define N_PRODUCER 2 //生产者数量#define C_SLEEP 1 //控制 consumer 消费的节奏#define P_SL...
分类：
编程语言 时间：
2014-11-05 21:06:30
阅读次数：
204
生产者-消费者问题（Producer-consumer problem），也称作有限缓冲问题（Bounded-buffer problem），是多线程领域的一个经典问题，可以描述为：两个或者更多个线程共享同一个缓冲区，其中一个或多个作为“生产者”会不断地向缓冲区中添加数据，另外的一个或者多个作为.....
分类：
编程语言 时间：
2014-11-03 12:44:30
阅读次数：
147
public class ShengChanZheXiaoFeiZhe {
public static void main(String[] args) {
Container c = new Container();
BulletProducer producer = new BulletProducer(c);
BulletConcumer consumer = new BulletConcumer(c);
Thread t1 = new Thread(producer);
Th...
分类：
编程语言 时间：
2014-10-27 21:21:29
阅读次数：
251
Kafka 分布式消息队列 类似产品有JBoss、MQ一、由Linkedln 开源，使用scala开发，有如下几个特点：（1）高吞吐（2）分布式（3）支持多语言客户端 （C++、Java）二、组成: 客户端是 producer 和 consumer，提供一些API，服务器端是Broker，客户端提供...
分类：
其他好文 时间：
2014-10-23 16:13:44
阅读次数：
199
多线程是一个很重要的应用，本节讲述多线程中同步问题public class ThreadDemo { public static void main(String[] args) { Resource r = new Resource(); Producer p1 ...
分类：
编程语言 时间：
2014-10-23 14:04:36
阅读次数：
142
