RabbitMQ C#实用示例

using RabbitMQ.Client;
using System;
using System.Text;

class Program
{
    static void Main()
    {
        // 创建连接工厂
        var factory = new ConnectionFactory()
        {
            HostName = "localhost", // RabbitMQ服务器地址
            UserName = "guest", // 用户名
            Password = "guest" // 密码
        };

        // 创建连接
        using (var connection = factory.CreateConnection())
        {
            // 创建通道
            using (var channel = connection.CreateModel())
            {
                // 声明队列
                channel.QueueDeclare(queue: "hello",
                                     durable: false,
                                     exclusive: false,
                                     autoDelete: false,
                                     arguments: null);

                // 发布消息
                string message = "Hello, RabbitMQ!";
                var body = Encoding.UTF8.GetBytes(message);
                channel.BasicPublish(exchange: "",
                                     routingKey: "hello",
                                     basicProperties: null,
                                     body: body);
                Console.WriteLine(" [x] Sent {0}", message);
            }
        }

        Console.WriteLine(" Press [enter] to exit.");
        Console.ReadLine();
    }
}