在Windows上安装RabbitMQ指南

c:Program Files (x86)RabbitMQ Serverrabbitmq_server-3.2.3sbin>rabbitmqctl.ba
t list_users
Listing users ...
guest [administrator]
...done.

c:Program Files (x86)RabbitMQ Serverrabbitmq_server-3.2.3sbin>rabbitmqctl.ba
t list_vhosts
Listing vhosts ...
/
...done.

c:Program Files (x86)RabbitMQ Serverrabbitmq_server-3.2.3sbin>rabbitmqctl.ba
t add_user geffzhang zsy@2014
Creating user "geffzhang" ...
...done.

c:Program Files (x86)RabbitMQ Serverrabbitmq_server-3.2.3sbin>rabbitmqctl.ba
t list_users
Listing users ...
geffzhang []
guest [administrator]
...done.

c:Program Files (x86)RabbitMQ Serverrabbitmq_server-3.2.3sbin>rabbitmqctl.ba
t set_user_tags geffzhang administrator
Setting tags for user "geffzhang" to [administrator] ...
...done.

c:Program Files (x86)RabbitMQ Serverrabbitmq_server-3.2.3sbin>rabbitmqctl.ba
t set_permissions -p / geffzhang ".*" ".*" ".*"
Setting permissions for user "geffzhang" in vhost "/" ...
...done.

c:Program Files (x86)RabbitMQ Serverrabbitmq_server-3.2.3sbin>rabbitmqctl.ba
t list_users
Listing users ...
geffzhang [administrator]
guest [administrator]
...done.

在.NET上使用Rabbit MQ

通过Nuget 获取Rabbit MQNET client bindings from NuGet:

PM> Install-Package RabbitMQ.Client

我们最常见的一个场景是发送和接收Rabbit MQ 持久化消息：

第一步是声明durable Exchange 和 Queue

private readonly ConnectionFactory rabbitMqFactory = new ConnectionFactory { HostName = "Geffzhang-NB", UserName="geffzhang", Password ="zsy@2014 ", VirtualHost ="/" };
conststringExchangeName="test.exchange";
conststringQueueName="test.queue";

using(IConnectionconn=rabbitMqFactory.CreateConnection())
using(IModelchannel=conn.CreateModel())
{
channel.ExchangeDeclare(ExchangeName,"direct",durable:true,autoDelete:false,arguments:null);

channel.QueueDeclare(QueueName,durable:true,exclusive:false,autoDelete:false,arguments:null);
channel.QueueBind(QueueName,ExchangeName,routingKey:QueueName);
}

下面对上面代码进行说明：
1. 使用ConnectionFactory创建连接，虽然创建时指定了多个server address，但每个connection只与一个物理的server进行连接。

2. 定义交换方式，创建了Direct Exchange和Durable Queue，并使用QueueName作为routing key，可以把消息直接投递到某个队列。rabbitmq交换方式分为三种，分别是：
Direct Exchange– 处理路由键。需要将一个队列绑定到交换机上，要求该消息与一个特定的路由键完全匹配。这是一个完整的匹配。如果一个队列绑定到该交换机上要求路由键 “dog”，则只有被标记为“dog”的消息才被转发，不会转发dog.puppy，也不会转发dog.guard，只会转发dog。
Fanout Exchange– 不处理路由键。你只需要简单的将队列绑定到交换机上。一个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。很像子网广播，每台子网内的主机都获得了一份复制的消息。Fanout交换机转发消息是最快的。
Topic Exchange– 将路由键和某模式进行匹配。此时队列需要绑定要一个模式上。符号“#”匹配一个或多个词，符号“*”匹配不多不少一个词。因此“audit.#”能够匹配到“audit.irs.corporate”，但是“audit.*” 只会匹配到“audit.irs”。

运行上述代码，可以在Rabbit MQ的管理控制台上看到test.exchangeExchange 绑定到 创建的队列test.queue

第二步就是发布持久化消息到队列

Exchange和Queue建立好以后，就可以发送消息到队列了。RabbitMq 可以接受byte[]的数据，字符串采用utf-8编码的字节数组。确保消息可持久化的，需要设置PersistMode为true，参看下面的代码：

varprops=channel.CreateBasicProperties();
props.SetPersistent(true);

varmsgBody=Encoding.UTF8.GetBytes("Hello, World!");
channel.BasicPublish(ExchangeName,routingKey:QueueName,basicProperties:props,body:msgBody);
第三步就是消费消息了，有几种不同的方法从队列中消费消息，最常见的是使用BasicGet：

BasicGetResult msgResponse = channel.BasicGet(QueueName, noAck: true);

var msgBody = Encoding.UTF8.GetString(msgResponse.Body);

NoAck:true告诉RabbitMQ立即从队列中删除消息，另一个非常受欢迎的方式是从队列中删除已经确认接收的消息，可以通过单独调用BasicAck 进行确认：

BasicGetResultmsgResponse=channel.BasicGet(QueueName,noAck:false);

//process message ...

channel.BasicAck(msgResponse.DeliveryTag,multiple:false);
使用BasicAck方式来告之是否从队列中移除该条消息，这一点很重要，因为在某些应用场景下，比如从队列中获取消息并用它来操作数据库或日志文件时，如果出现操作失败时，则该条消息应该保留在队列中，只到操作成功时才从队列中移除。

另一种方法是通过基于推送的事件订阅。您可以使用内置的QueueingBasicConsumer提供简化的编程模型，通过允许您在共享队列上阻塞，直到收到一条消息，例如

var consumer = new QueueingBasicConsumer(channel);

channel.BasicConsume(QueueName, noAck: true, consumer: consumer);

var msgResponse = consumer.Queue.Dequeue(); //blocking

var msgBody = Encoding.UTF8.GetString(msgResponse.Body);