消费端限流
/** 设置限流机制
* param1: prefetchSize,消息本身的大小 如果设置为0 那么表示对消息本身的大小不限制
* param2: prefetchCount,告诉rabbitmq不要一次性给消费者推送大于N个消息
* param3:global,是否将上面的设置应用于整个通道,false表示只应用于当前消费者
*/
channel.BasicQos(0, 1, false);
RabbitMQ高级应用之消费端限流策略basicQos详解_java_脚本之家 (jb51.net)
RabbitMQ消息有两种类型:
1、持久化消息和非持久化消息
2、这两种消息都会被写入磁盘
RabbitMQ的数据存储_rabbitmq数据存储位置-CSDN博客
IBasicProperties basicProperties = channel.CreateBasicProperties();
// basicProperties.Priority = 2;//消息优先级 2
basicProperties.DeliveryMode = 2;//持久化
《RabbitMQ系列》之RabbitMQ的优先级队列 - 知乎 (zhihu.com)
RabbitMQ_rabbitmq.deliverymode-CSDN博客
标签:false,rabbitmq,basicProperties,限流,RabbitMQ,消息 From: https://www.cnblogs.com/yyxone/p/18117903