netty通信之rpc

netty通信之rpc客户端

netty通信roc之服务端

RocketMQ是队列模型的消息中间件，具有高性能，高可靠，高实时，分布式的特点。同时支持分布式事物的两阶段提交，实现在分布式环境的事物操作。 1，nameserv是分布式的部署，并且相互之间不通...

这里根据RocketMQ的前期操作将整理Broker的存储设计及核心层次关系，先上图，根据源码的分析及整理，最终的核心层级关系如下： 1，通信层采用netty来进行网络的接受及处理 2，核心的处理有针...

根据消息的拉取代码，broker端的大体操作步骤如下，主要进行pullMessage 1，构建netty协议的响应体，主要是返回数据用，后期的操作是基于该对象进行内容填充 2，构造响应头对象，从请求体中解...

这章我们从broker接受到消息后的处理，从源码加注解的角度解析整体处理及技术，整体的处理步骤如下： sendMessage 1，消息协议转换，主要是兼容协议版本 2，验证消息的正确性，主要是当前bro...

Broker的BrokerController的初始化中比较核心的就是MessageStore的初始化操作，这章我们根据源码的加载顺序详细的解析MessageStore的初始化及加载操作，涉及到Broker的高性能技术及设计，找到...

接着上一章的BrokerController的基础功能讲，本章主要介绍的是BrokerController的初始化操作，在初始化的过程中做了哪些事情，使用了哪些技术设计完成了对broker的初始化操作。一切分析都是基...

broker的入口管理服务类BrokerController，在该类中定义并初始化了整个broker需要的核心操作。broker在接口请求处理的过程中，涉及到四方服务的数据交互：namesrv服务，进行发布当前broker的...

这里先从整体的执行请求流程进行梳理，然后针对broker的实现细节再做深入优化 RocketMQ的整体事件操作步骤为： producer -> netty -> broker -> netty -> consumer 先从整体的一张大图上看，...

broker的功能比较重要，体现了很多高性能的功能及技术，这里会分的比较细来介绍和源码解释 首先将broker的整体初始化，启动类的逻辑调用顺序捋顺，下图是整体的逻辑图 分为三个主要阶段 1，构...

consumer的核心，特别是push性的消息拉取，实现自动感知，自动拉取消息的操作 核心的启动在拉取消息的自动任务执行，核心思想如下 拉取消息任务-》根据订阅信息、消费消息位置-》组装请求协议...

consumer的常规订阅消息的总体操作流程： 构造初始化-》注册监听-》启动-》无限循环请求队列-》长连接的数据拉取 一，构造初始化 DefaultMQPushConsumer：常规的订阅消息，需要制定唯一的分组...

基于consumer的启动流程，前期先基于类的顺序图来说明，可以一目了然，然后再基于源码进行分析 consumer的核心操作类： DefaultMQPushConsumer： MessageListener：消息监听，接受消息做处理...

细节一，消息发送前，需要获得topic的发布配置信息 TopicPublishInfo topicPublishInfo = this.tryToFindTopicPublishInfo(msg.getTopic());//获得消息发布的topic配置信息 private TopicPub...

前提：rocketmq的broker是重点，里面涉及到最终的性能及技术实现，放置到最后，后面的章节会根据操作不同，穿插和功能相关的说明 producer的操作，我们这里先做基本的操作，就是我们说的快速...

netty的标准设计流程为：编码，解码，检测，链接，其他handler，业务。按照这个流程将rocketmq的netty的实现流程进行细化。 编码 NettyEncoder 继承MessageToByteEncoder，netty的编码规范要...

netty的服务端核心属性 public class NettyRemotingServer extends NettyRemotingAbstract implements RemotingServer { private static final InternalLogger log = InternalLoggerFactory...

这里介绍的都是有一定netty基础的，如果没有可以从网上找一个netty的入门 涉及到两个方面的操作，一是服务端，二是客户端 大体的类关系如图 根据netty的整理通信，可以大体整理的调用示意图如...