Message Builder.withPayload

2023-07-25 08:05:40 如果broker未收到消息（如果执行本地事务突然宕机了，相当执行本地事务(executeLocalTransaction)执行结果返回unknow，则和broker未收到确认消息的情况一样处理。 环境：springboot2.3.9 + RocketMQ4.8.0 可靠消息最终一致性原理 执行流程 Producer发送Prepare message到broker。 Prepare Message发送成功后开始执行本地事务。 如果本地事务执行成功的话则返回commit，如果执行失败则返回rollback。（这个是在事务消息的回调方法里由开发者自己决定commit or rollback） Producer发送上一步的commit还是rollback到broker，这里有以下两种情况： 1、如果broker收到了commit/rollback消息 ： 如果收到了commit，则broker认为整个事务是没问题的，执行成功的。那么会下发消息给Consumer端消费。...

领域模型介绍 Producer: 用于生产消息的运行实体。 Topic: 主题，用于消息传输和存储的分组容器。 MessageQueue: 消息传输和存储的实际单元容器。 Message: 消息传输的最小单元。 ConsumerGroup: 消费者组。 Consumer: 消费者。 Subscription: 订阅关系，发布订阅模式中消息过滤、重试、消费进度的规则配置。 MQ的优势 MQ的明显优势有3个。 应用解耦： 以多服务为例，用户下单，需要通知订单服务和库存服务，我们可以通过MQ消息来解除下单和库存系统的耦合。 异步提速： 以秒杀为例，我们可以先返回秒杀结果，后续再通过MQ异步消息去插入记录和扣减库存等，减少调用的链路长度。 削峰填谷： 将某一时间内的请求量分摊到更多时间处理，比如系统A一秒只能处理10000个请求，但是我有100000个请求需要处理，我可以将请求发到MQ中，再分成10秒去消费这些请求。 当然MQ也有劣势，系统可用性降低，系统复杂度提高，一致性问题。 RocketMQ的主要角色 主要包括Producer、Broker、Consumer、NameServer...

RocketMQ 是大家耳熟能详的消息队列，开源项目 rocketmq-spring 可以帮助开发者在 Spring Boot 项目中快速整合 RocketMQ。 这篇文章会介绍 Spring Boot 项目使用 rocketmq-spring SDK 实现消息收发的操作流程，同时笔者会从开发者的角度解读 SDK 的设计逻辑。 项目地址： rocketmq-spring 的本质是一个 Spring Boot starter 。 Spring Boot 基于“约定大于配置”（Convention over configuration）这一理念来快速地开发、测试、运行和部署 Spring 应用，并能通过简单地与各种启动器（如 spring-boot-web-starter）结合，让应用直接以命令行的方式运行，不需再部署到独立容器中。 Spring Boot starter 构造的启动器使用起来非常方便，开发者只需要在 pom.xml 引入 starter 的依赖定义，在配置文件中编写约定的配置即可。 下面我们看下 rocketmq-spring-boot-starter 的配置：...