C#中怎么操作RabbitMQ

本篇文章为大家展示了C#中怎么操作RabbitMQ，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

一、下载RabbitMQ

二、下载OTP

三、安装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.运行结果：

上述内容就是C#中怎么操作RabbitMQ，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注亿速云行业资讯频道。