rabbitmq使用basicQos控制速率

默认情况下，RabbitMq收到消息后，就向消费者全部推送。但是如果rabbitmq队列里消息过多，且消息的数量超过了消费者处理能力, 就会导致客户端超负荷崩溃。此时我们可以通过 prefetchCount 限制每个消费者在收到下一个确认回执前一次可以最大接受多少条消息。即如果设置prefetchCount =1，RabbitMQ向这个消费者发送一个消息后，再这个消息的消费者对这个消息进行ack之前，RabbitMQ不会向这个消费者发送新的消息

 // 每个客户端每次最后获取N个消息
channel.basicQos(1);

订阅队列消息不控制接收速率

不使用channel.BasicQos 控制 prefetchCount 数量:

         var consumer = new EventingBasicConsumer(channel);consumer.Received += (ch, ea) =>{var body = ea.Body.ToArray();var msg = Encoding.UTF8.GetString(body);Console.WriteLine(msg);// copy or deserialise the payload// and process the message// ...channel.BasicAck(ea.DeliveryTag, false);Thread.Sleep(1000);};String consumerTag = channel.BasicConsume("mytest", false, consumer);

订阅队列消息控制接收速率

 channel.BasicQos(0, 1, true); //每次从队列里取出一条消息;var consumer = new EventingBasicConsumer(channel);consumer.Received += (ch, ea) =>{var body = ea.Body.ToArray();var msg = Encoding.UTF8.GetString(body);Console.WriteLine(msg);// copy or deserialise the payload// and process the message// ...channel.BasicAck(ea.DeliveryTag, false);Thread.Sleep(1000);};String consumerTag = channel.BasicConsume("mytest", false, consumer);

(Qos 相当于把 connection 只限制了一个channel;)

本文由博客一文多发平台 OpenWrite 发布！

rabbitmq使用basicQos控制速率相关推荐

cesium的clock开始,结束,控制速率
开始 viewer.clock.shouldAnimate = true; 结束 window.viewer.clock.shouldAnimate = false; 速率调整 viewer.cloc ...
深入理解RabbitMQ中的prefetch_count参数
目录 prefetch_count参数的含义 RabbitMQ客户端中prefetch_count源码跟踪 prefetch_count参数使用 prefetch_count参数最佳实践小结 pre ...
消息队列重要机制讲解以及MQ设计思路（kafka、rabbitmq、rocketmq）
目录 <Kafka篇> 简述kafka的架构设计原理(入口点) 消息队列有哪些作用(简单) 消息队列的优缺点,使用场景(基础) 消息队列如何保证消息可靠传输死信队列是什么?延时队列是什么 ...
RabbitMQ 学习笔记
RabbitMQ 学习笔记 RabbitMQ 学习笔记 1. 中间件 1.1 什么是中间件 1.2 为什么要使用消息中间件 1.3 中间件特点 1.4 在项目中什么时候使用中间件技术 2. 中间件技术 ...
RabbitMQ狂神说笔记（RabbitMQ B站狂神说笔记、KuangStudy、学相伴飞哥）
一. 引用文章 RabbitMQ狂神说笔记(B站狂神说笔记.KuangStudy.学相伴飞哥) RabbitMQ狂神说笔记(B站狂神说笔记.KuangStudy.学相伴飞哥)百度云盘地址,提取码:07 ...
狂神RabbitMQ
RabbitMQ笔记一.中间件 1.什么是中间件 1.什么是中间件我国企业从20世纪80年代开始就逐渐进行信息化建设,由于方法和体系的不成熟,以及企业业务和市场需求的不断变化,一个企业可能同时运行 ...
【学相伴】狂神说 RabbitMQ笔记（简单使用RabbitMQ）
目录什么是rabbitMQ 使用docker安装RabbitMQ,如果没有使用过docker的可以看这篇文章https://blog.csdn.net/qq_44716544/article/det ...
消息中间件---RabbitMQ
rabbitmq和spring是同一个公司,支持性最好 1.什么是中间件中间件(Middleware)是处于操作系统和应用程序之间的软件,也有人认为它应该属于操作系统中的一部分.人们在使用中间件时, ...
RabbitMQ【RabbitMQ】
RabbitMQ[RabbitMQ] 前言说明推荐 RabbitMQ 一.中间件 1.什么是中间件 2.中间件技术及架构的概述 3.基于消息中间件的分布式系统的架构 4.消息队列协议 5.消息队列 ...

rabbitmq使用basicQos控制速率

订阅队列消息不控制接收速率

订阅队列消息控制接收速率

rabbitmq使用basicQos控制速率相关推荐

最新文章

热门文章