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