C#调用RabbitMQ实现消息队列

广州黑 發表於 2019-10-23 15:52:00

<div id="cnblogs_post_body" class="blogpost-body ">
<p style="width: 100%; background: rgba(65, 105, 225, 1); color: rgba(255, 255, 255, 1); height: 50px; font-size: 30px; line-height: 50px"><strong>前言</strong></p>
<p>我在刚接触使用中间件的时候，发现，中间件的使用并不是最难的，反而是中间件的下载，安装，配置才是最难的。</p>
<p>所以，这篇文章我们从头开始学习RabbitMq，真正的从头开始。</p>
<p style="width: 100%; background: rgba(65, 105, 225, 1); color: rgba(255, 255, 255, 1); height: 50px; font-size: 30px; line-height: 50px"><strong>关于消息队列</strong></p>
<p>其实消息队列没有那么神秘，我们这样想一下，用户访问网站，最终是要将数据以HTTP的协议的方式，通过网络传输到主机的某个端口上的。</p>
<p>那么，接收数据的方式是什么呢？自然是端口监听啦。</p>
<p>那消息队列是什么就很好解释了？</p>
<p>它就是端口监听，接到数据后，将数据排列起来。</p>
<p>那这件事，我们不用中间件能做吗？</p>
<p>当然能做啦，写个TCP/UDP/Socket的软件就可以做啦。</p>
<p>举个简单的例子，如下图：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019134255706-1956606734.png" alt=""></p>
<p>既然自己可以做消息队列，那为什么要用RabbitMQ?</p>
<p>因为，RabbitMQ成熟的开源中间件，可靠性有保证，bug少，性能也非常好。</p>
<p>而C#代码默认是使用托管内存的，所以，想写出媲美RabbitMQ性能的消息队列，就必须离开我们常用的托管内存，使用非托管内存，但这个代价就太大了；而且最终能否达到RabbitMQ的性能水平还是个未知数。</p>
<p>还有就是RabbitMQ除了基础的消息队列管理，还有很多很强大的额外功能，而自己开发消息队列，很难如此尽善尽美。</p>
<p>----------------------------------------------------------------------------------------------------</p>
<p>我们还会发现，在消息队列里有很多概念，什么消息总线啊，什么工作队列啊等等。</p>
<p>要怎么理解这些概念呢？</p>
<p>很简单，不要去理解。这些概念其实是人家代码架构的模式，不要去理解他们，【记】就完了，人家的中间件就是按照这个模式工作的。</p>
<p>比如，我写了一个接收消息的总控制器，然后我为他命名为总线，那这个控制器就是总线，没有理由，这就是定义。</p>
<p style="width: 100%; background: rgba(65, 105, 225, 1); color: rgba(255, 255, 255, 1); height: 50px; font-size: 30px; line-height: 50px"><strong>准备工作</strong></p>
<p>首先，我们访问官网【https://www.rabbitmq.com/】，点击Get Started。</p>
<p>然后，网站会自动跳转到当前首页Get Started的锚点位置，如下图：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019095811948-1850194752.png" alt=""></p>
<p>Get Started锚点：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019100243943-1755992533.png" alt=""></p>
<p>然后我们点击DownLoad+Installation，进入到下载界面。</p>
<p>在下载页面中，我们找到安装指南，然后在点击官网推荐的Windows系统的安装包，如下图：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019101003641-59431700.png" alt=""></p>
<p>现在，我们进入了Windows安装指南界面了。</p>
<p>首先，我们看一下预览信息，如下图：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019101533840-1798740751.png" alt=""></p>
<p>在预览里，我们得知，安装RabbitMQ有两种方法，一种是使用Chocolatey安装，一种是使用官方安装包安装。</p>
<p>Chocolatey是什么呢?随手百度一下，原来他是一个软件包管理工具，也就是说，Chocolatey是类似于Nuget的一种工具。</p>
<p>由于Chocolatey的使用，我不是很熟悉，所以，这里选择使用官方安装包安装。</p>
<p>点击【Using the official installer】，我们进入了【Using the official installer】对应的锚点，如下图。</p>
<p> <img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019102916450-754895055.png" alt=""></p>
<p>在【Using the official installer】段落里找到有推荐标志的安装包，然后下载。 </p>
<p>下载完成后，我们可以得到这样一个安装包，如下图：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019102604757-1807831000.png" alt=""></p>
<p>除了下载安装包，我们还会发现，在【Using the official installer】段落里，有提醒我们，RabbitMQ是有依赖的，依赖一个Erlang语言的框架（类似于C#语言的NetFramework）。</p>
<p>我们可以发现，在依赖的段落里，官网非常坑的给出了三个链接网址，如下：</p>
<p><span style="color: rgba(255, 102, 0, 1)">supported version of Erlang</span>：https://www.rabbitmq.com/which-erlang.html</p>
<p><span style="color: rgba(255, 102, 0, 1)">Windows installer</span>：https://www.erlang.org/downloads</p>
<p><span style="color: rgba(255, 102, 0, 1)">Erlang Solutions</span>：https://www.erlang-solutions.com/resources/download.html</p>
<p>因为，我们是无法通过文字描述来判断，哪一个是真的依赖框架的下载地址，所以只好每个都点击进去看看。。。</p>
<p>打开网址后发现，在后两个网址中都可以找到框架下载地址，但第二个地址明显更友好一点，所以我们在第二个网址内下载Erlang的框架。</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019105433878-68402157.png" alt=""></p>
<p> 下载完成得到如下图文件：</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019132511046-46840190.png" alt=""></p>
<p> PS：这里下载的是OTP的22.1的版本，我的理解是Erlang等于C#语言，而OTP等于NetFramework。</p>
<p><strong>安装</strong><strong>Erlang\OTP</strong></p>
<p>首先，我们运行otp_win64_22.1.exe，安装依赖框架Erlang\OTP。</p>
<p>安装完成后，设置环境变量如下：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019133251201-1818732706.png" alt=""></p>
<p>然后运行CMD，输入erl，测试安装是否成功，如下图：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019133441475-1550410939.png" alt=""></p>
<p>安装成功。</p>
<p><strong>安装rabbitmq-server</strong></p>
<p>安装完依赖后，我们接着安装rabbitmq-server-3.8.0.exe。</p>
<p>【rabbitmq-server-3.8.0.exe】？从这个文件名上，我们发现了一个问题，那就是，我们即将安装的RabbitMQ，是一个服务端啊。</p>
<p>什么？服务端？难道还有客户端？？？</p>
<p>其实这也很好理解，想一下最开始我举的那个例子，消息队列是需要一个监听端口的服务端的，然后客户端向这个服务端发送请求。</p>
<p>这样是不是就很好的理解RabbitMQ了呢：）</p>
<p>----------------------------------------------------------------------------------------------------</p>
<p>安装完RabbitMQ服务端后，我们还是启动CMD，用命令行来查看下安装状态。</p>
<p>首先输入下面的命令，将路径定位到RabbitMQ的路径下：</p>
<p>【CD /D C:\Program Files\RabbitMQ Server\rabbitmq_server-3.8.0\sbin】</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019140833671-1084989412.png" alt=""></p>
<p>然后输入rabbitmqctl status查看状态。</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019141814181-1936055736.png" alt=""></p>
<p>启动管理工具的命令行：rabbitmq-plugins enable rabbitmq_management。</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019141748794-2123419412.png" alt=""></p>
<p>启动成功后，在浏览器输入地址http://127.0.0.1:15672/，进入管理页面，账户密码都是guest。</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019142617261-493733273.png" alt=""></p>
<p>RabbitMQ还有很多常用命令，大家可以自行百度。</p>
<p>----------------------------------------------------------------------------------------------------</p>
<p>到此，RabbitMQ服务端的环境配置好了，正常情况，这些配置应该在服务器进行，但我为了测试方便，就把服务端也安装在本机了，因此我下面调用RabbitMQ时，连接的主机IP都是localhost。</p>
<p style="width: 100%; background: rgba(65, 105, 225, 1); color: rgba(255, 255, 255, 1); height: 50px; font-size: 30px; line-height: 50px"><strong>RabbitMQ应用</strong></p>
<p>首先创建两个控制台应用程序，KibaRabbitMQSend和KibaRabbitMQReceived。</p>
<p>然后引入RabbitMQ的开源类库。</p>
<p>在C#里使用RabbitMQ开源类库非常简单，可以去官网下载一个.NET版本的RabbitMQ客户端类库，也可以直接在Nuget上搜索RabbitMQ，然后安装，如下图：</p>
<p><img style="border: 1px solid rgba(0, 0, 0, 1)" src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019144618887-1051124440.png" alt=""></p>
<p><strong>KibaRabbitMQSend</strong></p>
<p>安装完RabbitMQ开源类库后，我们编写代码，实现向RabbitMQ服务器发送消息，代码如下：</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_74088" class="syntaxhighlightercsharp">
<div class="toolbar"><span>?</span></div>
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
<div class="line number8 index7 alt1">8</div>
<div class="line number9 index8 alt2">9</div>
<div class="line number10 index9 alt1">10</div>
<div class="line number11 index10 alt2">11</div>
<div class="line number12 index11 alt1">12</div>
<div class="line number13 index12 alt2">13</div>
<div class="line number14 index13 alt1">14</div>
<div class="line number15 index14 alt2">15</div>
<div class="line number16 index15 alt1">16</div>
<div class="line number17 index16 alt2">17</div>
<div class="line number18 index17 alt1">18</div>
<div class="line number19 index18 alt2">19</div>
<div class="line number20 index19 alt1">20</div>
<div class="line number21 index20 alt2">21</div>
<div class="line number22 index21 alt1">22</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="csharp keyword">static</code> <code class="csharp keyword">void</code> <code class="csharp plain">Main(</code><code class="csharp keyword">string</code><code class="csharp plain">[] args)</code></div>
<div class="line number2 index1 alt1"><code class="csharp plain">{</code></div>
<div class="line number3 index2 alt2"><code class="csharp spaces">    </code><code class="csharp keyword">var</code> <code class="csharp plain">factory = </code><code class="csharp keyword">new</code> <code class="csharp plain">ConnectionFactory();</code></div>
<div class="line number4 index3 alt1"><code class="csharp spaces">    </code><code class="csharp plain">factory.HostName = </code><code class="csharp string">"localhost"</code><code class="csharp plain">;</code><code class="csharp comments">//主机名，Rabbit会拿这个IP生成一个endpoint，这个很熟悉吧，就是socket绑定的那个终结点。</code></div>
<div class="line number5 index4 alt2"><code class="csharp spaces">    </code><code class="csharp plain">factory.UserName = </code><code class="csharp string">"guest"</code><code class="csharp plain">;</code><code class="csharp comments">//默认用户名,用户可以在服务端自定义创建，有相关命令行</code></div>
<div class="line number6 index5 alt1"><code class="csharp spaces">    </code><code class="csharp plain">factory.Password = </code><code class="csharp string">"guest"</code><code class="csharp plain">;</code><code class="csharp comments">//默认密码</code></div>
<div class="line number7 index6 alt2"> </div>
<div class="line number8 index7 alt1"><code class="csharp spaces">    </code><code class="csharp keyword">using</code> <code class="csharp plain">(</code><code class="csharp keyword">var</code> <code class="csharp plain">connection = factory.CreateConnection())</code><code class="csharp comments">//连接服务器，即正在创建终结点。</code></div>
<div class="line number9 index8 alt2"><code class="csharp spaces">    </code><code class="csharp plain">{</code></div>
<div class="line number10 index9 alt1"><code class="csharp spaces">        </code><code class="csharp comments">//创建一个通道，这个就是Rabbit自己定义的规则了，如果自己写消息队列，这个就可以开脑洞设计了</code></div>
<div class="line number11 index10 alt2"><code class="csharp spaces">        </code><code class="csharp comments">//这里Rabbit的玩法就是一个通道channel下包含多个队列Queue</code></div>
<div class="line number12 index11 alt1"><code class="csharp spaces">        </code><code class="csharp keyword">using</code> <code class="csharp plain">(</code><code class="csharp keyword">var</code> <code class="csharp plain">channel = connection.CreateModel())</code></div>
<div class="line number13 index12 alt2"><code class="csharp spaces">        </code><code class="csharp plain">{ </code></div>
<div class="line number14 index13 alt1"><code class="csharp spaces">             </code><code class="csharp plain">channel.QueueDeclare(</code><code class="csharp string">"kibaQueue"</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">null</code><code class="csharp plain">);</code><code class="csharp comments">//创建一个名称为kibaqueue的消息队列</code></div>
<div class="line number15 index14 alt2"><code class="csharp spaces">             </code><code class="csharp keyword">var</code> <code class="csharp plain">properties = channel.CreateBasicProperties();</code></div>
<div class="line number16 index15 alt1"><code class="csharp spaces">             </code><code class="csharp plain">properties.DeliveryMode = 1;</code></div>
<div class="line number17 index16 alt2"><code class="csharp spaces">             </code><code class="csharp keyword">string</code> <code class="csharp plain">message = </code><code class="csharp string">"I am Kiba518"</code><code class="csharp plain">; </code><code class="csharp comments">//传递的消息内容 </code></div>
<div class="line number18 index17 alt1"><code class="csharp spaces">             </code><code class="csharp plain">channel.BasicPublish(</code><code class="csharp string">""</code><code class="csharp plain">, </code><code class="csharp string">"kibaQueue"</code><code class="csharp plain">, properties, Encoding.UTF8.GetBytes(message)); </code><code class="csharp comments">//生产消息</code></div>
<div class="line number19 index18 alt2"><code class="csharp spaces">             </code><code class="csharp plain">Console.WriteLine($</code><code class="csharp string">"Send:{message}"</code><code class="csharp plain">); </code></div>
<div class="line number20 index19 alt1"><code class="csharp spaces">        </code><code class="csharp plain">}</code></div>
<div class="line number21 index20 alt2"><code class="csharp spaces">    </code><code class="csharp plain">}</code></div>
<div class="line number22 index21 alt1"><code class="csharp plain">}</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p>运行代码。</p>
<p>然后我们使用命令行rabbitmqctl list_queues，去RabbitMQ的服务器查看当前消息队列，如下图：</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019160450567-373476736.png" alt=""></p>
<p>可以看到，我们的消息已经发送成功了。</p>
<p><strong>KibaRabbitMQReceived</strong></p>
<p>现在我们编写接收消息代码，如下：</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_549479" class="syntaxhighlightercsharp">
<div class="toolbar"><span>?</span></div>
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
<div class="line number8 index7 alt1">8</div>
<div class="line number9 index8 alt2">9</div>
<div class="line number10 index9 alt1">10</div>
<div class="line number11 index10 alt2">11</div>
<div class="line number12 index11 alt1">12</div>
<div class="line number13 index12 alt2">13</div>
<div class="line number14 index13 alt1">14</div>
<div class="line number15 index14 alt2">15</div>
<div class="line number16 index15 alt1">16</div>
<div class="line number17 index16 alt2">17</div>
<div class="line number18 index17 alt1">18</div>
<div class="line number19 index18 alt2">19</div>
<div class="line number20 index19 alt1">20</div>
<div class="line number21 index20 alt2">21</div>
<div class="line number22 index21 alt1">22</div>
<div class="line number23 index22 alt2">23</div>
<div class="line number24 index23 alt1">24</div>
<div class="line number25 index24 alt2">25</div>
<div class="line number26 index25 alt1">26</div>
<div class="line number27 index26 alt2">27</div>
<div class="line number28 index27 alt1">28</div>
<div class="line number29 index28 alt2">29</div>
<div class="line number30 index29 alt1">30</div>
<div class="line number31 index30 alt2">31</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="csharp keyword">static</code> <code class="csharp keyword">void</code> <code class="csharp plain">Main(</code><code class="csharp keyword">string</code><code class="csharp plain">[] args)</code></div>
<div class="line number2 index1 alt1"><code class="csharp plain">{</code></div>
<div class="line number3 index2 alt2"><code class="csharp spaces">    </code><code class="csharp keyword">var</code> <code class="csharp plain">factory = </code><code class="csharp keyword">new</code> <code class="csharp plain">ConnectionFactory();</code></div>
<div class="line number4 index3 alt1"><code class="csharp spaces">    </code><code class="csharp plain">factory.HostName = </code><code class="csharp string">"localhost"</code><code class="csharp plain">;</code></div>
<div class="line number5 index4 alt2"><code class="csharp spaces">    </code><code class="csharp plain">factory.UserName = </code><code class="csharp string">"guest"</code><code class="csharp plain">;</code></div>
<div class="line number6 index5 alt1"><code class="csharp spaces">    </code><code class="csharp plain">factory.Password = </code><code class="csharp string">"guest"</code><code class="csharp plain">;</code></div>
<div class="line number7 index6 alt2"> </div>
<div class="line number8 index7 alt1"><code class="csharp spaces">    </code><code class="csharp keyword">using</code> <code class="csharp plain">(</code><code class="csharp keyword">var</code> <code class="csharp plain">connection = factory.CreateConnection())</code></div>
<div class="line number9 index8 alt2"><code class="csharp spaces">    </code><code class="csharp plain">{</code></div>
<div class="line number10 index9 alt1"><code class="csharp spaces">        </code><code class="csharp keyword">using</code> <code class="csharp plain">(</code><code class="csharp keyword">var</code> <code class="csharp plain">channel = connection.CreateModel())</code></div>
<div class="line number11 index10 alt2"><code class="csharp spaces">        </code><code class="csharp plain">{</code></div>
<div class="line number12 index11 alt1"><code class="csharp spaces">            </code><code class="csharp plain">channel.QueueDeclare(</code><code class="csharp string">"kibaQueue"</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">null</code><code class="csharp plain">);</code></div>
<div class="line number13 index12 alt2"> </div>
<div class="line number14 index13 alt1"><code class="csharp spaces">            </code><code class="csharp comments">/* 这里定义了一个消费者，用于消费服务器接受的消息</code></div>
<div class="line number15 index14 alt2"><code class="csharp spaces">             </code><code class="csharp comments">* C#开发需要注意下这里，在一些非面向对象和面向对象比较差的语言中，是非常重视这种设计模式的。</code></div>
<div class="line number16 index15 alt1"><code class="csharp spaces">             </code><code class="csharp comments">* 比如RabbitMQ使用了生产者与消费者模式，然后很多相关的使用文章都在拿这个生产者和消费者来表述。</code></div>
<div class="line number17 index16 alt2"><code class="csharp spaces">             </code><code class="csharp comments">* 但是，在C#里，生产者与消费者对我们而言，根本算不上一种设计模式，他就是一种最基础的代码编写规则。</code></div>
<div class="line number18 index17 alt1"><code class="csharp spaces">             </code><code class="csharp comments">* 所以，大家不要复杂的名词吓到，其实，并没那么复杂。</code></div>
<div class="line number19 index18 alt2"><code class="csharp spaces">             </code><code class="csharp comments">* 这里，其实就是定义一个EventingBasicConsumer类型的对象，然后该对象有个Received事件，</code></div>
<div class="line number20 index19 alt1"><code class="csharp spaces">             </code><code class="csharp comments">* 该事件会在服务接收到数据时触发。</code></div>
<div class="line number21 index20 alt2"><code class="csharp spaces">             </code><code class="csharp comments">*/</code></div>
<div class="line number22 index21 alt1"><code class="csharp spaces">            </code><code class="csharp keyword">var</code> <code class="csharp plain">consumer = </code><code class="csharp keyword">new</code> <code class="csharp plain">EventingBasicConsumer(channel);</code><code class="csharp comments">//消费者 </code></div>
<div class="line number23 index22 alt2"><code class="csharp spaces">            </code><code class="csharp plain">channel.BasicConsume(</code><code class="csharp string">"kibaQueue"</code><code class="csharp plain">, </code><code class="csharp keyword">true</code><code class="csharp plain">, consumer);</code><code class="csharp comments">//消费消息 </code></div>
<div class="line number24 index23 alt1"><code class="csharp spaces">            </code><code class="csharp plain">consumer.Received += (model, ea) =></code></div>
<div class="line number25 index24 alt2"><code class="csharp spaces">            </code><code class="csharp plain">{</code></div>
<div class="line number26 index25 alt1"><code class="csharp spaces">                </code><code class="csharp keyword">var</code> <code class="csharp plain">body = ea.Body;</code></div>
<div class="line number27 index26 alt2"><code class="csharp spaces">                </code><code class="csharp keyword">var</code> <code class="csharp plain">message = Encoding.UTF8.GetString(body); </code></div>
<div class="line number28 index27 alt1"><code class="csharp spaces">            </code><code class="csharp plain">}; </code></div>
<div class="line number29 index28 alt2"><code class="csharp spaces">        </code><code class="csharp plain">}</code></div>
<div class="line number30 index29 alt1"><code class="csharp spaces">    </code><code class="csharp plain">}</code></div>
<div class="line number31 index30 alt2"><code class="csharp plain">}</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p>运行代码。</p>
<p>然后我们使用命令行rabbitmqctl list_queues，去RabbitMQ的服务器查看当前消息队列，如下图：</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019164650500-222789453.png" alt=""></p>
<p>可以看到，消息已经被使用了。</p>
<p>----------------------------------------------------------------------------------------------------</p>
<p>现在我们在发送代码出做一个for循环，看看消息接收速度是什么样的，代码如下，for循环了100次，每次间隔3秒。</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_86756" class="syntaxhighlightercsharp">
<div class="toolbar"><span>?</span></div>
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
<div class="line number8 index7 alt1">8</div>
<div class="line number9 index8 alt2">9</div>
<div class="line number10 index9 alt1">10</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="csharp keyword">for</code> <code class="csharp plain">(</code><code class="csharp keyword">int</code> <code class="csharp plain">i = 0; i < 100; i++)</code></div>
<div class="line number2 index1 alt1"><code class="csharp plain">{</code></div>
<div class="line number3 index2 alt2"><code class="csharp spaces">    </code><code class="csharp plain">channel.QueueDeclare(</code><code class="csharp string">"kibaQueue"</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">false</code><code class="csharp plain">, </code><code class="csharp keyword">null</code><code class="csharp plain">);</code><code class="csharp comments">//创建一个名称为kibaQueue的消息队列</code></div>
<div class="line number4 index3 alt1"><code class="csharp spaces">    </code><code class="csharp keyword">var</code> <code class="csharp plain">properties = channel.CreateBasicProperties();</code></div>
<div class="line number5 index4 alt2"><code class="csharp spaces">    </code><code class="csharp plain">properties.DeliveryMode = 1;</code></div>
<div class="line number6 index5 alt1"><code class="csharp spaces">    </code><code class="csharp keyword">string</code> <code class="csharp plain">message = </code><code class="csharp string">"I am Kiba518"</code><code class="csharp plain">; </code><code class="csharp comments">//传递的消息内容 </code></div>
<div class="line number7 index6 alt2"><code class="csharp spaces">    </code><code class="csharp plain">channel.BasicPublish(</code><code class="csharp string">""</code><code class="csharp plain">, </code><code class="csharp string">"kibaQueue"</code><code class="csharp plain">, properties, Encoding.UTF8.GetBytes(message)); </code><code class="csharp comments">//生产消息</code></div>
<div class="line number8 index7 alt1"><code class="csharp spaces">    </code><code class="csharp plain">Console.WriteLine($</code><code class="csharp string">"Send:{message}"</code><code class="csharp plain">);</code></div>
<div class="line number9 index8 alt2"><code class="csharp spaces">    </code><code class="csharp plain">Thread.Sleep(3000);</code></div>
<div class="line number10 index9 alt1"><code class="csharp plain">}</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p>效果图如下：</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191019165141088-729303292.gif" alt=""></p>
<p>可以看到，发送消息和接收消息，几乎是同步的，效果非常理想。</p>
<p style="width: 100%; background: rgba(65, 105, 225, 1); color: rgba(255, 255, 255, 1); height: 50px; font-size: 30px; line-height: 50px"><strong>服务器端应用</strong></p>
<p>在上文，我们的RabbitMQ服务是安装在我的本机上的；现在我们把服务移植到服务器上，然后再来测试一下。</p>
<p>在服务器端安装RabbitMQ和在本机安装的步骤是一样的，但是安装完成后，我们需要设置下防火墙的入站规则和出站规则，将5672的UDP端口开放一下。</p>
<p>为什么要开放端口是5672？因为RabbitMQ的默认的消息接收和发送端口就是5672，我们可以使用断点查看一下。</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191021155427009-1905416441.png" alt=""></p>
<p>如上图，可以看到，在我们没有设置端口的时候，Endpoint的端口的默认值是5672。</p>
<p>配置完端口后，我们修改代码中的HostName为我们的服务器地址，如下。</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_367162" class="syntaxhighlightercsharp">
<div class="toolbar"><span>?</span></div>
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="csharp plain">factory.HostName = </code><code class="csharp string">"1.1.1.1"</code><code class="csharp plain">;</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p>重新运行代码，会发现在运行到factory.CreateConnection()的时候，系统提示一个异常【RabbitMQ.Client.Exceptions.BrokerUnreachableException:“None of the specified endpoints were reachable”】，如下图：</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191021162714074-302171709.png" alt=""></p>
<p>这是因为我们使用的账号是guest，guest账号默认是不支持远程连接的。</p>
<p>解决办法很简单，新建一个账户即可。</p>
<p><strong>创建用户</strong></p>
<p>在服务器端打开浏览器，输入http://127.0.0.1:15672/，进入管理页面。</p>
<p>点击菜单栏的Admin选项，进入用户管理界面创建用户kiba，密码123456，如下图：</p>
<p><strong><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191021164016958-672764107.png" alt=""></strong></p>
<p>创建完用户后，得到如下界面。</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191021165201246-1743565134.png" alt=""></p>
<p>如上图所示，刚刚创建的用户还没有任何访问权限。</p>
<p>现在我们点击用户名，进入权限管理页面设置权限。</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191021165433285-1748886781.png" alt=""></p>
<p>如上图所示，页面默认为我们设置了一个可读，可写，可管理配置的权限；所以，我们只要点击Set premission就可以了。</p>
<p>设置完权限，我们回到用户管理页面。 </p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191021165716528-545307299.png" alt=""></p>
<p>如上图所示，权限设置成功。</p>
<p>现在我们回到代码，修改用户名密码如下。</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_95188" class="syntaxhighlightercsharp">
<div class="toolbar"><span>?</span></div>
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="csharp plain">factory.HostName = </code><code class="csharp string">"1.1.1.1"</code><code class="csharp plain">;</code></div>
<div class="line number2 index1 alt1"><code class="csharp plain">factory.UserName = </code><code class="csharp string">"kiba"</code><code class="csharp plain">;</code></div>
<div class="line number3 index2 alt2"><code class="csharp plain">factory.Password = </code><code class="csharp string">"123456"</code><code class="csharp plain">;</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p>运行代码，不再抛异常，接受发送消息正常。</p>
<p>----------------------------------------------------------------------------------------------------</p>
<p> 设置用户权限也可以通过命令的方式设置，如下：</p>
<p> rabbitmqctl set_permissions -p "/" kiba "." "." ".*"</p>
<p><img src="https://img2018.cnblogs.com/blog/243596/201910/243596-20191021154313881-771163510.png" alt=""></p>
<p>----------------------------------------------------------------------------------------------------</p>
<p>到此C#调用RabbitMQ实现消息队列就讲完了。</p>
<p>代码已经传到Github上了，欢迎大家下载。</p>
<p style="border: 2px solid rgba(115, 191, 0, 1); padding: 10px 40px; background: rgba(204, 255, 128, 1); border-radius: 15px; -moz-border-radius: 15px">Github地址：https://github.com/kiba518/KibaRabbitMQ</p>
<p> </p>
<p> </p>

</div>
<p> </p>
<p>出处：https://www.cnblogs.com/kiba/p/11703073.html</p>

</div>
<div id="MySignature" role="contentinfo">
<div class="div_masklayer" id="div_masklayer"></div>
<div class="div_popup" id="Div_popup">
<div style="float:left;width:50%">
<img class="img_zfb" id="img_zfb" src="https://images.cnblogs.com/cnblogs_com/mq0036/508398/o_12.png" />
</div>
<div style="float:left;width:50%">
<img class="img_zfb" id="img_zfb" src="https://images.cnblogs.com/cnblogs_com/mq0036/508398/o_200921131119o_12.png">
</div>
<p class="mid">您的资助是我最大的动力！<br>金额随意,欢迎来赏！<br>
<span style="color: #f9f">付</span>款后有任何问题请给我留言。</p>
</div>

<div class="autograph">
<p> <span style="display: none"> 如果，您认为阅读这篇博客让您有些收获，不妨点击一下右下角的【<strong>推荐</strong>】按钮。<br>
   </span> 如果，您希望更容易地发现我的新博客，不妨点击一下绿色通道的【<strong>关注我</strong>】。(●'◡'●)</p>
<p>因为，我的写作热情也离不开您的肯定与支持，感谢您的阅读，我是【<strong>Jack_孟</strong>】！</p>
<div class="blogds">
   <b style="color:#f00;font-size: 22px">如果对你有所帮助，赞助一杯咖啡！打</b>

              
   <b style="color: #f00; font-size: 22px">付款后有任何问题请给我留言!!!</b>
</div>
<p>本文来自博客园，作者：jack_Meng，转载请注明原文链接：https://www.cnblogs.com/mq0036/p/11726733.html</p>
<p>【免责声明】本文来自源于网络，如涉及版权或侵权问题，请及时联系我们，我们将第一时间删除或更改！</p>
</div><br><br>
来源：https://www.cnblogs.com/mq0036/p/11726733.html

頁: [1]

琼殿技术论坛's Archiver

C#调用RabbitMQ实现消息队列