一、整体看一下Kafka
我们知道,Kafka系统有三大组件:Producer、Consumer、broker 。
producers 生产消息并推(push)送给brokers,consumers从brokers把消息提取(pull)出来。
二、开发一个Producer应用
Producers用来生产消息并把产生的消息推送到Kafka...
分类:
其他好文 时间:
2014-07-10 23:07:37
阅读次数:
263
Kafka是一个分布式的消息中间件,可以粗略的将其划分为三部分:Producer、Broker和Consumer。其中,Producer负责产生消息并负责将消息发送给Kafka;Broker可以简单的理解为Kafka集群中的每一台机器,其负责完成消息队列的主要功能(接收消息、消息的持久化存储、为Consumer提供消息、消息清理.....);Consumer从Broker获取消息并进行后续的操作。...
分类:
其他好文 时间:
2014-06-27 23:55:13
阅读次数:
387
微软近期Open的职位:Role Based in Shanghai, ChinaTitle: ProducerWe are seeking a Senior Producer to lead Production & Operations in the China region based in ...
分类:
其他好文 时间:
2014-06-27 16:28:42
阅读次数:
201
For a period before the recent nationwide gold industry shutdown, Duration was Zimbabwe’s second largest gold producer. Up until that point, it had en...
分类:
其他好文 时间:
2014-06-25 23:20:27
阅读次数:
274
介绍RabbitMQ是一个消息代理。它的核心原理非常简单:接收和发送消息。专有名词生产(Producing)意思就是发送。发送消息的程序就是一个生产者(producer)。我们一般用"P"来表示:队列(queue)就是邮箱的名称。消息通过你的应用程序和RabbitMQ进行传输,它们能够只存储在一个队...
分类:
其他好文 时间:
2014-06-20 20:45:02
阅读次数:
179
生产者-消费者模型是多线程问题里面的经典问题,也是面试的常见问题。有如下几个常见的实现方法:1.
wait()/notify()2. lock & condition3. BlockingQueue下面来逐一分析。1.
wait()/notify()第一种实现,利用根类Object的两个方法wait...
分类:
编程语言 时间:
2014-06-16 09:37:57
阅读次数:
314
1. kafka是一个分布式的消息发布-订阅队列。2. 其中有一些主要的概念: Topic:
就是对放入队列的消息进行分类,分类消息分开储存,比如现在有订单消息和用户投诉消息,则分成订单topic和投诉topic Message:
放入消息队列的一条一条的消息。 Producer: 消息的生...
分类:
其他好文 时间:
2014-05-24 11:45:13
阅读次数:
236
eventloop 用作 non-blockingIO 和定时器。threadpool
用来做计算,具体可以是任务队列或消费者-生产者队列任务对列,生产消费者 线程池TaskQueue、Producer-Consumer Queue、
CountDownLatchPTHREAD_MUTEX_ERRO...
分类:
其他好文 时间:
2014-05-08 10:09:52
阅读次数:
241