第8章 分布式消息处理——基于RocketMQ /374 8.1 消息中间件概述 /374 8.1.1 什么是消息中间件 /374 8.1.2 为什么需要消息中间件 /375 8.1.3 认识RocketMQ /376 8.2 搭建RocketMQ的运行环境 /379 8.2.1 了解RocketMQ的安装包 /379 8.2.2 搭建单Master的单机环境 /380 8.2.3 搭建多Master的集群环境 /380 8.2.4 搭建单Master和单Slave的集群环境 /382 8.2.5 搭建Raft集群环境 /384 8.2.6 【实例】用RocketMQ Admin控制台管控RocketMQ /386 8.3 将应用接入RocketMQ /386 8.3.1 【实例】用rocketmq-spring-boot-starter框架将应用接入RocketMQ /387 8.3.2 【实例】用spring-cloud-starter-stream-rocketmq框架将应用接入 RocketMQ /389 8.4 用Netty实现RocketMQ的通信渠道 /392 8.4.1 用NettyRemotingClient类实现客户端的通信渠道 /393 8.4.2 用NettyRemotingServer类实现服务器端的通信渠道 /395 8.5 用“异步”“同步”和“最多发送一次”模式生产消息 /400 8.5.1 用“异步”模式生产消息的原理 /400 8.5.2 用“同步”模式生产消息的原理 /403 8.5.3 用“最多发送一次”模式生产消息的原理 /405 8.5.4 【实例】在Spring Cloud Alibaba项目中生产同步消息和异步消息 /407 8.6 用Push模式和Pull模式消费消息 /410 8.6.1 “用Push模式消费消息”的原理 /410 8.6.2 “用Pull模式消费消息”的原理 /421 8.6.3 【实例】生产者生产消息，消费者用Pull模式和Push模式消费消息 /431 8.7 用两阶段提交和定时回查事务状态实现事务消息 /437 8.7.1 什么是事务消息 /437 8.7.2 两阶段提交的原理 /437 8.7.3 定时回查事务状态的原理 /447 8.7.4 【实例】在Spring Cloud Aliaba项目中生产事务消息 /451