asp.Net   发布时间:2022-04-07  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了.Net使用RabbitMQ大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

网上参大神们的博客,自己做了一个RabbitMQ即时发消息的Demo。

<p class="title">1.使用VS的NuGet安装包管理工具安装RabbitMQ.Client:

title=".Net使用RabbitMQ" alt=".Net使用RabbitMQ" src="https://cn.js-code.com/res/2019/02-06/17/9e77d522eeecb977aba7db0db25ba5b9.png" >

<p class="title">2.生产者端代码:


<div class="cnblogs_code">

  m.Collections.Generic;
 m.Linq;
 m.Text;
 m.Threading.Tasks;
  
  {
      {
          
                   
            ConnectionFactory rabbitMqFactory =  {
             HostName=             UserName =              password =              Port =              jentVirtualHost"
           
                   
          String Exchangename = jent.Exchange          
                   
          String Queuename = jent.Queue           Main(String {
 );
             Console.WriteLine();
 );
           
                   
            {
              (IConnection conn = {
                  (IModel chAnnel = {
                     chAnnel.ExchangeDeclare(Exchangename,,durable: ,autodelete: false,arguments: );
                     chAnnel.QueueDeclare(Queuename,exclusive: false,arguments: );
 Annel.QueueBind(Queuename,Exchangename,routIngKey: QueueName);
 
                      props =Annel.CreateBasicProperties();
                     props.Persistent =                      Console.WriteLine();
                     String vadata =);
                      (vadata !=  {
                          msgBody =);
 Annel.basicPublish(exchange: Exchangename,routIngKey: Queuename,basicProperties: props,body: msgBody);
                         Console.WriteLine(String.Format({0},发送完毕,输入exit退出消息发送,datetiR_720_11845@e.Now.ToString();
                         vadata =);
      }

title">3.消费者端代码:

m.Collections.Generic; m.Linq; m.Text; m.Threading.Tasks; { { ConnectionFactory rabbitMqFactory = { HostName = jentVirtualHost" String Exchangename = jent.Exchange String Queuename = jent.Queue Main(String { ); Console.WriteLine(); ); { (IConnection conn = { (IModel chAnnel = { chAnnel.ExchangeDeclare(Exchangename,routIngKey: QueueName); ( { BasicGetResult msgResponse = chAnnel.basicGet(Queuename,autoAck: false); (msgResponse != { msgBody =String(msgResponse.body); Console.WriteLine(String.Format({0},消息内容:{1},datetiR_720_11845@e.Now.ToString(); m.Threading.Thread.Sleep(TimeSpan.FromSeconds(1)); }

title">4.程序结果:

title=".Net使用RabbitMQ" alt=".Net使用RabbitMQ" src="https://cn.js-code.com/res/2019/02-06/17/4785e6610cd0ca2627bdef958f978131.png" >

注:在第一步之前,你@R_944_10936@RabbitMQ客户端,可从http://www.rabbitmq.com/download.html下载,

        但是RabbitMQ又是依赖于Erlang OTP平台,所以,安装RabbitMQ之前,需要先从http://www.erlang.org/download.html下载安装erlang

        关于这部分的内容,推荐阅读:http://www.cnblogs.com/5ishare/p/6716142.html

  此Demo只是‘direct’方式的消息发送接收方式。

大佬总结

以上是大佬教程为你收集整理的.Net使用RabbitMQ全部内容,希望文章能够帮你解决.Net使用RabbitMQ所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签: