简介
RabbitMQ是一个消息代理。从本质上讲，它从消息生产者处接收消息，然后传递给消息的消费者。它在消息的生产者和消费者之间根据你指定的规则对消息进行路由、缓存和持久化。
RabbitMQ通常使用如下术语：
- 生产（Producing），表示消息的发送。发送消息的程序被称为生产者。我们画一个图来表示它，如下所示：
- 队列（Queue），表示邮箱的名称，它存在于RabbitMQ服务器中。尽管消息在RabbitMQ和你的应用程序间流转，但它们只能存储与RabbitMQ内部的队列中。队列不会有任何限制，它可以存放任意多的消息，就像一个无限量的缓存一般。多个生产者可以向同一个队列发送消息，多个消费者也可以尝试从同一个队列中读取消息。一个队列可以被画成下面这样在其上有一个名称的图形：
- 消费（Consuming），表示消息的接收。消费者表示通常都在等待接收消息的程序。画图的时候给它标记一个“C”：
需要注意的是，生产者、消费者和代理并不必驻留于同一个服务器上面；通常情况下，他们是分部在不同的机器上面的。
“Hello World“
使用.NET/C#客户端
在教程的这一部分，我们将用C#写两个程序；一个发送一条信息的生产者和一个接收并打印消息的消费者。我们会略过.NET API的一些细节，仅仅专注于如何完成这个简单的程序，传输内容为“Hello World”的消息。
下图中，“P”表示生产者，“C”表示消费者。中间的方框，表示一个队列--RabbitMQ为消费者提供的一个消息缓存。
.NET 客户端库
RabbitMQ遵循AMQP协议，一个关于消息发送的开放、通用协议。现在已经有很多不同编程语言实现的AMQP的客户端。我们将使用由RabbitMQ提供的.NET客户端。
下载客户端库的包，按照描述去检查它的签名。提取包的内容，把“RabbitMQ.Client.dll”程序集复制到你的工作目录下。
你需要确认你的系统中能找到C#的编译器csc.exe，你可能需要把目录“;C:\WINDOWS\Microsoft.NET\Framework\v3.5”（需要根据你实际的安装情况，修改目录中.NET版本）添加到你的Path中。
现在我们已经有了.NET客户端的二进制程序，可以写些代码了。
发送（Sending）
我们把消息的发送者称为Send.cs，消息的接收者称为Receive.cs。消息发送者将连接到RabbitMQ，发送一条消息，然后退出。
在Send.cs中，我们需要用到一些命名空间：
using System;
using RabbitMQ.Client;
using System.Text;
设置类
class Send
{
public static void Main()
{
...
}
}
然后创建一个到RabbitMQ服务的链接
class Send
{
public static void Main()
{
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
{
using (var channel = connection.CreateModel())
{
...
}
}
}
}
该链接抽象了套接字连接，为我们关注协议版本协定和身份认证等。在这里，我们连接到了一个本地的代理，因此使用的是localhost。如果我们想连接到其他机器的代理，只需要简单在在这里指定该机器的名称或者Ip地址即可。
接下来我们创建信道（Channel），完成工作的很多API都在里面。
为了发送消息，我们必须申明一个队列，然后才能将消息发布其中：
using System;
using RabbitMQ.Client;
using System.Text; class Send
{
public static void Main()
{
var factory = new ConnectionFactory() { HostName = "localhost" };
using(var connection = factory.CreateConnection())
using(var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "hello",
durable: false,
exclusive: false,
autoDelete: false,
arguments: null); string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message); channel.BasicPublish(exchange: "",
routingKey: "hello",
basicProperties: null,
body: body);
Console.WriteLine(" [x] Sent {0}", message);
} Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
}
}
申明一个队列是幂等的，它仅仅会在申明的队列不存在于RabbitMQ中时才被创建。消息的内容是字节数组，所以，你可以使用任何喜欢的方式对消息进行编码。
当上面的代码运行结束，信道和链接将会被释放。
发送无法执行
如果这是你第一次使用RabbitMQ，而且未看到已发送的消息，你一定会搔首疑惑是出了什么问题。也许是因为代理运行在没有足够空闲硬盘空间的机器上（默认情况下，代理需要至少50MB的空闲空间）而导致拒绝接收消息。通过查看代理的日志文件可以确认，同时如果有必要降低该项限制。配置文件文档可以告诉你如何设置（disk_free_limit）。
接收
上面那些是关于发送者的。RabbitMQ将消息压入接收者，所以和发布一条消息的发送者不一样，我们要保持接收者一直运行着去监听消息然后打印出来。
Receive.cs的代码需要引用和Send.cs中差不多相同的命名空间：
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;
类的设置和发送者是相同的；我们打开一个链接和一个信道，申明一个我们将要消费的队列。注意队列需要和发送者中申明的队列相匹配。
class Receive
{
public static void Main()
{
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
{
using (var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "hello",
durable: false,
exclusive: false,
autoDelete: false,
arguments: null);
...
}
}
}
}
注意在这里申明的这个队列。我们可能在运行发送者前运行接收者，需要确保在消费这个队列之前队列已经存在。
我们将要告诉RabbitMQ服务从哪个队列传递消息给我们。因为该队列将压入异步消息给我们，我们提供回调。这就是EveningBasicConsumer.Received事件处理器做的事情了。
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text; class Receive
{
public static void Main()
{
var factory = new ConnectionFactory() { HostName = "localhost" };
using(var connection = factory.CreateConnection())
using(var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "hello",
durable: false,
exclusive: false,
autoDelete: false,
arguments: null); var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
var body = ea.Body;
var message = Encoding.UTF8.GetString(body);
Console.WriteLine(" [x] Received {0}", message);
};
channel.BasicConsume(queue: "hello",
noAck: true,
consumer: consumer); Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
}
}
}
组合在一起
你可以引用RabbitMQ的.NET客户端程序集，然后编译Send.cs和Receive.cs。我们将使用命令行（cmd.exe和csc）编译和运行这些代码。或者你可以使用Visual Studio。
$ csc /r:"RabbitMQ.Client.dll" Send.cs
$ csc /r:"RabbitMQ.Client.dll" Receive.cs
然后运行可执行文件
$ Send.exe
接着运行接收者
$ Receive.exe
接收者会打印从RabbitMQ接收到的消息。接收者一直运行等待新消息（使用Ctrl+C中止），所以可以尝试在不同的终端运行发送者。
如果你希望在队列上做检查，使用rabbitmqctl list_queues.
Hello World!
现在是时候进入到第二部分去创建一个工作队列了。
原文链接：http://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html