Rabbitmq及Web監控工具的使用

1.Rabbitmq的官方下載地址：https://www.rabbitmq.com/download.html

注意：

    RabbitMQ需要安裝64位支持的Erlang for Windows版本。Erlang版本包括Windows安裝程序。Erlang Solutions也 提供二進制64位Erlang版本。

   重要提示：必須使用管理帳戶運行Erlang安裝程序，否則RabbitMQ安裝程序所需的注冊表項將不存在。

 

2.web監控工具（下載RabbitMQ時默認包含web監控工具）

使用方式：

（1）進入到RabbitMQ的安裝地址：

    輸入命令啟動監控工具：rabbitmq-plugins enable rabbitmq_management

 

（2）步驟1啟動后打開瀏覽器輸入網址：http://localhost:15672/   賬號密碼都是：guest    

 

3..net 實現簡單的消息發送與接收

（1）創建.net core控制台項目，新建發送類：Send.cs

注：需要先添加程序集依賴項：RabbitMQ.Client

//建立一個消息，名稱為：hello
public class Send 
{
    public static void sendMain()
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        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 Amanda";
                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();
        }

    }
}

執行之后可以通過web監控工具程序查看結果：

    

 

 

（2）創建.net core控制台項目，新建接收類：Receive.cs

注：需要先添加程序集依賴項：RabbitMQ.Client

public class Receive
{
    public static void ReceiveMain()
    {
        var factory = new ConnectionFactory() { HostName = "localhost" };
        using (var connection = factory.CreateConnection())
        {
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare(
                    queue:"hello",
                    exclusive:false,
                    autoDelete:false,
                    arguments:null
                    );
                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);
                };
                channel.BasicConsume(
                    queue:"hello",
                    autoAck:true,
                    consumer:consumer
                    );
                Console.WriteLine("Press [enter] to exit");
                Console.ReadLine();
            }
        }
    }
}

執行之后可以通過web監控工具程序查看結果：