RocketMQ分布式事务中本地事务应该怎么处理？

RocketMQ处理分布式事务中，首先producer要给broker发送一个半消息，然后进行处理本地事务，本地事务处理完之后发送状态码告知broker。那么我该如何进行本地事务处理？假如我本地事务失败了，该怎么回滚，然后回滚完之后还能发送消息到broker？？？如图我该怎么处理本地事务保证既能回滚又能发送消息到broker

https://blog.csdn.net/fenglibing/article/details/92417739