537、RabbitMQ详细入门教程系列 -【消费者Consumer（一）】 2022.08.31

一、摘要概述

经过前面三篇文章的学习，对于RabbitMQ中间件应该处于拨开云雾见青天阶段。本文将趁热打铁，完善RabbitMQ基础应用最后一个消费版块。当然文中会持续深入讲解有关消息分发、消费端确认等中阶特性

二、消息消费

MQ队列可以理解为物品寄存中心，放进去总要拿出来用，一直放着没有利息还会持久增加成本引发系列问题。MQ存储的消息使用有两种途径，RabbitMQ服务推送、消费者客户端拉取

2.1 拉取消息

通过baiscGet()拉取RabbitMQ服务端消息有以下几点需要注意：

一次只能消费一条消息，千万别使用用循环代替后面的baiscConsume()
前面讲的队列创建参数有AutoDelete,但是注意这个自动删除前提为至少有一个消费者连接到队列，并且当所有消费者断开时删除，这里通过basicGet()消费不包含在内

        // 设置队列自动删除
        channel.queueDeclare("autoDeleteQueue", true, false, true, null);
        channel.basicPublish("", "autoDeleteQueue", null, "测试".getBytes());
        // 验证basicGet不触发队列自动删除
        channel.basicGet("autoDeleteQueue", true);
1
2
3
4
5

当然basicGet()方法自身API比较简单，第一个参数指明消费队列，第二个参数设置是否自动应答即AutoAck。返回对象也就封装Envelope、BasicProperties、body消息体等，具体信息如下表所示：

2.2 推送消息

相对于拉取消息而言，basicConsume()推送消息更加符合生产环境的需求，持续监控消费队列。自然其API也更加复杂，常用系列重载参数如下表所示：

推送消息消费最后一般都是采用实现Consumer接口亦或是继承DefaultConsumer类，DefaultConsumer实现了接口Consumer，但是大多数方法都是空实现，需要重写其中的逻辑。其中重要方法执行时间如下表所示：

        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){
            @Override
            public void handleDelivery (String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)     throws IOException {
                // 处理消息逻辑
            }
        };
        channel.basicConsume("queueName",true,"consumerTag",defaultConsumer);
1
2
3
4
5
6
7

2.3 队列重发

上面讲到Consumer的方法handleRecoverOk()将会在消息重发时调用，显示的调用消息重发方法为basicRecover()。该方法只有一个参数：

true：表示可以将重发消息发送给其它消费者
false：表示只能将消息发送给相同的消费者

三、参考链接

[01] RabbitMQ详细入门教程系列 -【消费者Consumer（一）