导航：首页 > 服务器 >

springboot中怎么利用rabbitmq实现限流与并发

发表于：2025-01-19 作者：千家信息网编辑

千家信息网最后更新 2025年01月19日，springboot中怎么利用rabbitmq实现限流与并发，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。一并发步骤:1 、在rabb

千家信息网最后更新 2025年01月19日springboot中怎么利用rabbitmq实现限流与并发

springboot中怎么利用rabbitmq实现限流与并发，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

一并发

步骤:

1 、在rabbitListener中配置concurency="min-max"

如下代表最小并发数是5

@Component
public class pricon {
    @RabbitListener(queues ="textQueue",concurrency = "5-10")
    public void hand(String str){
        System.out.println(Thread.currentThread().getName()+"接受到了一个消息:"+str+"现在时间:"+System.currentTimeMillis()/1000);
    }
}

2、测试

@Component
public class priConsumer {
    private static final String EXCHANGE = "textExchange";

    public static final String QUEUE = "textQueue";

    private static final String ROUTING_KEY = "textQueue";
    @Autowired
    RabbitTemplate template;
    public void test(){
        for(int i=50;i>1;i--){
            int finalI = i;
            template.convertAndSend(EXCHANGE,ROUTING_KEY,"queue:"+i);
        }

    }
}

3、在rabbitmq的控制面板中会显示:

二限流

1、配置Bean

setPrefetchCount 表示单位时间最多能处理多少消息

@Autowired
    CachingConnectionFactory connectionFactory;
    @Bean(name = "mqlistenerContainer")
    public SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory(){
        SimpleRabbitListenerContainerFactory factory=new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setPrefetchCount(10);
        return factory;
    }

2、在rabbitListener中配置工厂

 @RabbitListener(queues ="textQueue",concurrency = "5-10",containerFactory = "mqlistenerContainer")
    public void hand(String str){
        System.out.println(Thread.currentThread().getName()+"接受到了一个消息:"+str+"现在时间:"+System.currentTimeMillis()/1000);
    }

在控制面板中会显示:

3结果:

看完上述内容，你们掌握springboot中怎么利用rabbitmq实现限流与并发的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注行业资讯频道，感谢各位的阅读！

很赞哦！