转载请注明出处：http://www.cnblogs.com/xiaodf/ 本示例展示了一个RocketMQ producer的简单实现，通过解析文本文件获取输入数据，将数据经过Avro序列化后发送到RocketMQ。 程序通过stdin.xml配置文件获取主要参数值，stdin.xml文件内容如 ...
分类：
其他好文 时间：
2016-10-26 14:13:45
阅读次数：
282
本博文的主要内容有 .kafka的官网介绍 http://kafka.apache.org/ 来，用官网上的教程，快速入门。 http://kafka.apache.org/documentation kafka的官网文档教程。 The Producer API allows an applicat ...
分类：
其他好文 时间：
2016-10-16 09:39:30
阅读次数：
434
摘要: 从为什么我们需要消息系统（MQ）讲起，贯穿kafka架构、Producer发布消息、broker存储消息、Consumer消费消息以及 kafka HA等关键知识点，并附上实践中遇到的问题及解决方案。持续更新中…… ...
分类：
其他好文 时间：
2016-10-13 02:31:13
阅读次数：
248
1、简介Kafkaisadistributed,partitioned,replicatedcommitlogservice。它提供了类似于JMS的特性，但是在设计实现上完全不同，此外它并不是JMS规范的实现。kafka对消息保存时根据Topic进行归类，发送消息者成为Producer,消息接受者成为Consumer,此外kafka集群有多个kafka实例组..
分类：
其他好文 时间：
2016-10-12 07:13:03
阅读次数：
285
List<? extend Fruit> list=new ArrayList<>(); 解释为：集合中元素是继承自Fruit，究竟是何种类型，编译器也无法判定。 如果要从集合中读取类型T的数据，并且不能写入，可以使用 ? extends 通配符；(Producer Extends) List<? ...
分类：
编程语言 时间：
2016-10-10 13:46:57
阅读次数：
190
RocketMQ3.2.6安装部署及调用
1、RocketMQ部署架构
所有IP都是127.0.0.1，其中NameServer一个，Broker一个，Producer一个，Consumer一个 ...
分类：
其他好文 时间：
2016-10-10 11:31:07
阅读次数：
148
针对公司业务逻辑，向阿里云MQ发送指定数据，消费端根据数据来做具体的业务，分两个项目，一个生产端（Producer）、一个消费端(Consumer) 生产端通过定时任务执行sql向阿里云MQ发送数据，消费端消费指定Topic上的数据 1：定时任务列表： 2:生产端表结构： aliasName：定时任 ...
分类：
其他好文 时间：
2016-09-30 12:30:12
阅读次数：
613
一、kafka理论1、kafka是神马？kafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发，之后成为Apache项目的一部分。Kafka是一个分布式的，可划分的，冗余备份的持久性的日志服务。它主要用于处理活跃的流式数据。分布式系统，易于向外扩展。所有的producer、broker和con..
分类：
其他好文 时间：
2016-09-29 02:23:19
阅读次数：
198
在上一篇我们分析了Java NIO的原理和使用方式，本篇将进一步分析Kafka client是如何基于NIO构建自己的network层。network层的分层架构下图展示了从最上层的KafkaProd...
分类：
Web程序 时间：
2016-09-28 02:23:24
阅读次数：
316
ProducerConsumer
生产者创建数据，通过中介控制流量并安全传递给消费者。
适用环境
生产者生产数据的速度与消费者处理数据的速度不一致，中介者通过缓存和阻塞对消费者的数据压力进行调整。
样例
4生产者生产产品，放入市场，2消费者消费。
..
分类：
编程语言 时间：
2016-09-27 21:06:27
阅读次数：
241
