MQ消息队列(4)C#利用RabbitMQ实现点对点消息传输


MQ消息队列(4)C#利用RabbitMQ实现点对点消息传输

RabbitMQ做为消息代理,负责接收和转发消息,可以将RabbitMQ比喻为一个邮筒、一个邮局和一个邮递员。本文主要以一个简单的小例子,简述RabbitMQ实现消息传输的相关内容,仅供学习分享使用,如有不足之处,还请指正。

消息队列模型

所有 MQ 产品从模型抽象上来说都是一样的过程:
消费者(consumer)订阅某个队列。生产者(producer)创建消息,然后发布到队列(queue)中,最后将消息发送到监听的消费者。

C#利用RabbitMQ实现点对点消息传输

RabbitMQ设置

RabbitMQ是通过交换机将消息转发到对应队列,所以队列需要和交换机进行绑定。本例将队列绑定到默认的amq.direct交换机,并设置Routing key,如下图所示:

C#利用RabbitMQ实现点对点消息传输

RabbitMQ动态库安装

通过NuGet包管理器进行安装RabbitMQ.Client,如下所示:

C#利用RabbitMQ实现点对点消息传输

RabbitMQ.Client相关知识点

  • ConnectionFactory:构造一个实例,主要创建连接。
  • IConnection:表示一个基于AMQP协议的连接。
  • IModel:表示一个RabbitMQ通道,可用于声明一个队列,然后开始消费。
  • EventingBasicConsumer:基于独立事件监听的基础消费者,可以监听并接收消息。
  • 生产者基本步骤:1. 创建连接 2. 基于连接创建通道 3. 基于通道声明队列,4. 开始生产并发布消息
  • 消费者基本步骤:1. 创建连接 2. 基于连接创建通道 3. 基于通道声明队列,4. 创建消费者,5. 绑定通道和消费者,并开始消费

示例效果图

本例主要有一个生产者,一个消费者,通过消息队列进行消息转发和接收。

生产者负责消息发送,如下图所示:

C#利用RabbitMQ实现点对点消息传输

消费者负责消息接收,如下图所示:

C#利用RabbitMQ实现点对点消息传输

核心代码

代码结构:主要包括生产者,消费者,公共基础代码,如下所示:

C#利用RabbitMQ实现点对点消息传输

RabbitMqHelper主要创建连接,如下所示:

     public class RabbitMqHelper
     {
         
         /// <summary>
         /// 创建连接
         /// </summary>
         /// <returns></returns>
         public IConnection GetConnection()
         {
             try
             {
                 var factory = new ConnectionFactory()
                 {
                     HostName = "127.0.0.1",
                     Port = 5672,
                     UserName = "guest",
                     Password = "guest",
                     VirtualHost = "/ShortMsgHost"
                 };
                 var conn = factory.CreateConnection();
                 return conn;
             }
             catch (Exception ex) {
                 throw ex;
             }
         }
 
    
 
     }

RabbmitMqSendHelper用于发送消息,如下所示:

     public class RabbmitMqSendHelper : RabbitMqHelper
     {
         /// <summary>
         /// 发送消息
         /// </summary>
         /// <param name="msg"></param>
         /// <returns></returns>
         public bool SendMsg(string msg)
         {
             try
             {
                 using (var conn = GetConnection())
                 {
                     using (var channel = conn.CreateModel())
                     {
                         channel.QueueDeclare(queue: "ShortMsgQueue",
                                      durable: true,
                                      exclusive: false,
                                      autoDelete: false,
                                      arguments: null);
                         var body = Encoding.UTF8.GetBytes(msg);
 
                         channel.BasicPublish(exchange: "amq.direct",
                                              routingKey: "ShortMsgKey",
                                              basicProperties: null,
                                              body: body);
 
                         //Console.WriteLine(" [x] Sent {0}", message);
                     };
                 };
                 return true;
             }
             catch (Exception ex)
             {
                 throw ex;
             }
         }
     }

