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