RabbitMQ 事务机制详解及 Spring 配置实践

RabbitMQ 事务机制详解

RabbitMQ 是基于 AMQP 协议实现的，该协议实现了事务机制，因此 RabbitMQ 也支持事务机制。Spring AMQP 也提供了对事务相关的操作。RabbitMQ 事务允许开发者确保消息的发送和接收是原子的，要么全部成功，要么全部失败。

添加配置

spring:
  application:
    name: rabbit-extensions-demo
  rabbitmq:
    addresses: amqp://study:[email protected]:5672/extension

常量类

public class Constants {
    // 事务
    public static final String TRANS_QUEUE = "trans.queue";
}

声明队列

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import rabbitextensionsdemo.constant.Constants;

@Configuration
public class RabbitMQConfig {
    @Bean("transQueue")
    public Queue transQueue() {
        return QueueBuilder.durable(Constants.TRANS_QUEUE).build();
    }
}

设置 RabbitTemplate

import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
 org.springframework.context.annotation.Configuration;


   {
    
     RabbitTemplate  {
            (connectionFactory);
        rabbitTemplate.setChannelTransacted(); 
         rabbitTemplate;
    }
}