C#操作RabbitMQ的完整實例

更新時間：2017年08月29日 11:19:40 作者：YSWALLE

這篇文章主要為大家詳細介紹了C#操作RabbitMQ的完整實例，具有一定的參考價值，感興趣的小伙伴們可以參考一下

一、下載RabbitMQ

http://www.rabbitmq.com/install-windows.html

二、下載OTP

http://www.erlang.org/downloads

三、安裝OTP、RabbitMQ

四、配置RabbitMQ

找到bat的目錄

執(zhí)行相關(guān)命令

1.添加用戶密碼 rabbitmqctl add_user wenli wenli

2.設(shè)置wenli為管理員rabbitmqctl set_user_tags wenli administrator

3.啟動RabbitMQ的web管理rabbitmq-plugins enable rabbitmq_management

4.創(chuàng)建virtual host

5.設(shè)置用戶權(quán)限

點擊用戶名進行設(shè)置

將virtual hosts 權(quán)限賦給用戶wenli

6.創(chuàng)建Exchanges

五.創(chuàng)建C# console

1.下載RabbitMQ驅(qū)動 https://github.com/yswenli/Wenli.Data.RabbitMQ/releases/tag/Release1.0.0

2.添加引用

3.添加配置

4.測試代碼：

using System;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Wenli.Data.RabbitMQ.Console
{
  using Console = System.Console;

  class Program
  {
    static void Main(string[] args)
    {
      Console.Title = "Wenli.Data.RabbitMQ.Console";
      Console.WriteLine("正連接到mq");

      try
      {
        Test();
      }
      catch (Exception ex)
      {
        Console.WriteLine("err:" + ex.Message + ex.Source + ex.StackTrace);
      }

      Console.Read();
    }


    static void Test()
    {

      var topic = "testtopic";

      var cnn = RabbitMQBuilder.Get(MQConfig.Default).GetConnection();

      var operation = cnn.GetOperation(topic);

      Console.WriteLine("正連接到訂閱【" + topic + "】");

      operation.Subscribe();

      Console.WriteLine("正在入隊");

      Task.Factory.StartNew(() =>
      {
        while (true)
        {
          operation.Enqueue(Encoding.UTF8.GetBytes(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "   hello!"));
          Thread.Sleep(1);
        }
      });




      Console.WriteLine("正在出隊");



      Task.Factory.StartNew(() =>
      {
        while (true)
        {
          var result = operation.Dnqueue();

          if (result == null)
          {
            Thread.Sleep(1);
          }
          else
          {
            Console.WriteLine(Encoding.UTF8.GetString(result));
          }
        }
      });

      Console.ReadLine();

      Console.WriteLine("正在取消訂閱");

      operation.UnSubscribe();

      Console.WriteLine("測試完成");
    }
  }
}

5.運行結(jié)果：