文件名称:java二进制补码源码-coolmq:消息最终一致性方案,基于rabbitmq的分布式事务解决方案
文件大小:39KB
文件格式:ZIP
更新时间:2024-06-25 01:56:33
系统开源
java二进制补码源码 用法 更新 自定义注解插入发送切面 抽象消息存储 扩展元消息 项目结构说明 coolmq为实际包 microservice-demo们为spring-boot集成demo 使用说明 maven引入coolmq依赖 在项目启动中配置包扫描:@SpringBootApplication(scanBasePackages= {"com.coolmq.amqp.config"}),以自动装配项目bean 声明队列: BizQueueConfig.java 声明消息接受者: TransMessageListener.java provider中加入 @TransMessage包裹业务操作即可 代码使用示例请参考microservice-message-demo 视频教程 coolmq 用rabbitmq解决分布式事务 传统的事务解决方案,例如TCC,都太消耗资源,而rabbitmq用两阶段确认确保了消息只要发送,就能送达。本方案是基于Spring-Boot Amqp,已经在生产上部署实践,可用于支付等跨服务调用的业务情况 一 两阶段确认 1 发送确认 发送确认用来确保消息
【文件预览】:
coolmq-master
----coolmq()
--------pom.xml(2KB)
--------src()
----pom.xml(1KB)
----.idea()
--------compiler.xml(1KB)
----.gitignore(16KB)
----README.md(6KB)
----microservice-message-demo()
--------pom.xml(2KB)
--------.springBeans(485B)
--------src()