C#操作RabbitMQ的完整实例

2020-01-24 00:32:44

字体：大中小

来源：转载

供稿：网友

一、下载RabbitMQ

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

二、下载OTP

http://www.erlang.org/downloads

三、安装OTP、RabbitMQ

四、配置RabbitMQ

找到bat的目录

执行相关命令

1.添加用户密码 rabbitmqctl add_user wenli wenli

2.设置wenli为管理员rabbitmqctl set_user_tags wenli administrator

3.启动RabbitMQ的web管理rabbitmq-plugins enable rabbitmq_management

4.创建virtual host

5.设置用户权限

点击用户名进行设置

将virtual hosts 权限赋给用户wenli

6.创建Exchanges

五.创建C# console

1.下载RabbitMQ驱动 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.运行结果：