kafka生产者线程负责生产消息，而将消息发送给broker是有一个专门的发送者线程来处理的，也称之为IO Thread，实现了消息的生产与发送解耦，提高吞吐量。 IO Th...
发简信
IP属地：辽宁
kafka生产者线程负责生产消息，而将消息发送给broker是有一个专门的发送者线程来处理的，也称之为IO Thread，实现了消息的生产与发送解耦，提高吞吐量。 IO Th...
程序中调用kafka生产者发送消息，并不是每调用一次send方法，就直接将消息通过底层网络发送给broker了，而是会将多个消息形成一个批次，然后再以批次的形式，发送给bro...
在kafka中，生产者发送的消息最终会落在主题下的某个分区，但是很多开发者在使用的过程中其实并没有指定消息发往哪个分区，那么kafka是如何处理的呢？ 在kafka中，消息主...
在netty开发中，当调用pipeline的write方法时，并不会将数据直接写入到底层channel通道发送出去，而是先添加到缓冲区中；只有当调用flush方法，才会真正将...
编解码器指的是转换两种不同格式的数据，在网络编程中几乎是必不可少的。比如将String转成ByteBuf，将Student转成String等等。 netty中，编码器处理的是...
拆包与粘包是网络编程中必会出现的一个问题。因此，本文先介绍下什么是拆包与粘包，然后通过例子演示这个现象，最后再介绍netty中如何处理拆包与粘包 所谓的拆包就是发送方发送一条...
在netty中，ByteBuf是对字节的封装，对nio的ByteBuffer的增强，用于从socket缓冲区读取和写入数据的。 ByteBuf有基于堆内存和直接内存的，若是堆...
NioEventLoop的事件循环处理，就是在一个死循环中处理IO事件和队列里的任务，并且可以根据策略来平衡这两者之间的执行比例。 首先，先来看下selectStrategy...
上一篇中netty注册流程分析一[//www.greatytc.com/p/0743e40dee69]，分析到了channel注册到nioEventLoop中了，接...
在之前的这篇文章有讲述三者的关系[//www.greatytc.com/p/84b0456f4f83]，本文主要讲解下三者的一些重要方法及方法的调用关系 先看下Ch...
netty的自适应缓冲区用于接收从channel读取的数据，且可以动态调整缓冲区大小，减少内存的浪费。当连续两次读取的字节数小于当前缓冲区大小时，就会缩小，当读取的字节数刚好...
从本文开始，来分析下springmvc几个重要组件是如何工作的。 首选，来看下HandlerMapping 这个接口主要有这个方法，通过request获取一个HandlerE...
在之前的文章说过，springmvc在要初始化spring容器时，会提前注册一个监听器，当spring容器完成刷新后，此监听器的回调方法会收到回调通知，会执行如下方法 这个方...
在前文知道了，DispatcherServlet的init方法是springmvc项目初始化的入口，init方法内部又调用了initServletBean configure...
springmvc的启动流程分析一 在servlet3.0以前，启动一个springmvc项目，需要在classpath目录下web-inf目录新建一个web.xml文件，然...
异常解析器也是springmvc的一个非常重要组件，在编写程序代码时，若抛出异常了，那么springmvc是通过异常解析器来获取异常并进行后续的处理 看下接口定义的方法 入参...
会发送，有时间阈值和空间阈值，满足其中一个就会发送
springmvc源码分析-HandlerMapping工作流程之前的一篇HandlerMapping初始化流程[//www.greatytc.com/p/b43fe22546ab]，讲述了HandlerMapping的初始化流...
springmvc中HandlerAdapter用于执行具体的Handler，也就是controller，是springmvc中一个特别重要的组件，先来看下接口定义的方法 方...
之前的一篇HandlerMapping初始化流程[//www.greatytc.com/p/b43fe22546ab]，讲述了HandlerMapping的初始化流...
spring容器管理的bean中，有一种比较特殊的类型FactoryBean，这种类型的bean，自身即是一个bean对象，也能产生其他类型的bean对象，通过接口方法便可得...