站长之家seo工具包,广东创粤建设有限公司网站,wordpress评论跳过验证码,毕业设计做音乐网站可以吗序言 这几天呢#xff0c;公司风波再起#xff0c;去年一年公司CTO换啦4任#xff0c;CEO换啦三个#xff0c;这不刚来个新老大#xff0c;感觉还不错#xff0c;却没干过3个月又要走#xff0c;索性趁老大们走来走去的时候#xff0c;就给自己空出来#xff0c;稍稍总… 序言 这几天呢公司风波再起去年一年公司CTO换啦4任CEO换啦三个这不刚来个新老大感觉还不错却没干过3个月又要走索性趁老大们走来走去的时候就给自己空出来稍稍总结一下刚写的一个日志服务组件中用到的RabbitMQ,在.net中的实战中应用。 首先不去讨论我的日志组件怎么样。因为有些日志需要走网络有的又不需要走网路也是有性能与业务场景的多般变化在其中就把他抛开我们只谈消息RabbitMQ。 那么什么是RabbitMQ它是用来解决什么问题的性能如何又怎么用我会在下面一一阐述如有错误不到之处还望大家不吝赐教。 RabbitMQ简介 必须一提的是rabbitmq是由LShift提供的一个消息队列协议AMQP)的开源实现由以高性能、健壮以及可伸缩性出名的Erlang写成因此也是继承了这些优点。 百度百科对RabbitMQ阐述也非常明确建议去看下还有amqp协议。 RabbitMQ官网http://www.rabbitmq.com/ 如果你要下载安装那么必须先把Erlang语言装上。 RabbitMQ的.net客户端可以在nuget中输入rabbitmq轻松获得。 RabbitMQ与其他消息队列的对比早有仙人给写出来。 Message Queue Shootout 这篇文章中的测试案例为1百万条1k的消息每秒种的收发情况如下图。 如果你安装好啦rabbitmq他会提供一个操作监控页面,页面如下他几乎提供啦对rabbitmq的所有操作与监控所以你装上后自己多看看多操作下。 RabbitMQ中的一些名词阐述与消息从投递到消费的整个过程 从上图的标题中可以看到一些陌生的英文单词让我们感觉一无所知更无从操作那么我给大家弄啦一个图片大家可以看下或许对您理解这些新鲜的单词有所帮助。 看过这些名词之后或许你还毫无头绪那么我把消息从生产到消费的整个流程给大家说一下或许会更深入一点其中Exchange与Queue都是可以设置相关属性队列的持久化交换器类型制定。 Note首先这个过程走分三个部分1、客户端生产消息队列2、RabbitMQ服务端负责路由规则的绑定与消息的分发3、客户端消费消息队列中的消息 Note:由图可以看出一个消息可以走一次网络却被分发到不同的消息队列中然后被多个的客户端消费那么这个过程就是RabbitMQ的核心机制RabbitMQ的路由类型与消费模式。 RabbitMQ中Exchange的类型 类型有4种directfanouttopicheaders。其中headers不常用本篇不做介绍其他三种类型会做详细介绍。 那么这些类型是什么意思呢就是Exchange与队列进行绑定后消息根据exchang的类型按照不同的绑定规则分发消息到消息队列中可以是一个消息被分发给多个消息队列也可以是一个消息分发到一个消息队列。具体请看下文。 介绍之初还要说下RoutingKey这是个什么玩意呢他是exchange与消息队列绑定中的一个标识。有些路由类型会按照标识对应消息队列有些路由类型忽略routingkey。具体看下文。 1、Exchange类型direct 他是根据交换器名称与routingkey来找队列的。 Note:消息从client发出传送给交换器ChangeARoutingKey为routingkey.ZLH,那么不管你发送给Queue1还是Queue2一个消息都会保存在Queue1Queue2Queue3三个队列中。这就是交换器的direct类型的路由规则。只要找到路由器与routingkey绑定的队列那么他有多少队列他就分发给多少队列。 2、Exchange类型fanout 这个类型忽略Routingkey他为广播模式。 Note:消息从客户端发出只要queue与exchange有绑定那么他不管你的Routingkey是什么他都会将消息分发给所有与该exchang绑定的队列中。 3、Exchange类型topic 这个类型的路由规则如果你掌握啦那是相当的好用与灵活。他是根据RoutingKey的设置来做匹配的其中这里还有两个通配符为 *代表任意的一个词。例如topic.zlh.*他能够匹配到topic.zlh.one ,topic.zlh.two ,topic.zlh.abc, .... #代表任意多个词。例如topic.#他能够匹配到topic.zlh.one ,topic.zlh.two ,topic.zlh.abc, .... Note这个图看上去很乱但是他是根据匹配符做匹配的这里我建议你自己做下消息队列的具体操作。 具体操作如下 public static void Producer(int value){ try{ var qName lhtest1; var exchangeName fanoutchange1; var exchangeType fanout;//topic、fanoutvar routingKey *; var uri new Uri(amqp://192.168.10.121:5672/); var factory new ConnectionFactory{UserName 123,Password 123,RequestedHeartbeat 0,Endpoint new AmqpTcpEndpoint(uri)}; using (var connection factory.CreateConnection()){ using (var channel connection.CreateModel()){ //设置交换器的类型 channel.ExchangeDeclare(exchangeName, exchangeType); //声明一个队列设置队列是否持久化排他性与自动删除channel.QueueDeclare(qName, true, false, false, null); //绑定消息队列交换器routingkey channel.QueueBind(qName, exchangeName, routingKey); var properties channel.CreateBasicProperties(); //队列持久化properties.Persistent true; var m new QMessage(DateTime.Now, value); var body Encoding.UTF8.GetBytes(DoJson.ModelToJsonQMessage(m)); //发送信息 channel.BasicPublish(exchangeName, routingKey, properties, body);}}} catch (Exception ex){Console.WriteLine(ex.Message);}} 消息队列的消费与消息确认Ack 1、消息队列的消费 Note:如果一个消息队列中有大量消息等待操作时我们可以用多个客户端来处理消息这里的分发机制是采用负载均衡算法中的轮询。第一个消息给A下一个消息给B下下一个消息给A下下下一个消息给B......以此类推。 2、为啦保证消息的安全性保证此消息被正确处理后才能在服务端的消息队列中删除。那么rabbitmq提供啦ack应答机制来实现这一功能。 ack应答有两种方式1、自动应答2、手动应答。具体实现如下。 public static void Consumer(){ try{ var qName lhtest1; var exchangeName fanoutchange1; var exchangeType fanout;//topic、fanoutvar routingKey *; var uri new Uri(amqp://192.168.10.121:5672/); var factory new ConnectionFactory{UserName 123,Password 123,RequestedHeartbeat 0,Endpoint new AmqpTcpEndpoint(uri)}; using (var connection factory.CreateConnection()){ using (var channel connection.CreateModel()){channel.ExchangeDeclare(exchangeName, exchangeType);channel.QueueDeclare(qName, true, false, false, null);channel.QueueBind(qName, exchangeName, routingKey); //定义这个队列的消费者QueueingBasicConsumer consumer new QueueingBasicConsumer(channel); //false为手动应答true为自动应答channel.BasicConsume(qName, false, consumer); while (true){BasicDeliverEventArgs ea (BasicDeliverEventArgs)consumer.Queue.Dequeue(); byte[] bytes ea.Body; var messageStr Encoding.UTF8.GetString(bytes); var message DoJson.JsonToModelQMessage(messageStr);Console.WriteLine(Receive a Message, DateTime: message.DateTime.ToString(yyyy-MM-dd HH:mm:ss) Title: message.Title); //如果是自动应答下下面这句代码不用写啦。if ((Convert.ToInt32(message.Title) % 2) 1){channel.BasicAck(ea.DeliveryTag, false);}}}}} catch (Exception ex){Console.WriteLine(ex.Message);}} 总结 RabbitMQ个人感觉比较简易文章写的也可能比较简易呵呵见谅。如果您开发中用到啦RabbitMQ,或者开发中有什么疑惑欢迎加入群161474816232458226 我们一起讨论学习。 原文地址http://www.cnblogs.com/knowledgesea/p/5296008.html .NET社区新闻深度好文微信中搜索dotNET跨平台或扫描二维码关注
