} }
代码@1：如果请求为提交事务，进入事务消息提交处理流程。
代码@2：提交消息，别被这名字误导了，该方法主要是根据commitLogOffset从commitlog文件中查找消息返回OperationResult实例。
● private MessageExt prepareMessage ：消息对象。
● private int responseCode：查找结果。
● private String responseRemark ：错误提示。
代码@3：如果成功查找到消息，则继续处理，否则返回给客户端，消息未找到错误信息。
代码@4：验证消息必要字段。
● 验证消息的生产组与请求信息中的生产者组是否一致。
● 验证消息的队列偏移量（queueOffset）与请求信息中的偏移量是否一致。
● 验证消息的commitLogOffset与请求信息中的CommitLogOffset是否一致。
代码@5:调用endMessageTransaction方法，该方法主要的目的就是恢复事务消息的真实的主题、队列，并设置事务ID。
代码@6：设置消息的相关属性，这一步应该直接在endMessageTransaction中实现就好，统一恢复原消息的数量，特别关注的是取消了事务相关的系统标记。
代码@7：发送最终消息，其实现原理非常简单，调用MessageStore将消息存储在commitlog文件中，此时的消息，会被转发到原消息主题对应的消费队列，被消费者消费。
代码@8：删除预处理消息(prepare)，其实是将消息存储在主题为：RMQ_SYS_TRANS_OP_HALF_TOPIC的主题中，代表这些消息已经被处理（提交或回滚）。
上述就是事务消息提交的流程，事务回滚类似，接下来大概分析一下事务消息回滚的流程。
EndTransactionProcessor#processRequest else if (MessageSysFlag.TRANSACTION_ROLLBACK_TYPE == requestHeader.getCommitOrRollback()) { result = this.brokerController.getTransactionalMessageService().rollbackMessage(requestHeader); // @1 if (result.getResponseCode() == ResponseCode.SUCCESS) { RemotingCommand res = checkPrepareMessage(result.getPrepareMessage(), requestHeader); if (res.getCode() == ResponseCode.SUCCESS) { this.brokerController.getTransactionalMessageService().deletePrepareMessage(result.getPrepareMessage()); // @2 } return res; } }
