using RabbitMQ.Client;

var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
{
    // 連接成功后的代碼...
}

using (var channel = connection.CreateModel())
{
    // 創(chuàng)建成功后的代碼...
}

channel.QueueDeclare(queue: "hello",
                     durable: false,
                     exclusive: false,
                     autoDelete: false,
                     arguments: null);

string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);

channel.BasicPublish(exchange: "",
                     routingKey: "hello",
                     basicProperties: null,
                     body: body);
Console.WriteLine(" [x] Sent {0}", message);

var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
    var body = ea.Body.ToArray();
    var message = Encoding.UTF8.GetString(body);
    Console.WriteLine(" [x] Received {0}", message);
};

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

channel.ExchangeDeclare(exchange: "direct_logs",
                         type: ExchangeType.Direct);

var severity = "info";
var message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "direct_logs",
                     routingKey: severity,
                     basicProperties: null,
                     body: body);
Console.WriteLine(" [x] Sent '{0}':'{1}'", severity, message);

channel.ExchangeDeclare(exchange: "topic_logs",
                         type: ExchangeType.Topic);

var routingKey = "anonymous.info";
var message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "topic_logs",
                     routingKey: routingKey,
                     basicProperties: null,
                     body: body);
Console.WriteLine(" [x] Sent '{0}':'{1}'", routingKey, message);