RocketMQ实战(3)事务消息

RocketMQ实战(3) -事务消息

干干净净没有故事,一个酷字贯穿一生。

springBoot快速整合rabbitMQ。话不多少&＃xff0c;上才艺~

1.生产者方面

1.1 定义监听器------执行本地事务和事务会查&＃xff1a;

&＃64;RocketMQTransactionListener
&＃64;Slf4j
public class TransactionListener implements RocketMQLocalTransactionListener {&＃64;Overridepublic RocketMQLocalTransactionState executeLocalTransaction(Message message, Object o) {// 模拟本地事务不通过log.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61; executeLocalTransaction");return RocketMQLocalTransactionState.UNKNOWN;}&＃64;Overridepublic RocketMQLocalTransactionState checkLocalTransaction(Message message) {// 模拟回查本地事务log.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61; checkLocalTransaction");return RocketMQLocalTransactionState.COMMIT;}
}


1.2发送事务消息

&＃64;RequestMapping("/temSendTran")public String temSendTransaction(String message){String transactionId &＃61; UUID.randomUUID().toString();TransactionSendResult result &＃61; this.rocketMQTemplate.sendMessageInTransaction("test-tranc", MessageBuilder.withPayload(message).setHeader(RocketMQHeaders.TRANSACTION_ID, transactionId).build(), message);return "ok";}


2.消费者方面–定义对应的消息监听即可

&＃64;Component
&＃64;Slf4j
&＃64;RocketMQMessageListener(topic &＃61; "test-tranc", consumerGroup &＃61; "test-tranc-consumer")
public class TransConsumerListener implements RocketMQListener<Message> {&＃64;Overridepublic void onMessage(Message message) {log.info("topic-tx received message: {}", message);}
}


创作不易&＃xff0c;点个赞吧&＃xff0c;您的赞&＃xff0c;是我继续创作的动力。

编程并不是一蹴而就的&＃xff0c;每天都是新的革命&＃xff0c;加油呀~