FolkMQ 提供了二段式提交的事务提交的机制（TCC 模型）。允许生产者在发送消息时绑定到一个事务中并接收事务的管理，以确保消息的原子性（要么全成功，要么全失败）。在 FolkMQ 中，事务是通过 MqTransaction 接口实现管理的。一般是通过：
- 新建事务：在产生者端，可以通过调用
MqTransaction tran = client.newTransaction() 新建一个事务。后续的消息发送与此事务绑定。绑定的消息，即参与此事务；没绑定的消息，则照旧。
- 发送消息（T）：接下来的事务中，尝试发送消息。此时，中间件会把消息放在一个事务中转队列里。
- 提交事务（C）：如果所有消息都发送成功了，就通过
tran.commit() 方法提交事务。此时，中间件把事务相关消息从事务中转队列取出，并转到派发队列。
- 回滚事务（C）：通过
try catch，如果有某一条消息发送异常了。就通过 tran.rollback() 方法回滚事务，即所有消息全部取消。此时，中间件把事务相关消息从事务中转队列删掉。
发送事务消息：
//发送事务消息
MqTransaction tran = client.newTransaction();
try {
//同步
client.publish("demo", new MqMessage("demo1").attr("orderId","1").transaction(tran));
client.publish("demo", new MqMessage("demo2").attr("orderId","1").transaction(tran));
//异步，也行！
client.publishAsync("demo", new MqMessage("demo3").attr("orderId","1").transaction(tran));
client.publishAsync("demo", new MqMessage("demo4").attr("orderId","1").transaction(tran));
tran.commit();
} catch (Throwable e) {
tran.rollback();
}
FolkMQ 的服务端事务处理，是基于专属的"事务中转队列"实现（支持快照持久化）。它可以保证在事务中的消息，要么全部成功，要么全部失败。而且，当客户端没有提交二次确认时（偶尔会有网络原因），超过60秒后，会发起反向“回查”。要实现更“周密”的事务处理，客户端还需要实现回查处理。一般在客户端初始化时，或者连接建立后配置事务回查处理：
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
.nameAs("demoapp") //一般用当前应用名
.connect();
client.transactionCheckback(m->{
if("1".equals(m.getAttr("orderId"))) {
m.acknowledge(true);
}
});
FolkMQ 的事务机制，并且不会对性能有影响，与非事务消息性能没什么差别。
