fix rabbitmq

Helius

2021-12-03 31702fe7fb4a4576daf0420539ff3ccc1216c6fe

fix rabbitmq

 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() {

 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 {

 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: