Reactor模型 Netty中的Reactor模型主要由多路复用器(Acceptor)、事件分发器(Dispatcher)、事件处理器(Han...
Reactor模型 Netty中的Reactor模型主要由多路复用器(Acceptor)、事件分发器(Dispatcher)、事件处理器(Han...
每个 ChannelSocket 的 Unsafe 都有一个绑定的 ChannelOutboundBuffer , Netty 向站外输出数据的...
Netty 版本:4.1.33.Final-SNAPSHOT AbstractNioByteChannel 1、该类定义了一个 flushTas...
概述 channel 是 netty 网络 IO 操作抽象出来的一个接口,主要功能有:网络IO的读写,客户端发起连接、主动关闭连接,链路关闭,获...
概述 Netty 中的 ByteBuf 和 NIO 中的 ByteBuffer 的区别。 1、Netty 中的 ByteBuf 支持动态的扩容和...
未写完,待续。。。。 刷盘服务类有三种 同步刷盘时使用 GroupCommitService 异步刷盘时使用 FlushRealTimeServ...
创建 MappedFile 文件 创建 MappedFile 文件实现如下: 从代码中可以看出,只有 MappedFile 的大小等于或大于 C...
概述 RocketMQ 支持发送延迟消息,但不支持任意时间的延迟消息的设置,仅支持内置预设值的延迟时间间隔的延迟消息。 预设值的延迟时间间隔为:...
1、CommitLog 文件生成规则 偏移量:每个 CommitLog 文件的大小为 1G,一般情况下第一个 CommitLog 的起始偏移量为...
producer 发送消息后,broker端开始存储消息,会调用 store 模块的 DefaultMessageStore.putMessag...
专题公告
java从菜鸟到大神的成神之路学习路线
公众号:jijs_java