springboot整合rabbitmq实现限流与并发

java1234

共 2872字,需浏览 6分钟

 ·

2021-03-15 09:26

点击上方蓝色字体,选择“标星公众号”

优质文章,第一时间送达

76套java从入门到精通实战课程分享

一 并发

步骤:

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结果:

————————————————


版权声明:本文为CSDN博主「zisuu」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。

原文链接:

https://blog.csdn.net/zisuu/article/details/105567216




粉丝福利:Java从入门到入土学习路线图

👇👇👇

👆长按上方微信二维码 2 秒


感谢点赞支持下哈 

浏览 45
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报