C# 使用 RabbitMQ
1. RabbitMQ
MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。其中较为成熟的MQ产品有MSMQ,ActiveMQ,RabbitMQ,IBM WEBSPHERE MQ 等。
RabbitMQ是使用Erlang开发的,开源的,一个在高级消息队列协议(AMQP)基础上完整的,可复用的企业消息系统,遵循Mozilla Public License开源协议。
RabbitMQ支持大多数开发语言如Java,Ruby,Python,.Net,C/C++,Erlang等,各种语言的客户端可以从官网上下载。
2. RabbitMQ的一些概念
- 连接(Connection),与RabbitMQ Server建立的一个连接,由ConnectionFactory创建,每个connection只与一个物理的Server进行连接,此连接是基于Socket进行连接的,这个可以相似的理解为像一个DB Connection。AMQP一般使用TCP链接来保证消息传输的可靠性。
- 通道 (Channel),在C#客户端里应该是叫Model,其他客户端基本都叫Channel。建立在Connection基础上的一个通道,相对于Connection来说,它是轻量级的。它就像是Hibernate里面的Session一样。Channel 主要进行相关定义,发送消息,获取消息,事务处理等。Channel可以在多线程中使用,但是必须保证任何时候只有一个线程执行命令。一个Connection可以有多个Channel。客户端程序有时候会是一个多线程程序,每一个线程都想要和RabbitMQ进行连接,但是又不想共享一个连接,这种需求还是比较普遍的。因为一个Connection就是一个TCP链接,RabbitMQ在设计的时候不希望与每一个客户端保持多个TCP连接,但这确实是有些客户端的需求,所以在设计中引入了Channel的概念,每一个Channel之间没有任何联系,是完全分离的。多个Channel来共享一个Connection。
- 交换器(Exchange),发送消息的实体。
- 队列(Queue),接收消息的实体。
- 绑定器(Bind),将交换器和队列连接起来,并且封装消息的路由信息。
3.资源文件
4.发送消息
/// <summary>
/// </summary>
/// <param name="deptId">部门id</param>
/// <param name="userCode">用户名</param>
/// <returns></returns>
[Generated]
protected override String SendMQ(long deptId, string userCode, string clientIP)
{
var factory = new ConnectionFactory();
factory.HostName = "182.94.73.104"; //MQ服务端IP
factory.Port = ; //MQ 服务端端口
factory.UserName = "login_mq_user";
factory.Password = "chinaiss_xyz@345Q1uTfcx.vb";
//factory.HostName = "localhost";
//factory.UserName = "yy";
//factory.Password = "hello!"; string ticket = System.Guid.NewGuid().ToString(); //对应URL中的token参数 //MQINFOPoco MQobj = new MQINFOPoco();
//MQobj.clientIP = clientIP;
//MQobj.section = deptId;
//MQobj.userId = userCode;
//MQobj.loginTime = GetTimeStamp();
//MQobj.timeLive = 480;
//MQobj.token = ticket;
var loginTime = GetTimeStamp(); using (var connection = factory.CreateConnection())
{
using (var channel = connection.CreateModel())
{
channel.QueueDeclare("login_queue", false, false, false, null); //MQ队列名称login_queue
//string message = ObjectToJson(MQobj);
StringBuilder message = new StringBuilder(@"{""clientIP"":");
message.AppendFormat("\"{0}\"", clientIP);
message.AppendFormat(",\"section\":\"{0}\"", deptId);
message.AppendFormat(",\"userId\":\"{0}\"", userCode);
//message.Append(",\"userId\":\"hxj\"");
message.AppendFormat(",\"loginTime\":{0}", loginTime);
message.Append(",\"timeLive\":480");
message.AppendFormat(",\"token\":\"{0}\"", ticket);
message.Append("}"); var properties = channel.CreateBasicProperties();
properties.SetPersistent(true);
var body = Encoding.UTF8.GetBytes(message.ToString());
channel.BasicPublish("", "login_queue", properties, body);
}
} return ticket;
}
最新文章
- python画决策树
- python爬某个网站的图片
- python用法笔记(数组(list、touple、dict)、字符串)
- vim命令总结
- 谈谈以下关键字的作用auto static register const volatile extern
- 六行代码获取本地IP
- Windows环境搭建Web自动化测试框架Watir
- icheck.min.js 选中效果
- SQL的自增列重置的方法
- 事件g_Events
- NodeJS之queryString
- 【技术干货】听阿里云CDN安防技术专家金九讲tengine+lua开发
- 结对编程-四则运算-GUI
- 2017-9-3模拟赛T2 取数(win)
- jQuery上传文件
- JS 网页快捷键设置
- php empty()与isset()
- Electron 入门案例1
- TA-Lib函数对照
- 我的AOP那点事儿--1
热门文章
- Windows 98 二十岁了,这些功能都是从它开始的(虽然 Windows 98 不如 Windows 95 那样具有革命性,但完成度更高,更加成熟。到最后还是:相见不如怀念。)
- The program yum-complete-transaction is found in the yum-utils package
- 洛谷P3954 成绩【民间数据】
- Day4下午解题报告
- 关于Promise详解
- C#打印日志的小技巧(转)
- Eclipse工具修理集
- WEB前端--深入进去
- JSP语法基础(一)
- JS实现弹性势能效果(弹力球效果[实现插件封装])