Bläddra i källkod

// 消息队列优化

ZIPZAP 2 år sedan
förälder
incheckning
6c5184e29b

+ 3 - 3
consumer-manager/consumer-store/src/main/java/com/qls/consumer/store/config/RabbitListenerConfig.java

@@ -19,9 +19,9 @@ public class RabbitListenerConfig {
         factory.setConnectionFactory(connectionFactory);
         factory.setBatchListener(true);
         factory.setConsumerBatchEnabled(true);
-        factory.setPrefetchCount(100);
-        factory.setConcurrentConsumers(50);
-        factory.setMaxConcurrentConsumers(100);
+        factory.setPrefetchCount(20);
+        factory.setConcurrentConsumers(20);
+        factory.setMaxConcurrentConsumers(40);
         configurer.configure(factory, connectionFactory);
         return factory;
     }