阿里二面：消息队列的事务消息可以用 TCC 模式实现吗?

本文主要是介绍阿里二面：消息队列的事务消息可以用 TCC 模式实现吗?，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

大家好，我是君哥。

消息队列的主要功能是系统间解耦，实现流量的削峰填谷。主流的消息队列一般有三个核心操作：消费者发送消息，Broker 保存消息，消费者消费消息。如下图：

对于一个完整的事务消息，可以理解为生产者生产消息和消费者消费消息，这两个操作要不全部成功要不全部失败。但事实上，很难有消息队列来实现生产消息和消费消息的事务特性。

1 事务消息实现

1.1 生产者事务

一些消息队列在生产端实现事务消息，对生产的一批消息要不全部发送成功，要不全部发送失败。

下图是 RabbitMQ 的事务消息：

RabbitMQ 的事务消息实现的就是生产者的事务消息，发送消息的时候，把 Channel 设置为事务模式，这样这一批消息就会缓存在 Channel，等提交事务时才会提交到 Broker。可以参考下面代码：

ConnectionFactory factory=new ConnectionFactory();
connection=factory.newConnection();
Channel channel=connection.createChannel();
//开启事务
channel.txSelect();
channel.basicPublish("directTransactionExchange","transactionRoutingKey",null,message.getBytes("utf-8"));
//提交事务 或者 channel.txRollback()回滚事务
channel.txCommit();

Kafka 的事务消息类似，指定一个事务 id，集群中不同的生产者都可以使用这个事务 id 来实现事务消息。看下面代码：

String transactionId = "xxxx123yyy"
Properties properties = new Properties();
properties.put(ProducerConfig.TRANSACTIONAL_ID_CONFIG, transactionId);
KafkaProducer<String, String> producer = new KafkaProducer<String, String>(properties);
//开启事务消息
producer.initTransactions();
producer.beginTransaction();try {//发送消息String topic = "testTransactionId"producer.send(new ProducerRecord<String, String>(topic, "msg1"));producer.send(new ProducerRecord<String, String>(topic, "msg2"));producer.send(new ProducerRecord<String, String>(topic, "msg3"));// 提交事务producer.commitTransaction();
} catch (ProducerFencedException e) {producer.abortTransaction();
}
producer.close();

使用同一个事务 id 后，集群中的多个生产者可以实现对不同 Topic、不同分区的原子性写入。在提交事务之前，这些消息是不可见的，事务提交之后，这些消息才能变为可见。