思维导图备注

RocketMQ实战与原理解析
首页 收藏书籍 阅读记录
  • 书签 我的书签
  • 添加书签 添加书签 移除书签 移除书签

13.4.3 基于Netty的Server和Client

浏览 6 扫码
  • 小字体
  • 中字体
  • 大字体
2022-01-24 10:32:39
请 登录 再阅读
上一篇:
下一篇:
  • 书签
  • 添加书签 移除书签
  • 推荐序
  • 前言
  • 第1章 快速入门
    • 1.1.1 应用解耦
    • 1.2 RocketMQ简介
    • 1.1.3 消息分发
    • 1.3 快速上手RocketMQ
      • 1.3.2 启动消息队列服务
      • 1.3.4 关闭消息队列
    • 1.4 本章小结
  • 第2章 生产环境下的配置和使用
    • 2.1 RocketMQ各部分角色介绍
    • 2.2 多机集群配置和部署
    • 2.2.2 配置参数介绍
    • 2.4 常用管理命令
    • 2.5 通过图形界面管理集群
    • 2.6 本章小结
  • 第3章 用适合的方式发送和接收消息
    • 3.1 不同类型的消费者
      • 3.1.1 DefaultMQPushConsumer的使用
      • 3.1.2 DefaultMQPushConsumer的处理流程
      • 3.1.3 DefaultMQPushConsumer的流量控制
      • 3.1.4 DefaultMQPullConsumer
      • 3.1.5 Consumer的启动、关闭流程
    • 3.2 不同类型的生产者
      • 3.2.2 发送延迟消息
      • 3.2.3 自定义消息发送规则
      • 3.2.4 对事务的支持
    • 3.3 如何存储队列位置信息
    • 3.4 自定义日志输出
    • 3.5 本章小结
  • 第4章 分布式消息队列的协调者
    • 4.1 NameServer的功能
      • 4.1.1 集群状态的存储结构
      • 4.1.2 状态维护逻辑
    • 4.2 各个角色间的交互流程
      • 4.2.2 为何不用ZooKeeper
    • 4.3 底层通信机制
      • 4.3.2 协议设计和编解码
      • 4.3.3 Netty库
    • 4.4 本章小结
  • 第5章 消息队列的核心机制
    • 5.1 消息存储和发送
    • 5.2 消息存储结构
    • 5.3 高可用性机制
    • 5.4 同步刷盘和异步刷盘
    • 5.5 同步复制和异步复制
    • 5.6 本章小结
  • 第6章 可靠性优先的使用场景
    • 6.1.1 全局顺序消息
    • 6.2 消息重复问题
    • 6.3 动态增减机器
      • 6.3.1 动态增减NameServer
      • 6.3.2 动态增减Broker
    • 6.4 各种故障对消息的影响
    • 6.5 消息优先级
    • 6.6 本章小结
  • 第7章 吞吐量优先的使用场景
    • 7.1 在Broker端进行消息过滤
      • 7.1.2 通过Tag进行过滤
      • 7.1.4 Filter Server方式过滤
    • 7.2 提高Consumer处理能力
    • 7.3 Consumer的负载均衡
      • 7.3.1 DefaultMQPushConsumer的负载均衡
      • 7.3.2 DefaultMQPullConsumer的负载均衡
    • 7.4 提高Producer的发送速度
    • 7.5 系统性能调优的一般流程
    • 7.6 本章小结
  • 第8章 和其他系统交互
    • 8.1.1 直接使用
    • 8.2 直接使用云上RocketMQ
    • 8.3 RocketMQ与Spark、Flink对接
    • 8.4 自定义开发运维工具
    • 8.4.2 基于Tools模块开发自定义运维工具
  • 第9章 首个Apache中间件顶级项目
    • 9.1 RocketMQ的前世今生
    • 9.2 Apache顶级项目（TLP）之路
    • 9.3 源码结构
    • 9.4 不断迭代的代码
    • 9.5 本章小结
  • 第10章 NameServer源码解析
    • 10.1 模块入口代码的功能
      • 10.1.3 初始化NameServer的Controller
    • 10.2 NameServer的总控逻辑
    • 10.3 核心业务逻辑处理
    • 10.4 集群状态存储
    • 10.5 本章小结
  • 第11章 最常用的消费类
    • 11.1 整体流程
      • 11.1.2 DefaultMQPushConsumer的实现者
      • 11.1.3 获取消息逻辑
    • 11.2 消息的并发处理
      • 11.2.2 ProcessQueue对象
    • 11.3 生产者消费者的底层类
      • 11.3.2 MQClientInstance类的功能
    • 11.4 本章小结
  • 第12章 主从同步机制
    • 12.1 同步属性信息
    • 12.2 同步消息体
    • 12.3 sync_master和async_master
    • 12.4 本章小结
  • 第13章 基于Netty的通信实现
    • 13.1 Netty介绍
    • 13.2 Netty架构总览
      • 13.2.1 重新实现ByteBuffer
      • 13.2.2 统一的异步I/O接口
      • 13.2.3 基于拦截链模式的事件模型
      • 13.2.4 高级组件
    • 13.3 Netty用法示例
      • 13.3.2 查看收到的数据
    • 13.4 RocketMQ基于Netty的通信功能实现
      • 13.4.2 自定义协议
      • 13.4.3 基于Netty的Server和Client
    • 13.5 本章小结
暂无相关搜索结果！
    展开/收起文章目录

    二维码

    手机扫一扫，轻松掌上学

    《RocketMQ实战与原理解析》电子书下载

    请下载您需要的格式的电子书，随时随地，享受学习的乐趣！
    EPUB 电子书

    书签列表

      阅读记录

      阅读进度: 0.00% ( 0/0 ) 重置阅读进度