c# rabbitmq连接池封装的方法是什么

在C#中，可以通过使用RabbitMQ.Client库来连接和操作RabbitMQ消息队列。以下是一个简单的示例，展示了如何封装一个基本的RabbitMQ连接池方法：

using System;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;

public class RabbitMQPool
{
    private readonly string _connectionString;
    private IConnection _connection;
    private IModel _channel;

    public RabbitMQPool(string connectionString)
    {
        _connectionString = connectionString;
        CreateConnection();
    }

    public void CreateConnection()
    {
        var factory = new ConnectionFactory
        {
            Uri = new Uri(_connectionString)
        };
        _connection = factory.CreateConnection();
        _channel = _connection.CreateModel();
    }

    public void Publish(string exchange, string routingKey, byte[] message)
    {
        _channel.BasicPublish(exchange, routingKey, null, message);
    }

    public void Consume(string queue, Action<byte[]> callback)
    {
        var consumer = new EventingBasicConsumer(_channel);
        consumer.Received += (model, ea) =>
        {
            var body = ea.Body.ToArray();
            callback(body);
        };

        _channel.BasicConsume(queue, true, consumer);
    }

    public void CloseConnection()
    {
        _channel?.Close();
        _connection?.Close();
    }
}

使用示例：

var connectionString = "amqp://guest:guest@localhost:5672";
var pool = new RabbitMQPool(connectionString);

// 发布消息
var exchange = "myExchange";
var routingKey = "myRoutingKey";
var message = Encoding.UTF8.GetBytes("Hello RabbitMQ");
pool.Publish(exchange, routingKey, message);

// 消费消息
var queue = "myQueue";
pool.Consume(queue, (body) =>
{
    var receivedMessage = Encoding.UTF8.GetString(body);
    Console.WriteLine(receivedMessage);
});

// 关闭连接
pool.CloseConnection();

注意：在实际使用中，你可能需要根据自己的需求进一步完善和优化连接池的功能，例如添加连接池大小限制、连接复用等。上述示例仅提供了一个基本的封装框架，你可以根据自己的实际需求进行调整和扩展。