springboot rabbitmq线程数配置 yml 共用同一个连接 设置最小线程数和最大线程数

在Spring Boot中配置RabbitMQ的线程数可以通过application.yml文件来实现。首先，你需要添加RabbitMQ的配置信息，如下所示：

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

接下来，你需要配置线程池的最小和最大线程数。可以使用SimpleRabbitListenerContainerFactory类来配置线程池，如下所示：

@Configuration
public class RabbitMQConfig {

    @Autowired
    private ConnectionFactory connectionFactory;

    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setConcurrentConsumers(3); // 设置最小线程数
        factory.setMaxConcurrentConsumers(10); // 设置最大线程数
        return factory;
    }
}

在上面的代码中，我们通过SimpleRabbitListenerContainerFactory类来创建一个RabbitMQ监听器容器工厂，并设置了最小线程数为3，最大线程数为10。然后，我们将这个工厂注入到Spring容器中。

最后，你可以使用@RabbitListener注解来定义消费者方法，如下所示：

@Component
public class RabbitMQConsumer {

    @RabbitListener(queues = "myQueue")
    public void handleMessage(String message) {
        // 消费消息的逻辑
    }
}

上面的代码中，我们使用@RabbitListener注解来定义了一个消费者方法，用于处理名为"myQueue"的队列中的消息。

这样，当应用启动时，RabbitMQ将会以3个线程开始消费消息，并且最多可以使用10个线程来处理消息