RabbitMQ ACK 消息确认机制

╰+攻爆jí腚メ 2022-06-03 10:40 415阅读 0赞

  2. 在消费者端的mq配置文件上添加,配置 关键代码为 acknowledeg = “manual”
    ，意为表示该消费者的ack方式为手动（此时的queue已经和生产者的exchange通过某个routeKey绑定了）

新建一个类 MqConsumer ，并实现接口 ChannelAwareMessageListener ，实现onMessage方法，不需要指定方法。

关键点在实现了ChannelAwareMessageListener的onMessage方法后，会有2个参数。

一个是message（消息实体），一个是channel就是当前的通道

很多地方都没有说清楚怎么去手动ack，其实手动ack就是在当前channel里面调用basicAsk的方法，并传入当前消息的tagId就可以了。

注意如果抛异常或unack（并且requeue为true），消息会一直重新入队列，一不小心就会xxxxx一大堆消息不断重复~。

//消息的标识，false只确认当前一个消息收到，true确认所有consumer获得的消息 (正常消费)

channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);

//ack返回false，并重新回到队列，api里面解释得很清楚 (本地异常)

channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);

//拒绝消息

channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);

发表评论

表情：
评论列表 （有 0 条评论，415人围观）

还没有评论，来说两句吧...

相关阅读

    相关 RabbitMQ的消息确认ACK机制

    1、什么是消息确认ACK。 　　答：如果在处理消息的过程中，消费者的服务器在处理消息的时候出现异常，那么可能这条正在处理的消息就没有完成消息消费，数据就会丢失。为了确保数据不

    冷不防冷不防/ 0 赞/ 92 阅读