《RabbitMQ系列教程-第十一章-RabbitMQ之队列限流》

分手后的思念是犯贱 2023-01-02 04:20 112阅读 0赞

# 教程说明 #

*  本系列教程目录大纲：[《RabbitMQ系列教程-目录大纲》][RabbitMQ_-]

--------------------

*  本系列教程配套代码：[https://gitee.com/Horizon1024/rabbitmt.git][https_gitee.com_Horizon1024_rabbitmt.git]（码云地址）

--------------------

# RabbitMQ之队列限流 #

我们在之前讲MQ好处的时候就说过MQ可以做流量削峰，当网站承受的压力已经到达极限时，我们可以采用MQ来进行限流操作

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center]

## 11.1 案例测试 ##

### 11.1.1配置spring.xml： ###

一般情况下，队列限流设置为手动签收

<rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual" prefetch="1">
         <rabbit:listener ref="qosListener" queue-names="test_queue_confirm"></rabbit:listener>
    </rabbit:listener-container>

### 11.1.2 监听器 ###

package com.lscl.rabbitmq.listener;
    
    import com.rabbitmq.client.Channel;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
    import org.springframework.stereotype.Component;
    
    /** * Consumer 限流机制 * listener-container配置属性 * perfetch = 1,表示消费端每次从mq拉去一条消息来消费，直到手动确认消费完毕后，才会继续拉去下一条消息。 */
    
    @Component
    public class QosListener implements ChannelAwareMessageListener { 
    
        @Override
        public void onMessage(Message message, Channel channel) throws Exception { 
    
            Thread.sleep(1000);
            //1.获取消息
            System.out.println(new String(message.getBody()));
    
            //2. 处理业务逻辑
            System.out.println("处理业务逻辑...");
    
            //3. 签收
            channel.basicAck(message.getMessageProperties().getDeliveryTag(),true);
        }
    }

### 11.1.3 消息生产者发送消息 ###

@Test
    public void testSend() { 
        for (int i = 1; i <= 10; i++) { 
            rabbitTemplate.convertAndSend("test_exchange_confirm", "confirm", "这是第" + i + "条消息");
        }
    }

[RabbitMQ_-]: https://blog.csdn.net/Bb15070047748/article/details/112194912
[https_gitee.com_Horizon1024_rabbitmt.git]: https://gitee.com/Horizon1024/rabbitmt.git
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JiMTUwNzAwNDc3NDg_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/b8c974bbbafd4528bf588b9f30b74261.png