rabbitmq 用BlockingQueue实现一个连接池，使用springBoot框架

可以使用SpringBoot框架和BlockingQueue实现一个RabbitMQ连接池，具体步骤如下：

1. 创建一个连接池类，用于管理RabbitMQ连接。在这个类中，我们需要定义一个BlockingQueue来存储连接对象，以及一些方法来获取和释放连接。

@Component
public class RabbitMQPool {
    @Value("${rabbitmq.host}")
    private String host;
    @Value("${rabbitmq.port}")
    private int port;
    @Value("${rabbitmq.username}")
    private String username;
    @Value("${rabbitmq.password}")
    private String password;
    @Value("${rabbitmq.virtualhost}")
    private String virtualHost;
    @Value("${rabbitmq.poolSize}")
    private int poolSize;

    private BlockingQueue<Channel> channelPool;

    private ConnectionFactory connectionFactory;

    @PostConstruct
    public void init() {
        channelPool = new LinkedBlockingQueue<>(poolSize);
        connectionFactory = new ConnectionFactory();
        connectionFactory.setHost(host);
        connectionFactory.setPort(port);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        connectionFactory.setVirtualHost(virtualHost);
    }

    public Channel getChannel() throws InterruptedException, TimeoutException, IOException {
        Channel channel = channelPool.poll();
        if (channel == null) {
            Connection connection = connectionFactory.newConnection();
            channel = connection.createChannel();
        }
        return channel;
    }

    public void releaseChannel(Channel channel) {
        channelPool.offer(channel);
    }
}

2. 在SpringBoot配置文件中，配置RabbitMQ连接池的参数。

rabbitmq.host=127.0.0.1
rabbitmq.port=5672
rabbitmq.username=guest
rabbitmq.password=guest
rabbitmq.virtualhost=/
rabbitmq.poolSize=10

3. 在需要使用RabbitMQ连接的地方，注入RabbitMQPool对象，并使用它来获取和释放连接。

@Service
public class RabbitMQService {
    @Autowired
    private RabbitMQPool rabbitMQPool;

    public void sendMessage(String message) {
        try {
            Channel channel = rabbitMQPool.getChannel();
            channel.basicPublish("exchange", "routingKey", null, message.getBytes());
            rabbitMQPool.releaseChannel(channel);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

通过以上步骤，我们就可以使用BlockingQueue和SpringBoot框架来实现一个简单的RabbitMQ连接池了。