RocketMQ-Spring-Boot-Starter是一款专为简化RocketMQ在Spring Boot项目中集成而设计的启动器。它提供了自动配置、属性绑定及多种实用工具,让开发者能够快速便捷地使用RocketMQ进行消息通信和异步处理。
RocketMQ-Spring-Boot-Starter 阿里云 RocketMQ Spring 版支持的功能包括:
1. 发送普通消息的三种模式:同步、异步和单向。
2. 订阅消息集群,广播订阅。
3. 发送和接收顺序消息。
4. 交易信息处理。
对于延迟信息和定时消息:
- 在官方情况下,延迟新闻与常规新闻几乎相同,本质上是普通新闻。如果需要使用延迟或计时功能,请考虑采用定时任务(如定时任务调度平台)来实现这些需求的设置。
关于事务性消息,在框架中操作变得简单:只需通过注解即可完成交易信息处理。无论是本地事务还是跨语言分布式解决方案,核心都是确保可以发送消息,并且消费者能够可靠地使用它们。
1. 使用@TransactionMessage 注释进行标记,内核将保证如果本地事务执行有误,则不会发送任何消息;若无错误则默认提交并发送消息。
2. 默认采用可靠性保证机制,默认情况下会自动确认提交。这一设置的前提是确保本地交易的正确性。
快速开始:
添加依赖至 pom.xml 文件中。