kafka生产者线程负责生产消息，而将消息发送给broker是有一个专门的发送者线程来处理的，也称之为IO Thread，实现了消息的生产与发送...

程序中调用kafka生产者发送消息，并不是每调用一次send方法，就直接将消息通过底层网络发送给broker了，而是会将多个消息形成一个批次，然...

在kafka中，生产者发送的消息最终会落在主题下的某个分区，但是很多开发者在使用的过程中其实并没有指定消息发往哪个分区，那么kafka是如何处理...

在netty开发中，当调用pipeline的write方法时，并不会将数据直接写入到底层channel通道发送出去，而是先添加到缓冲区中；只有当...

编解码器指的是转换两种不同格式的数据，在网络编程中几乎是必不可少的。比如将String转成ByteBuf，将Student转成String等等。...

拆包与粘包是网络编程中必会出现的一个问题。因此，本文先介绍下什么是拆包与粘包，然后通过例子演示这个现象，最后再介绍netty中如何处理拆包与粘包...

在netty中，ByteBuf是对字节的封装，对nio的ByteBuffer的增强，用于从socket缓冲区读取和写入数据的。 ByteBuf有...

NioEventLoop的事件循环处理，就是在一个死循环中处理IO事件和队列里的任务，并且可以根据策略来平衡这两者之间的执行比例。 首先，先来看...

上一篇中netty注册流程分析一[https://www.jianshu.com/p/0743e40dee69]，分析到了channel注册到n...