c# rabbitmq消费者

C# RabbitMQ消费者可以通过使用EventingBasicConsumer类来接收生产者发送的消息。在代码中，我们创建了一个Connection和一个Channel，并使用EventingBasicConsumer定义了一个消费者。在接收到消息时，可以通过设置Received事件来触发相应的处理逻辑。具体的代码如下所示：

var factory = new ConnectionFactory()
{
    HostName = "127.0.0.1", // RabbitMQ服务器的IP地址
    UserName = "wyy", // 用户名
    Password = "123321" // 密码
};

using (var connection = factory.CreateConnection())
{
    using (var channel = connection.CreateModel())
    {
        // 定义一个EventingBasicConsumer消费者
        var consumer = new EventingBasicConsumer(channel);

        // 接收到消息时触发的事件
        consumer.Received += (model, ea) =>
        {
            Console.WriteLine(Encoding.UTF8.GetString(ea.Body));
        };

        Console.WriteLine("消费者准备就绪....");

        // 调用消费方法
        channel.BasicConsume(queue: "myqueue", autoAck: true, consumer: consumer);

        Console.ReadKey();
    }
}