C#调用RabbitMQ实现消息队列

时间  2019-11-06
标签 c# 调用 rabbitmq 实现 消息 队列 栏目 C# 繁體版
原文   原文链接

前言html

我在刚接触使用中间件的时候，发现，中间件的使用并非最难的，反而是中间件的下载，安装，配置才是最难的。git

因此，这篇文章咱们从头开始学习RabbitMq，真正的从头开始。github

关于消息队列设计模式

其实消息队列没有那么神秘，咱们这样想一下，用户访问网站，最终是要将数据以HTTP的协议的方式，经过网络传输到主机的某个端口上的。浏览器

那么，接收数据的方式是什么呢？天然是端口监听啦。服务器

那消息队列是什么就很好解释了？网络

它就是端口监听，接到数据后，将数据排列起来。架构

那这件事，咱们不用中间件能作吗？框架

固然能作啦，写个TCP/UDP/Socket的软件就能够作啦。socket

举个简单的例子，以下图：

既然本身能够作消息队列，那为何要用RabbitMQ?

由于，RabbitMQ成熟的开源中间件，可靠性有保证，bug少，性能也很是好。

而C#代码默认是使用托管内存的，因此，想写出媲美RabbitMQ性能的消息队列，就必须离开咱们经常使用的托管内存，使用非托管内存，但这个代价就太大了；并且最终可否达到RabbitMQ的性能水平仍是个未知数。

还有就是RabbitMQ除了基础的消息队列管理，还有不少很强大的额外功能，而本身开发消息队列，很难如此尽善尽美。

----------------------------------------------------------------------------------------------------

咱们还会发现，在消息队列里有不少概念，什么消息总线啊，什么工做队列啊等等。

要怎么理解这些概念呢？

很简单，不要去理解。这些概念实际上是人家代码架构的模式，不要去理解他们，【记】就完了，人家的中间件就是按照这个模式工做的。

好比，我写了一个接收消息的总控制器，而后我为他命名为总线，那这个控制器就是总线，没有理由，这就是定义。

准备工做

首先，咱们访问官网【https://www.rabbitmq.com/】，点击Get Started。

而后，网站会自动跳转到当前首页Get Started的锚点位置，以下图：

Get Started锚点：

而后咱们点击DownLoad+Installation，进入到下载界面。

在下载页面中，咱们找到安装指南，而后在点击官网推荐的Windows系统的安装包，以下图：

如今，咱们进入了Windows安装指南界面了。

首先，咱们看一下预览信息，以下图：

在预览里，咱们得知，安装RabbitMQ有两种方法，一种是使用Chocolatey安装，一种是使用官方安装包安装。

Chocolatey是什么呢?随手百度一下，原来他是一个软件包管理工具，也就是说，Chocolatey是相似于Nuget的一种工具。

因为Chocolatey的使用，我不是很熟悉，因此，这里选择使用官方安装包安装。

点击【Using the official installer】，咱们进入了【Using the official installer】对应的锚点，以下图。

 

在【Using the official installer】段落里找到有推荐标志的安装包，而后下载。 

下载完成后，咱们能够获得这样一个安装包，以下图：

除了下载安装包，咱们还会发现，在【Using the official installer】段落里，有提醒咱们，RabbitMQ是有依赖的，依赖一个Erlang语言的框架（相似于C#语言的NetFramework）。

咱们能够发现，在依赖的段落里，官网很是坑的给出了三个连接网址，以下：

supported version of Erlang：https://www.rabbitmq.com/which-erlang.html

Windows installer：https://www.erlang.org/downloads

Erlang Solutions：https://www.erlang-solutions.com/resources/download.html

由于，咱们是没法经过文字描述来判断，哪个是真的依赖框架的下载地址，因此只好每一个都点击进去看看。。。

打开网址后发现，在后两个网址中均可以找到框架下载地址，但第二个地址明显更友好一点，因此咱们在第二个网址内下载Erlang的框架。

 下载完成获得以下图文件：

 PS：这里下载的是OTP的22.1的版本，个人理解是Erlang等于C#语言，而OTP等于NetFramework。

安装Erlang\OTP

首先，咱们运行otp_win64_22.1.exe，安装依赖框架Erlang\OTP。