RabbitMqReceiveHelper主要用于接收信息,如下所示:

     public class RabbitMqReceiveHelper : RabbitMqHelper
     {
         public RabbitMqReceiveEventHandler OnReceiveEvent;
 
         private IConnection conn;
 
         private IModel channel;
 
         private EventingBasicConsumer consumer;
 
         public bool StartReceiveMsg()
         {
             try
             {
                 conn = GetConnection();
 
                 channel = conn.CreateModel();
 
                 channel.QueueDeclare(queue: "ShortMsgQueue",
                                 durable: true,
                                 exclusive: false,
                                 autoDelete: false,
                                 arguments: null);
 
                 consumer = new EventingBasicConsumer(channel);
                 consumer.Received += (model, ea) =>
                 {
                     var body = ea.Body.ToArray();
                     var message = Encoding.UTF8.GetString(body);
                     //Console.WriteLine(" [x] Received {0}", message);
                     if (OnReceiveEvent != null)
                     {
                         OnReceiveEvent(message);
                     }
                 };
                 channel.BasicConsume(queue: "ShortMsgQueue",
                                         autoAck: true,
                                         consumer: consumer);
                 return true;
             }
             catch (Exception ex)
             {
                 throw ex;
             }
         }
     }

关于RabbitMQ的基础知识介绍,可参考前几篇博文。

版权声明:本文为开发框架文库发布内容,转载请附上原文出处连接
C/S框架网
上一篇:MQ消息队列(5)C#利用RabbitMQ实现消息订阅与发布
下一篇:MQ消息队列(3)RabbitMQ交换机类型简述
评论列表

发表评论

评论内容
昵称:
关联文章

MQ消息队列4C#利用RabbitMQ实现消息传输
MQ消息队列(5)C#利用RabbitMQ实现消息订阅与发布
MQ消息队列(2)RabbitMQ概念及控制台介绍
MQ消息队列(1)RabbitMQ入门介绍及环境搭建
MQ消息队列(3)RabbitMQ交换机类型简述
[原创]C#仿QQ聊天程序(无服务端, P2P)
C#.NET 消息机制
C# .NET 入门概念与知识总结
.NET 6 优先队列 PriorityQueue 详解
C#.NET 监视操作系统打开程序(使用Window消息实现全局系统勾子)
C# 利用PrintDocument定制打印单据
C# 实现FTP客户端
中国象棋网络战版(作者:孙中吕,C/S框架网原创)
编译器错误消息: CS0016: 未能写入输出文件“c:\Windows\Microsoft.NET\Framework\v4.0.30319\Temporary ASP.NET Files\root
企业版V4.0 - 并发控制几说明
热烈祝贺C/S框架网正式发布企业版V4.5,感谢您们长期我的支持!
热烈祝贺C/S框架网正式发布企业版V4.5,感谢您们长期我的支持!
DevExpress Winform 利用GridControl开发的会计凭证控件(C#源码)
C# 利用ZXing.Net来生成条形码和二维码
财务账模块 - 客户账 - TMS - 物流运输管理系统

热门标签
.NET5 .NET6 .NET7 APP Auth-软件授权注册系统 Axios B/S B/S开发框架 Bug Bug记录 C#加密解密 C#源码 C/S CHATGPT CMS系统 CodeGenerator CSFramework.DB CSFramework.EF CSFrameworkV1学习版 CSFrameworkV2标准版 CSFrameworkV3高级版 CSFrameworkV4企业版 CSFrameworkV5旗舰版 CSFrameworkV6.0 DAL数据访问层 Database datalock DbFramework Demo教学 Demo下载 DevExpress教程 DOM EF框架 Element-UI EntityFramework ERP ES6 Excel FastReport GIT HR IDatabase IIS JavaScript LINQ MES MiniFramework MIS NavBarControl Node.JS NPM OMS ORM PaaS POS Promise API Redis SAP SEO SQL SQLConnector TMS系统 Token令牌 VS2022 VSCode VUE WCF WebApi WebApi NETCore WebApi框架 WEB开发框架 Windows服务 Winform 开发框架 Winform 开发平台 WinFramework Workflow工作流 Workflow流程引擎 版本区别 报表 踩坑日记 操作手册 代码生成器 迭代开发记录 基础资料窗体 架构设计 角色权限 开发sce 开发技巧 开发教程 开发框架 开发平台 开发指南 客户案例 快速搭站系统 快速开发平台 秘钥 密钥 权限设计 软件报价 软件测试报告 软件简介 软件开发框架 软件开发平台 软件开发文档 软件体系架构 软件下载 软著证书 三层架构 设计模式 生成代码 实用小技巧 收钱音箱 数据锁 数据同步 微信小程序 未解决问题 文档下载 喜鹊ERP 喜鹊软件 系统对接 详细设计说明书 行政区域数据库 需求分析 疑难杂症 蝇量级框架 蝇量框架 用户管理 用户开发手册 用户控件 在线支付 纸箱ERP 智能语音收款机 自定义窗体 自定义组件 自动升级程序