ASP.NET中的长时间运行的RabbitMQ连接

using RabbitMQ.Client;

public class RabbitMQConnection
{
    private static IConnection _connection;

    public static IConnection GetConnection()
    {
        if (_connection == null || !_connection.IsOpen)
        {
            var factory = new ConnectionFactory()
            {
                HostName = "localhost", // RabbitMQ服务器地址
                UserName = "guest", // 用户名
                Password = "guest" // 密码
            };

            _connection = factory.CreateConnection();
        }

        return _connection;
    }
}

public class RabbitMQProducer
{
    public void SendMessage(string message)
    {
        var connection = RabbitMQConnection.GetConnection();
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "myqueue", durable: true, exclusive: false, autoDelete: false, arguments: null);

            var body = Encoding.UTF8.GetBytes(message);

            var properties = channel.CreateBasicProperties();
            properties.Persistent = true;

            channel.BasicPublish(exchange: "", routingKey: "myqueue", basicProperties: properties, body: body);
        }
    }
}

public class RabbitMQConsumer
{
    public void StartConsuming()
    {
        var connection = RabbitMQConnection.GetConnection();
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: "myqueue", durable: true, exclusive: false, autoDelete: false, arguments: null);

            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);

                // 处理接收到的消息
                Console.WriteLine("Received message: {0}", message);
            };

            channel.BasicConsume(queue: "myqueue", autoAck: true, consumer: consumer);
        }
    }
}