RabbitMQ

RabbitMQ:这是一种基于AMQP协议的消息队列,C#可以通过RabbitMQ Client库进行访问。

// 创建连接工厂
ConnectionFactory factory = new ConnectionFactory() { HostName = "localhost" };
// 创建连接
using (IConnection connection = factory.CreateConnection())
{
 // 创建信道
 using (IModel channel = connection.CreateModel())
 {
     // 声明消息队列
     channel.QueueDeclare("queue_name", false, false, false, null);

     // 发布消息
     channel.BasicPublish("", "queue_name", null, Encoding.UTF8.GetBytes("Message"));

     // 消费消息
     var consumer = new QueueingBasicConsumer(channel);
     channel.BasicConsume("queue_name", true, consumer);
     while (true)
     {
         var delivery = consumer.Queue.Dequeue();
         var message = Encoding.UTF8.GetString(delivery.Body);
         Console.WriteLine("Received: {0}", message);
     } 
 }
}