ChannelHandler
本章主要内容
Channel
ChannelHandler
ChannePipeline
ChannelHandlerContext
我们在上一章研究的 ByteBuf 是一个用来“包装”数据的容器。在本章我们将探讨这些容器是如何在应用程序中进行传输的，以及如何处理它们“包装”的数据。
Nett
...
ByteBuf
正如我们先前所指出的，网络数据的基本单位永远是 byte(字节)。Java NIO 提供 ByteBuffer 作为字节的容器，但它的作用太有限，也没有进行优化。使用ByteBuffer通常是一件繁琐而又复杂的事。
幸运的是，Netty提供了一个强大的缓冲实现类用来表示字节序列以及帮助你操作字节和自
...
Vim
所有的 Unix Like 系统都会内建 vi 文书编辑器，其他的文书编辑器则不一定会存在。
但是目前我们使用比较多的是 vim 编辑器。
vim 具有程序编辑的能力，可以主动的以字体颜色辨别语法的正确性，方便程序设计。
什么是 vim？
Vim是从 vi 发展出来的一个文本编辑器。代码补完、编译及错误跳转等方便编程的功能特别丰富，在程序员中被广泛使用。
简单的来说， vi 是老式的字处理器，不过功能已经很齐全了，但是还是有可以进步的地方。 vim 则可以说是程序开发者的一项很好用的工具。
kafka Stream API（未完）
KStream APIfilter123org.apache.kafka.streams.kstream.KStreamKStream<K, V> filter(Predicate<? super K, ? super V> predicate)
创建一个新的 KStream
...
kafka Stream
Kafka Stream背景Kafka Stream是什么Kafka Stream是Apache Kafka从0.10版本引入的一个新Feature。它是提供了对存储于Kafka内的数据进行流式处理和分析的功能。
Kafka Stream的特点如下：
Kafka Stream提供了一个非常简单而轻
...
kafka消费者客户端（0.10.0.1API）
Kafka Consumer1public class KafkaConsumer<K,V> extends Object implements Consumer<K,V>
Kafka客户端从集群中消费消息，并透明地处理kafka集群中的故障服务器，透明地调节适应集群中变化的
...
kafka生产者客户端（0.10.1.1API）
KafkaProducer 0.10.1.1 API 和0.9.0.0的API没有什么区别。
kafka客户端发布record(消息)到kafka集群。新的生产者是线程安全的，在线程之间共享单个生产者实例，通常单例比多个实例要快。
一个简单的例子，使用producer发送一个有序的key/val
...
kafka QuickStart
Step 1: 下载代码下载0.10.0.0版本并且解压它。
12$ tar -xzf kafka_2.11-0.10.0.0.tgz $ cd kafka_2.11-0.10.0.0
Step 2: 启动服务运行kafka需要使用Zookeeper，所以你需要先启动Zookeeper，如果你没有Z
...
Zookeeper 的服务器角色
LeaderLeader服务器是Zookeeper集群工作的核心，其主要工作如下
事务请求的唯一调度和处理者，保证集群事务处理的顺序性。
集群内部各服务器的调度者
请求处理链使用责任链来处理每个客户端的请求时Zookeeper的特色，Leader服务器的请求处理链如下
PrepRequest
...
Zookeeper 数据与存储
内存数据Zookeeper的数据模型是树结构，在内存数据库中，存储了整棵树的内容，包括所有的节点路径、节点数据、ACL信息，Zookeeper会定时将这个数据存储到磁盘上。
DataTree
DataTree是内存数据存储的核心，是一个树结构，代表了内存中一份完整的数据。DataTree不包含任何
...