C# 使用RabbitMQ的完整图解

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了C# 使用RabbitMQ的完整图解，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4013字，纯文字阅读大概需要6分钟。

内容图文

C# 使用RabbitMQ的完整图解

1.前言

Message Queue消息队列，简称MQ，是一种应用程序对应用程序的通信方法，应用程序通过读写出入队列的消息来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此通信。

MQ是消费-生产者模型的一个典型代表，一端往消息队列中不断写入消息，而另一端则可以读取或者订阅队列中的消息。

2. 安装

提示：以下的链接下载特别慢，建议到我的网盘下载,包括案例，速度特快(回复rabbit)

1. 下载RabbitMQ

RabbitMQ服务：http://www.rabbitmq.com/download.html

安装完RabbitMQ服务后，会在Windows服务中看到。如果没有Erlang运行环境，在安装过程中会提醒先安装Erlang环境

2. OTP

点击是就会直接跳转，或者点击链接进行下载

下载完后进行暗安装

3.使用

打不开web管理工具的请看参考

web管理工具的地址是：http://localhost:15672
初始用户名：guest
初始密码：guest

4.代码实现

消息生产者

class Program
    {
        static void Main(string[] args)
        {
            try
            {
                ConnectionFactory factory = new ConnectionFactory();
                factory.HostName = Constants.MqHost;
                factory.Port = Constants.MqPort;
                factory.UserName = Constants.MqUserName;
                factory.Password = Constants.MqPwd;
                using (IConnection conn = factory.CreateConnection())
                {
                    using (IModel channel = conn.CreateModel())
                    {
                        //在MQ上定义一个持久化队列，如果名称相同不会重复创建
                        channel.QueueDeclare("MyFirstQueue", true, false, false, null);
                        while (true)
                        {
                            string customStr = Console.ReadLine();
                            RequestMsg requestMsg = new RequestMsg();
                            requestMsg.Name = string.Format("Name_{0}", customStr);
                            requestMsg.Code = string.Format("Code_{0}", customStr);
                            string jsonStr = JsonConvert.SerializeObject(requestMsg);
                            byte[] bytes = Encoding.UTF8.GetBytes(jsonStr);
                            
                            //设置消息持久化
                            IBasicProperties properties = channel.CreateBasicProperties();
                            properties.DeliveryMode = 2;
                            channel.BasicPublish("", "MyFirstQueue", properties, bytes);

                            //channel.BasicPublish("", "MyFirstQueue", null, bytes);

                            Console.WriteLine("消息已发送：" + requestMsg.ToString());
                        }
                    }
                }
            }
            catch (Exception e1)
            {
                Console.WriteLine(e1.ToString());
            }
            Console.ReadLine();
        }
    }

消息消费者

class Program
    {
        static void Main(string[] args)
        {
            try
            {
                ConnectionFactory factory = new ConnectionFactory();
                factory.HostName = Constants.MqHost;
                factory.Port = Constants.MqPort;
                factory.UserName = Constants.MqUserName;
                factory.Password = Constants.MqPwd;
                using (IConnection conn = factory.CreateConnection())
                {
                    using (IModel channel = conn.CreateModel())
                    {
                        //在MQ上定义一个持久化队列，如果名称相同不会重复创建
                        channel.QueueDeclare("MyFirstQueue", true, false, false, null);

                        //输入1，那如果接收一个消息，但是没有应答，则客户端不会收到下一个消息
                        channel.BasicQos(0, 1, false);
                        
                        Console.WriteLine("Listening...");

                        //在队列上定义一个消费者
                        QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);
                        //消费队列，并设置应答模式为程序主动应答
                        channel.BasicConsume("MyFirstQueue", false, consumer);

                        while (true)
                        {
                            //阻塞函数，获取队列中的消息
                            BasicDeliverEventArgs ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
                            byte[] bytes = ea.Body;
                            string str = Encoding.UTF8.GetString(bytes);
                            RequestMsg msg = JsonConvert.DeserializeObject<RequestMsg>(str);
                            Console.WriteLine("HandleMsg:" + msg.ToString());
                            //回复确认
                            channel.BasicAck(ea.DeliveryTag, false);
                        }
                    }
                }
            }
            catch (Exception e1)
            {
                Console.WriteLine(e1.ToString());
            }
            Console.ReadLine();
        }
    }

5.总结

最后的运行结果

消息生产者_代码GITHUB
https://github.com/PrideJoy/NetTemple/blob/master/MessageProducer/Program.cs

消息消费者 _代码GITHUB

6.项目说明

关于仓库说明，https://github.com/PrideJoy/NetTemple/
每一个项目都是自己亲自练习的
这个项目是关于c#基本知识学习的练习，作为我入门的练手程序，自己学习的一个积累，如今共享出来，也希望对学习C#的朋友有点参考价值

如果觉得可以的话，点点关注不迷路

喜欢开源项目的话，可以点点看看（项目代码也放在里面啦，回复rabbit获取）

（微信公众号）分享最新的Net和Core相关技术以及实战技巧，更重要的是分享Net项目，不容错过的还有书籍，手写笔记等等。

参考

1.安装RabbitMQ无法访问(http://localhost:15672)_解决方案
2.C#调用RabbitMQ实现消息队列
3.在C#中使用消息队列RabbitMQ
4.rabbitmq 安装过程中遇到的 rabbitmq-plugins不是内部命令或外部命令
5.win10 安装RabbitMQ 报错无法将“rabbitmq-plugins”项识别为 cmdlet、函数、脚本文件或可运行程序的名称

内容总结

以上是互联网集市为您收集整理的C# 使用RabbitMQ的完整图解全部内容，希望文章能够帮你解决C# 使用RabbitMQ的完整图解所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---