1 Star 0 Fork 0

javahongxi/spring-boot-project

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

针对官方starter修改点 官方

  • 支持连接多个集群(订阅) (官方一个应用只能连接一个集群)
  • 顺序消息消费失败,可配重试次数 (非顺序消息默认重试16次,每次时间延后)
  • 发送延时消息方法参数优化(魔法参数改为枚举)
  • 优化getMessageType方法,支持 MyConsumer extends AbstractConsumer implements RocketMQListener
    (官方只支持MyConsumer implements RocketMQListener)
  • RocketMQTemplate方法重载(加入keys)
  • 让@RocketMQMessageListener自带@Service注解
  • 消息数据类型转换优化,增加Integer,Boolean等基础类型的转换
  • 暂未加入事务消息功能 (官方最新版支持)

关于RocketMQTemplate往多集群发送消息的说明

当需要往其他集群发送消息时,需要拷贝一份RocketMQAutoConfigurationRocketMQProperties, 并相应修改@Bean方法名和Conditional,最重要的是给MQProducer设置instanceName,且默认的MQProducer也需要手动实例化。 当然,科学的场景应该是往自己的集群发消息,让外部系统来消费。

马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Java
1
https://gitee.com/javahongxi/spring-boot-project.git
git@gitee.com:javahongxi/spring-boot-project.git
javahongxi
spring-boot-project
spring-boot-project
main

搜索帮助