RabbitMQ 筆記

digraph hierarchy {
​               User -> {Virtual_Hosts}
​               Virtual_Hosts -> {Exchange User}
​               Exchange -> {Routing_Key Queue}
​               Routing_Key -> {Queue Exchange}
}

digraph hierarchy {
​​              User -> {Virtual_Hosts}
​​              Virtual_Hosts -> {Queue User}

}

public class RabbitMqFactory
{
    public static ConnectionFactory Create()
    {
        return new ConnectionFactory()
        {
            HostName = "192.168.11.142",
            UserName = "dpc",
            Password = "123",
            VirtualHost = "DPC"
        };
    }
}

var factory = RabbitMqFactory.Create();
using (var connection = factory.CreateConnection())
{
    using (var channel = connection.CreateModel())
    {
        var consumer = new EventingBasicConsumer(channel);
        consumer.Received += (model, ea) =>
        {
            var body = ea.Body;
            var message = Encoding.UTF8.GetString(body);
            Console.WriteLine(" [x] Received {0}", message);
        };
        //底下代表同時監聽OAO,OAO2,OAO3
        channel.BasicConsume(queue: "OAO",
            autoAck: true,
            consumer: consumer);
        channel.BasicConsume(queue: "OAO2",
            autoAck: true,
            consumer: consumer);
        channel.BasicConsume(queue: "OAO3",
            autoAck: true,
            consumer: consumer);

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

var factory = RabbitMqFactory.Create();
using (var connection = factory.CreateConnection())
{
    using (var channel = connection.CreateModel())
    {
        string message = "Hello World!";
        var body = Encoding.UTF8.GetBytes(message);
                        
        channel.BasicPublish(exchange: "",
                             routingKey: "OAO",
                             basicProperties: null,
                             body: body);
        Console.WriteLine(" [x] Sent {0}", message);
    }
}

channel.ExchangeDeclare("testOAO",ExchangeType.Direct);

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

BasicGetResult result = channel.BasicGet("QueueName", false);
uint count = result != null ? result.MessageCount : 0;