springboot 整合RabbitMQ 补充理解

smallmayi

发布于 2022-05-12 11:20:05

2300

发布于 2022-05-12 11:20:05

文章被收录于专栏：small专栏

SpringBoot中使用RabbitMQ消息队列——路由、通配符、订阅模式这篇文章中已经整合了rabbitmq。

1.rabbitmq 默认交换机

//创建队列
   @Bean
    public Queue defaultQueue() {
        return new Queue("default_queue");
    }
//发送消息
amqpTemplate.convertAndSend("default_queue","hello default");
//接收
 @RabbitListener(queues = "default_queue")
    public void defaultQueue(String string) {
        log.info("【监听到消息】" + string);
    }

以上方式未创建exchange，说明rabbitmq 默认交换机是direct exchange.

2.监听消费

同样使用上面的默认交换机，使用两个监听

    @RabbitListener(queues = "default_queue")
    public void defaultQueue(String string) {
        log.info("【监听到消息】" + string);
    }
    @RabbitListener(queues = "default_queue")
    public void defaultQueue2(String string) {
        log.info("【监听到消息2】" + string);
    }
    //结果
    【sendFanout已发送消息】
    【监听到消息2】hello default
	【sendFanout已发送消息】
	【监听到消息】hello default

两个监听器轮流监听,topic exchange 测试也是一样轮流监听

3.发送消息到队列，未监听消费

如图，未监听消息还在队列中。 Ready:就绪状态，处于队列中说明没有被监听 Unacked: 已被监听，但未确认消费，断开后变成Ready状态

默认是自动消费，监听启动后会将该消息消费掉。

4.手动确认消费ACK

rabbitmq 默认是自动消费，改为手动确认。 1）配置文件

# none意味着没有任何的应答会被发送。manual意味着监听者必须通过调用Channel.basicAck()来告知所有的消息。
# auto意味着容器会自动应答，除非MessageListener抛出异常，这是默认配置方式。
spring.rabbitmq.listener.simple.acknowledge-mode=manual

2）监听

  @RabbitListener(queues = RabbitMQConfig.FANOUT_QUEUE2)
    public void receiveTopic2(String string, Message message, Channel channel) throws IOException {
        channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
        log.info("【receiveTopic2监听到消息】" + string);
    }

5.声明MessageQueue

在Rabbit MQ中，无论是生产者发送消息还是消费者接受消息，都首先需要声明一个MessageQueue。这就存在一个问题，是生产者声明还是消费者声明呢？要解决这个问题，首先需要明确：

a)消费者是无法订阅或者获取不存在的MessageQueue中信息。

b)消息被Exchange接受以后，如果没有匹配的Queue，则会被丢弃。

在明白了上述两点以后，就容易理解如果是消费者去声明Queue，就有可能会出现在声明Queue之前，生产者已发送的消息被丢弃的隐患。如果应用能够通过消息重发的机制允许消息丢失，则使用此方案没有任何问题。但是如果不能接受该方案，这就需要无论是生产者还是消费者，在发送或者接受消息前，都需要去尝试建立消息队列。这里有一点需要明确，如果客户端尝试建立一个已经存在的消息队列，Rabbit MQ不会做任何事情，并返回客户端建立成功的。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2019-10-28，如有侵权请联系 cloudcommunity@tencent.com 删除

kafka