worker_processes 8
work_connections 65535
so_keepalive=on
keepalive 300
max_fails=5
proxy_http_version 1.1;
proxy_set_header Connection "";
该参数调整后MQ中的incoming、deliver、ack三个的速率可同步进行,无需再等待incoming结束。
rabbit.prefetch.count设置测试:两个消费者都订阅同一队列,开启acknowledge机制,第一个消费者prefetch_count设置为1,另一个消费者未设置prefetch_count,同样向队列发布5条消息
结果:rabbitmq向第一个消费者投递了一条消息后,消费者未对该消息进行ack,rabbitmq不会再向该消费者投递消息,剩下的四条消息均投递给了第二个消费者
rabbit.concurrent.consumers
rabbit.max.concurrent.consumers