¿Cómo implementar mensajes de transacción?

La mensajería de transacciones es una función de transacción proporcionada por RocketMQ que permite que las transacciones distribuidas garanticen que las operaciones de transacción y los mensajes enviados anteriormente tengan éxito o fallen. El mecanismo de implementación de mensajes de transacción de RocketMQ se basa en el patrón TCC (Try-Confirm-Cancel). Específicamente, la implementación de mensajes de transacción RocketMQ incluye los siguientes pasos:

1.

2. Mensajes de transacciones de consumo del consumidor.

3. Ejecutar la lógica empresarial.

4. Si la ejecución de la lógica de negocios es exitosa, envíe un mensaje de confirmación a RocketMQ; si la ejecución de la lógica de negocios falla, envíe un mensaje de cancelación a RocketMQ.

5. Si todos los servidores envían mensajes de confirmación a RocketMQ, la transacción se confirma; de lo contrario, la transacción se revierte.