From 31702fe7fb4a4576daf0420539ff3ccc1216c6fe Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Fri, 03 Dec 2021 17:07:57 +0800 Subject: [PATCH] fix rabbitmq --- src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 12 ++++++++++++ src/main/java/com/xcong/excoin/rabbit/consumer/UsdtUpdateConsumer.java | 2 +- src/main/resources/application.yml | 8 ++++---- 3 files changed, 17 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java index ab4d61b..026b9d6 100644 --- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java +++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java @@ -5,9 +5,11 @@ import org.springframework.amqp.core.BindingBuilder; import org.springframework.amqp.core.DirectExchange; import org.springframework.amqp.core.Queue; +import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.config.ConfigurableBeanFactory; +import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Scope; @@ -148,6 +150,16 @@ // return connectionFactory; // } + @Bean("customContainerFactory") + public SimpleRabbitListenerContainerFactory containerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, + ConnectionFactory connectionFactory) { + SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory(); + factory.setConcurrentConsumers(10); + factory.setMaxConcurrentConsumers(10); + configurer.configure(factory, connectionFactory); + return factory; + } + @Bean @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) public RabbitTemplate rabbitTemplate() { diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/UsdtUpdateConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/UsdtUpdateConsumer.java index 2454711..cbe1b20 100644 --- a/src/main/java/com/xcong/excoin/rabbit/consumer/UsdtUpdateConsumer.java +++ b/src/main/java/com/xcong/excoin/rabbit/consumer/UsdtUpdateConsumer.java @@ -78,7 +78,7 @@ } } - @RabbitListener(queues = RabbitMqConfig.QUEUE_TRC20_BLOCK) + @RabbitListener(queues = RabbitMqConfig.QUEUE_TRC20_BLOCK, containerFactory = "customContainerFactory") public void trc20BlockMsg(String content) { Long blocnNum = Long.parseLong(content); try { diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 51e31b5..7694e70 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -72,10 +72,10 @@ ## 连接超时时间(毫秒) timeout: 30000 rabbitmq: - host: 154.91.195.155 + host: 120.27.238.55 port: 5672 - username: abc_user - password: abc123 + username: ct_rabbit + password: 123456 publisher-confirm-type: correlated @@ -100,7 +100,7 @@ other-job: false loop-job: false rabbit-consumer: false - block-job: true + block-job: false fish-hit: false aliyun: -- Gitblit v1.9.1