事务消息逻辑

首先我们来docker 部署rocketMQ与rocketMQDashBoard

docker ps查看rocketMQ 容器名称

docker ps

进入容器内部

docker exec -it rmqnamesrv /bin/bash

创建事务消息

sh mqadmin updateTopic -c DefaultCluster -t TRANSACTIONTopic -n 127.0.0.1:9876 -a +message.type=TRANSACTION

创建事务消息成功

在github rocktmq5.0 golang客户端已经支持事务消息

官方事务消息demo

https://github.com/apache/rocketmq-clients/blob/master/golang/example/producer/transaction/main.go

rocketmq半事务时间限制