Reactor模型 Netty中的Reactor模型主要由多路复用器(Acceptor)、事件分发器(Dispat...[作者空间]
每个 ChannelSocket 的 Unsafe 都有一个绑定的 ChannelOutboundBuffer ，...[作者空间]
Netty 版本：4.1.33.Final-SNAPSHOT AbstractNioByteChannel 1、该...[作者空间]
概述 channel 是 netty 网络 IO 操作抽象出来的一个接口，主要功能有：网络IO的读写，客户端发起连...[作者空间]
概述 Netty 中的 ByteBuf 和 NIO 中的 ByteBuffer 的区别。 1、Netty 中的 B...[作者空间]
未写完，待续。。。。 刷盘服务类有三种 同步刷盘时使用 GroupCommitService 异步刷盘时使用 Fl...[作者空间]
创建 MappedFile 文件 创建 MappedFile 文件实现如下： 从代码中可以看出，只有 Mapped...[作者空间]
概述 RocketMQ 支持发送延迟消息，但不支持任意时间的延迟消息的设置，仅支持内置预设值的延迟时间间隔的延迟消...[作者空间]
1、CommitLog 文件生成规则 偏移量：每个 CommitLog 文件的大小为 1G，一般情况下第一个 Co...[作者空间]
producer 发送消息后，broker端开始存储消息，会调用 store 模块的 DefaultMessage...[作者空间]
具体原理，改天在补充[作者空间]
概述 Producer 发送消息，RocketMQ 提供了三种模式。 同步发送 异步发送 OneWay 发送 示例...[作者空间]
MQProducer 从类关系中可以看出，MQProducer 有两种实现方式。一个是 DefaultMQProd...[作者空间]
概述 生产者 producer 在发送消息的时候，每个消息发送到 broker 只存储在某一个 quene 上。那...[作者空间]
概述 RocketMQ 提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker 等信息的管理； 进入...[作者空间]
概述 NameServer 是RocketMQ 消息队列的状态服务器（服务发现功能），集群中的各个服务都需要通过 ...[作者空间]
概述 RocketMQ 底层通讯是使用Netty来实现的。下面我们通过源码分析下RocketMQ是怎么利用Nett...[作者空间]
1、 runAsync 和 supplyAsync方法 CompletableFuture 提供了四个静态方法来创...[作者空间]
这篇文章, 我主要分享JavaWeb动态网页开发.要谈JavaWeb动态网页开发.我们就要来了解Servlet, ...[作者空间]
