一个winform带你玩转rabbitMQ(一)

干货先上图源码在系列结束后放出大概2到3篇本文从第三部分开始根据winform逐点展开

一. 安装部署

　　下载 rabbitMQ ：http://www.rabbitmq.com/download.html

　　安装rabbitmq需要erlang，下载erlang：http://www.erlang.org/download.html

　　按照官网按照步骤，例如windows http://www.rabbitmq.com/install-windows.html

　　安装完rabbitMQ可以再启动插件扩展，其中包含了一个管理后台

　　最新版本的后台地址为 http://localhost:15672/

　　用户名和密码都为guest，输入完成进入主菜单

　　功能很丰富，可以查看当前服务器的交换机，队列，消息，连接，会话等得使用情况。

　　基本上到这里服务器的安装部署环节算是ok，很简单。

二. 简介

　　要了解rabbitMQ 首先要了解AMQP协议百科上给的很详细 http://baike.baidu.com/view/4023136.htm?fr=aladdin

　　AMQP 有四个非常重要的概念：虚拟机(virtual host)，通道(exchange)，队列(queue)和绑定(binding)。

　　虚拟机: 通常是应用的外在边界，我们可以为不同的虚拟机分配访问权限。虚拟机可持有多个交换机、队列和绑定。
　　交换机: 从连接通道(Channel)接收消息，并按照特定的路由规则发送给队列。
　　队列: 消息最终的存储容器，直到消费客户端(Consumer)将其取走。
　　绑定: 也就是所谓的路由规则，告诉交换机将何种类型的消息发送到某个队列中。

　　这个概念很重要不然在学习rabbitmq的地方会碰到很多困难。想要进阶学习的可以参考 https://www.rabbitmq.com/tutorials/amqp-concepts.html

　　借用官方一个图来阐述AMQP

　　RabbitMQ是一个消息代理。它的核心原理非常简单：接收和发送消息。

　　你可以把它想像成一个邮局：你把信件放入邮箱，邮递员就会把信件投递到你的收件人处。在这个比喻中，RabbitMQ是一个邮箱、邮局、邮递员。RabbitMQ和邮局的主要区别是，它处理的不是纸，而是接收、存储和发送二进制的数据——消息。

　　对于rabbitMQ本身的特点参考官网 http://www.rabbitmq.com/features.html

　　1、可靠性(Reliability)
　　RabbitMQ提供很多特性供我们可以在性能和可靠性作出折中的选择，包括持久化、发送确认、发布者确认和高可用性等。
　　2、弹性选路(Flexible Routing)
　　消息在到达队列前通过交换（exchanges）来被选路。RabbitMQ为典型的选路逻辑设计了几个内置的交换类型。对于更加复杂的选路，我们可以将exchanges绑定在一起或者写属于自己的exchange类型插件。
　　3、集群化(Clustering)
　　在一个局域网内的几个RabbitMQ服务器可以集群起来，组成一个逻辑的代理人。
　　4、联盟(Federation)
　　对于那些需要比集群更加松散和非可靠连接的服务器来说，RabbitMQ提供一个联盟模型（Federation Model）
　　5、高可用队列(High Available Queue)
　　可以在一个集群里的几个机器里对队列做镜像，确保即时发生了硬件失效，你的消息也是安全的。
　　6、多客户端(Many Clients)
　　有各种语言的RabbitMQ客户端
　　7、管理UI(Management UI)
　　RabbitMQ提供一个易用的管理UI来监控和控制消息代理人的各个方面。
　　8、跟踪(Tracing)
　　如果你的消息系统行为异常，RabbitMQ提供跟踪支持来找出错误的根源。
　　9、插件系统(Plugin System)
　　RabbitMQ提供各种方式的插件扩展，我们可以实现自己的插件。

　　使用任务队列一个优点是能够轻易地并行处理任务。当处理大量积压的任务，只要增加工作队列，通过这个方式，能够实现轻易的缩放。

三. 初探

　　文中的winform所采取的client为官方的.net版本 https://github.com/rabbitmq/rabbitmq-dotnet-client

　　首先是Connection和Channel的概念

　　Connection 建立与rabbitmq server的一个连接，由ConnectionFactory创建，Channel建立在connection基础上的一个频道，相对于connection来说，它是轻量级的。可以理解成一次会话。

　　代码示例本机环境

                using (IConnection connection = factory.CreateConnection())
                {
                    using (IModel channel = connection.CreateModel())
                    {
			//do something
                    }
                }

　　exchange有三种类型：

　　Direct ：处理路由键。需要将一个队列绑定到交换机上，要求该消息与一个特定的路由键完全匹配。这是一个完整的匹配。
　　Fanout ：不处理路由键。你只需要简单的将队列绑定到交换机上。一个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。
　　Topic : 将路由键和某模式进行匹配。此时队列需要绑定要一个模式上。符号“#”匹配一个或多个词，符号“*”匹配不多不少一个词。

　　我们用winform分别造成三种类型的exchange来实际体验一下