RabbitMQ学习（六）-- 限流器使用

女爷i 2022-12-29 06:17 134阅读 0赞

### 目录 ###

*  一、添加配置
 *  二、添加代码
 *  三、测试结果

# 一、添加配置 #

spring:
      rabbitmq:
        listener:
          type: direct
          direct:
            acknowledge-mode: manual #手动模式
            prefetch: 5 #每秒处理5条请求

# 二、添加代码 #

package com.wayne.listener;
    
    import com.rabbitmq.client.Channel;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
    import org.springframework.stereotype.Component;
    
    import static com.wayne.core.config.RabbitConfig.QUEUE_NAME;
    
    @Slf4j
    @Component
    public class QosListenser implements ChannelAwareMessageListener { 
    
    
        @Override
        @RabbitListener(queues = QUEUE_NAME)
        public void onMessage(Message message, Channel channel) throws Exception { 
    
            Thread.sleep(1000);
            long deliveryTag = message.getMessageProperties().getDeliveryTag();
            //1.接收转换参数
            log.info(new String(message.getBody()));
            //2.接收业务处理
            log.info("业务处理");
            //3.手动签收
            /** * deliveryTag：发送状态 * multiple:允许多条消息同时被签收 */
            //限流模式必须要手动确认，这里注释，只是为了学习用
            //channel.basicAck(deliveryTag,true);
        }
    }

# 三、测试结果 #

测试结果如下  
原消息队列中有10条数据  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ_size_16_color_FFFFFF_t_70]  
prefetch为1时  
![测试结果][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ_size_16_color_FFFFFF_t_70 1]  
prefetch为5时  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ_size_16_color_FFFFFF_t_70]: /images/20221120/d603a7b8f04747418153389b597f74c0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20201220165227115.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201220165721273.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E4MEM1MQ==,size_16,color_FFFFFF,t_70