消息中间件系列教程（16） -RabbitMQ-应答模式-阿里云开发者社区

消息中间件系列教程（16） -RabbitMQ-应答模式

2023-11-07 75

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 消息中间件系列教程（16） -RabbitMQ-应答模式

在前面的章节中，消费者都是自动应答的：

那么消费者可以手动应答吗？答案是可以的

下面基于《消息中间件系列教程（13） -RabbitMQ-SpringBoot集成RabbitMQ》的环境讲解下自动应答的核心代码。

1.application.yml里添加自动应答（最后一行）：

server:
  port: 8082
spring:
  rabbitmq:
    ####连接地址
    host: 127.0.0.1
    ####端口号
    port: 5672
    ####账号
    username: guest
    ####密码
    password: guest
    ### 地址
    virtual-host: /
    listener:
      simple:
        retry:
          ####开启消费者重试
          enabled: true
          ####最大重试次数
          max-attempts: 5
          ####重试间隔次数
          initial-interval: 3000
        ####开启手动ack
        acknowledge-mode: manual

2.消费内容，手动应答：

@Component
public class FanoutSmsConsumer {
    @RabbitListener(queues = "fanout_sms_queue")
    public void process(Message message, @Headers Map<String, Object> headers, Channel channel) throws Exception {
        System.out
                .println(Thread.currentThread().getName() + ",邮件消费者获取生产者消息msg:" + new String(message.getBody(), "UTF-8")
                        + ",messageId:" + message.getMessageProperties().getMessageId());
        // 手动ack
        Long deliveryTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
        // 手动签收
        channel.basicAck(deliveryTag, false);
    }
}