安装完成后，设置环境变量以下：

而后运行CMD，输入erl，测试安装是否成功，以下图：

安装成功。

安装rabbitmq-server

安装完依赖后，咱们接着安装rabbitmq-server-3.8.0.exe。

【rabbitmq-server-3.8.0.exe】？从这个文件名上，咱们发现了一个问题，那就是，咱们即将安装的RabbitMQ，是一个服务端啊。

什么？服务端？难道还有客户端？？？

其实这也很好理解，想一下最开始我举的那个例子，消息队列是须要一个监听端口的服务端的，而后客户端向这个服务端发送请求。

这样是否是就很好的理解RabbitMQ了呢：）

----------------------------------------------------------------------------------------------------

安装完RabbitMQ服务端后，咱们仍是启动CMD，用命令行来查看下安装状态。

首先输入下面的命令，将路径定位到RabbitMQ的路径下：

【CD /D C:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.0\sbin】

而后输入rabbitmqctl status查看状态。

启动管理工具的命令行：rabbitmq-plugins enable rabbitmq_management。

启动成功后，在浏览器输入地址http://127.0.0.1:15672/，进入管理页面，帐户密码都是guest。

RabbitMQ还有不少经常使用命令，你们能够自行百度。

----------------------------------------------------------------------------------------------------

到此，RabbitMQ服务端的环境配置好了，正常状况，这些配置应该在服务器进行，但我为了测试方便，就把服务端也安装在本机了，所以我下面调用RabbitMQ时，链接的主机IP都是localhost。

RabbitMQ应用

首先建立两个控制台应用程序，KibaRabbitMQSend和KibaRabbitMQReceived。

而后引入RabbitMQ的开源类库。

在C#里使用RabbitMQ开源类库很是简单，能够去官网下载一个.NET版本的RabbitMQ客户端类库，也能够直接在Nuget上搜索RabbitMQ，而后安装，以下图：

KibaRabbitMQSend

安装完RabbitMQ开源类库后，咱们编写代码，实现向RabbitMQ服务器发送消息，代码以下：

static void Main(string[] args)
{
    var factory = new ConnectionFactory();
    factory.HostName = "localhost";//主机名，Rabbit会拿这个IP生成一个endpoint，这个很熟悉吧，就是socket绑定的那个终结点。
    factory.UserName = "guest";//默认用户名,用户能够在服务端自定义建立，有相关命令行
    factory.Password = "guest";//默认密码

    using (var connection = factory.CreateConnection())//链接服务器，即正在建立终结点。
    {
        //建立一个通道，这个就是Rabbit本身定义的规则了，若是本身写消息队列，这个就能够开脑洞设计了
        //这里Rabbit的玩法就是一个通道channel下包含多个队列Queue
        using (var channel = connection.CreateModel())
        { 
             channel.QueueDeclare("kibaQueue", false, false, false, null);//建立一个名称为kibaqueue的消息队列
             var properties = channel.CreateBasicProperties();
             properties.DeliveryMode = 1;
             string message = "I am Kiba518"; //传递的消息内容 
             channel.BasicPublish("", "kibaQueue", properties, Encoding.UTF8.GetBytes(message)); //生产消息
             Console.WriteLine($"Send:{message}"); 
        }
    }
}

运行代码。

而后咱们使用命令行rabbitmqctl list_queues，去RabbitMQ的服务器查看当前消息队列，以下图：

能够看到，咱们的消息已经发送成功了。

KibaRabbitMQReceived

如今咱们编写接收消息代码，以下：

static void Main(string[] args)
{
    var factory = new ConnectionFactory();
    factory.HostName = "localhost";
    factory.UserName = "guest";
    factory.Password = "guest";

    using (var connection = factory.CreateConnection())
    {
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare("kibaQueue", false, false, false, null);

            /* 这里定义了一个消费者，用于消费服务器接受的消息
             * C#开发须要注意下这里，在一些非面向对象和面向对象比较差的语言中，是很是重视这种设计模式的。
             * 好比RabbitMQ使用了生产者与消费者模式，而后不少相关的使用文章都在拿这个生产者和消费者来表述。
             * 可是，在C#里，生产者与消费者对咱们而言，根本算不上一种设计模式，他就是一种最基础的代码编写规则。
             * 因此，你们不要复杂的名词吓到，其实，并没那么复杂。
             * 这里，其实就是定义一个EventingBasicConsumer类型的对象，而后该对象有个Received事件，
             * 该事件会在服务接收到数据时触发。
             */
            var consumer = new EventingBasicConsumer(channel);//消费者 
            channel.BasicConsume("kibaQueue", true, consumer);//消费消息 
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body); 
            }; 
        }
    }
}

