RabbitMQ/Spring-AMQP 高级特性：事务机制与消息限流

RabbitMQ 事务机制用于确保消息发布的原子性，需配置 RabbitTemplate 为事务模式并禁用 Publisher Confirms。消息限流通过设置 Prefetch 数量和手动 ACK 模式，限制消费者未确认消息数，防止生产速度超过消费能力导致积压。

星河入梦发布于 2026/3/210 浏览

在这里插入图片描述

1. 事务

AMQP(高级消息队列协议) 实现了事务机制，主要用于确保消息的原子性发布和确认。换言之，它允许你将多个操作 (如发送消息、确认消息) 绑定在一起，要么全部成功，要么全部失败。

发送消息

@RestController
@RequestMapping("/producer")
public class ProducerController {
    @Resource(name = "transRabbitTemplate")
    private RabbitTemplate transRabbitTemplate;

    @Transactional
    @RequestMapping("/trans")
    public String trans() {
        transRabbitTemplate.convertAndSend("", Constants.TRANS_QUEUE, "trans test ---> 1");
        int num = 5 / 0;
        transRabbitTemplate.convertAndSend("", Constants.TRANS_QUEUE, "trans test ---> 2");
        return "发送成功";
    }
}

在这里插入图片描述

Spring Boot 的 RabbitMQ 自动配置默认会开启确认模式，但 RabbitMQ 不允许同一个通道同时使用事务模式和确认模式，所以需要确保 publisher confirms 被禁用。

spring:
  rabbitmq:
    publisher-confirm-type: none
    publisher-returns:

相关免费在线工具

Keycode 信息
查找任何按下的键的javascript键代码、代码、位置和修饰符。在线工具，Keycode 信息在线工具，online
Escape 与 Native 编解码
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。在线工具，Escape 与 Native 编解码在线工具，online
JavaScript / HTML 格式化
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。在线工具，JavaScript / HTML 格式化在线工具，online
JavaScript 压缩与混淆
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。在线工具，JavaScript 压缩与混淆在线工具，online
Base64 字符串编码/解码
将字符串编码和解码为其 Base64 格式表示形式即可。在线工具，Base64 字符串编码/解码在线工具，online
Base64 文件转换器
将字符串、文件或图像转换为其 Base64 表示形式。在线工具，Base64 文件转换器在线工具，online

@Configuration
public class RabbitTemplateConfig {
    @Bean("transRabbitTemplate")
    public RabbitTemplate transRabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setChannelTransacted(true);
        return rabbitTemplate;
    }

    @Bean
    public RabbitTransactionManager rabbitTransactionManager(ConnectionFactory connectionFactory) {
        return new RabbitTransactionManager(connectionFactory);
    }
}

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

@RestController
@RequestMapping("/producer")
public class ProducerController {
    @Resource(name = "rabbitTemplate")
    private RabbitTemplate rabbitTemplate;

    @RequestMapping("/qos")
    public String qos() {
        for (int i = 0; i < 20; i++) {
            rabbitTemplate.convertAndSend(Constants.QOS_EXCHANGE, "qos", "qos test:" + i);
        }
        return "发送成功";
    }
}

@Component
@Slf4j
public class QosListener {
    @RabbitListener(queues = Constants.QOS_QUEUE)
    public void handMessage(Message message, Channel channel) throws IOException {
        long deliveryTag = message.getMessageProperties().getDeliveryTag();
        try {
            log.info("接收到消息:{},deliveryTag:{}", new String(message.getBody(), StandardCharsets.UTF_8), deliveryTag);
            log.info("处理成功");
            // channel.basicAck(deliveryTag, true); // 消费者不确认消息
        } catch (Exception e) {
            channel.basicNack(deliveryTag, true, true);
        }
    }
}

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: manual # 消费者确认机制
        prefetch: 5

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

    @Bean("qosExchange")
    public DirectExchange qosExchange() {
        return ExchangeBuilder.directExchange(Constants.QOS_EXCHANGE).build();
    }

    @Bean("qosBinding")
    public Binding qosBinding(@Qualifier("qosExchange") DirectExchange directExchange, @Qualifier("qosQueue") Queue queue) {
        return BindingBuilder.bind(queue).to(directExchange).with("qos");
    }
}

RabbitMQ/Spring-AMQP 高级特性：事务机制与消息限流

1. 事务

发送消息

更多推荐文章

相关免费在线工具

配置 RabbitTemplate 和事务管理器

配置队列

2. 消息限流

发送消息

配置消费者

声明和配置交换器、队列和绑定关系

RabbitMQ/Spring-AMQP 高级特性：事务机制与消息限流

1. 事务

发送消息

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具

配置 RabbitTemplate 和事务管理器

配置队列

2. 消息限流

发送消息

配置消费者

声明和配置交换器、队列和绑定关系