Publisher中调用send函数先创建一个连接到服务器，然后用该连接创建了一个channel，接着用该channel声明了一个hello的队列，最后向默认的交换机发送了一条消息。（exchange: ""） 空字符串即为默认的交换机 ，消息的路由为hello ，默认的交换机是direct类型，根据路由名称完全匹配队列的名称。所有的队列都会绑定到默认的交换机上,路由名称就是队列的名称。所以默认的交换机将消息发送到名声为hello 的队列。紧接着Consumer中调用ReceiveMsg 函数从hello 队列获取消息，获取到消息后调用act函数通知broker该消息已经被成功地消费，broker将这条消息删除，如下图
网上有部分示例是使用QueueingBasicConsumer来创建消费者的，我发现在新版本中已经过时了，原因是它容易造成内存溢出性能降低等一系列的问题,简单说一下QueueingBasicConsumer的处理流程，它接收到消息之后会把消息塞到一个Queue队列中，然后用户来循环这个队列处理消息，但是如果你一个消息处理的很慢，而消息又发送过来的很快很大，就会造成队列里面存的消息越来越多，最终造成内存溢出。所以现在推荐使用EventingBasicConsumer或者继承DefaultBasicConsumer来创建消费者，事件驱动就不会有这个问题了
上面的代码需要注意以下几点：
想要通过guest账户指定ip连接需要修改loopback_users配置
我们调用QueueDeclare函数声明一个队列，如果设置了队列持久化，即使重启服务队列仍然在。如果不是持久化，即使消息全都被消费了，只要服务没有重启，队列仍然存在。RabbitMQ不允许你使用不同的参数重新定义一个已经存在的队列，所以要么删除队列要么重新命名一个队列，删除队列可以通过管理界面来删除或者调用QueueDelete函数。
队列如果存在声明一次就够了，如果多次声明了一样的队列将不会有任何异常，但是如果消费者绑定了一个不存在的队列是会发生异常的:**_channel.BasicConsume**，所以习惯是在Woker中将需要监听的队列先声明一遍
排他队列：大概意思就是通过连接connectionA声明一个排他队列之后，以后也只能通过连接connectionA来访问该队列，其他连接一旦访问就会报队列被锁定的错误，这个实在想不到应用场景
队列持久化代表的是重启服务后队列仍然在，想要队列里的消息仍然存在需要同时设置消息持久化，但是如果只设置消息持久化不设置队列持久话也没有意义。但这也并不一定能保证消息一定不会丢失。首先必须要有消息确认机制来保证消息一定被正确消费了。最主要的问题是消息写入到磁盘需要一定的时间，如果服务接收到消息没有来得及写入磁盘就挂掉了，那么这个消息就丢失了，对于这一点可以查询一下RabbitMQ集群相关的文章
默认发送的消息都需要消费者确认，可以通过设置autoAct为true来自动确认消息，也可以调用BasicAck函数确认，总之如果消息需要确认，一定要在消息处理完成之后进行确认，否则当消费者连接关闭之后未被确认的消息很快就会被退回。
我上面定义的消费者原本是想要多次实例化Receive来模拟多个消费者的，然而事实证明并不好用，想要模拟多个消费者还是需要打开多个程序
EventingBasicConsumer的监听会创建一个前台线程一直在运行，所以在winform中如果关闭程序需要dispose掉connection占用的线程
轮询调度轮询调度就是同时运行多个消费者，当任务数量很多的时候RabbitMQ会将消息分发给不同的消费者（Worker）来减轻压力，想要让RabbitMQ公平的分发任务，需要在worker中用以下代码来设置一个worker的最大未确认消息数量
channel.BasicQos(0, 1, false);参数1就代表此Worker同时只会处理一条消息，如果当前的消息没有处理完毕（没有act），rabbitmq就会把剩下的任务发送给其他的worker，如果所有的worker都很忙，就需要排队了
绑定