运行代码。

而后咱们使用命令行rabbitmqctl list_queues，去RabbitMQ的服务器查看当前消息队列，以下图：

能够看到，消息已经被使用了。

----------------------------------------------------------------------------------------------------

如今咱们在发送代码出作一个for循环，看看消息接收速度是什么样的，代码以下，for循环了100次，每次间隔3秒。

for (int i = 0; i < 100; i++)
{
    channel.QueueDeclare("kibaQueue", false, false, false, null);//建立一个名称为kibaQueue的消息队列
    var properties = channel.CreateBasicProperties();
    properties.DeliveryMode = 1;
    string message = "I am Kiba518"; //传递的消息内容 
    channel.BasicPublish("", "kibaQueue", properties, Encoding.UTF8.GetBytes(message)); //生产消息
    Console.WriteLine($"Send:{message}");
    Thread.Sleep(3000);
}

效果图以下：

能够看到，发送消息和接收消息，几乎是同步的，效果很是理想。

服务器端应用

在上文，咱们的RabbitMQ服务是安装在个人本机上的；如今咱们把服务移植到服务器上，而后再来测试一下。

在服务器端安装RabbitMQ和在本机安装的步骤是同样的，可是安装完成后，咱们须要设置下防火墙的入站规则和出站规则，将5672的UDP端口开放一下。

为何要开放端口是5672？由于RabbitMQ的默认的消息接收和发送端口就是5672，咱们可使用断点查看一下。

如上图，能够看到，在咱们没有设置端口的时候，Endpoint的端口的默认值是5672。

配置完端口后，咱们修改代码中的HostName为咱们的服务器地址，以下。

factory.HostName = "1.1.1.1";

从新运行代码，会发如今运行到factory.CreateConnection()的时候，系统提示一个异常【RabbitMQ.Client.Exceptions.BrokerUnreachableException:“None of the specified endpoints were reachable”】，以下图：

这是由于咱们使用的帐号是guest，guest帐号默认是不支持远程链接的。

解决办法很简单，新建一个帐户便可。

建立用户

在服务器端打开浏览器，输入http://127.0.0.1:15672/，进入管理页面。

点击菜单栏的Admin选项，进入用户管理界面建立用户kiba，密码123456，以下图：

建立完用户后，获得以下界面。

如上图所示，刚刚建立的用户尚未任何访问权限。

如今咱们点击用户名，进入权限管理页面设置权限。

如上图所示，页面默认为咱们设置了一个可读，可写，可管理配置的权限；因此，咱们只要点击Set premission就能够了。

设置完权限，咱们回到用户管理页面。 

如上图所示，权限设置成功。

如今咱们回到代码，修改用户名密码以下。

factory.HostName = "1.1.1.1";
factory.UserName = "kiba";
factory.Password = "123456";

运行代码，再也不抛异常，接受发送消息正常。

----------------------------------------------------------------------------------------------------

 设置用户权限也能够经过命令的方式设置，以下：

 rabbitmqctl set_permissions -p "/" kiba "." "." ".*"

----------------------------------------------------------------------------------------------------

到此C#调用RabbitMQ实现消息队列就讲完了。

代码已经传到Github上了，欢迎你们下载。

Github地址：https://github.com/kiba518/KibaRabbitMQ

----------------------------------------------------------------------------------------------------

注：此文章为原创，任何形式的转载都请联系做者得到受权并注明出处！
若您以为这篇文章还不错，请点击下方的【推荐】，很是感谢！
本文已独家受权给脚本之家（ID:jb51net）公众号发布

http://www.javashuo.com/article/p-yiyczbzz-bc.html

 

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程