rabbitmq中是否支持事务 - 面试宝典

javaCopy codeimport com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class RabbitMQTransactionExample {
    private static final String QUEUE_NAME = "my_queue";
    public static void main(String[] args) {
        try {
            // 创建连接工厂
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            
            // 创建连接
            Connection connection = factory.newConnection();
            
            // 创建信道
            Channel channel = connection.createChannel();
            
            // 声明队列
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            
            try {
                // 开启事务
                channel.txSelect();
                
                // 发送消息
                String message = "Hello, RabbitMQ!";
                channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
                
                // 提交事务
                channel.txCommit();
                System.out.println("Message sent successfully.");
            } catch (Exception e) {
                // 回滚事务
                channel.txRollback();
                System.out.println("Failed to send message. Transaction rolled back.");
            }
            
            // 关闭信道和连接
            channel.close();
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}