前言：这可能将会是关于RabbitMQ的一系列文章，博主也是刚接触，许多东西也不是很懂，如有错误，还请指正。
一、安装RabbitMQ Management
如果有后台已经帮你搭好了环境，你可以跳过这一步。
- 使用Mac终端，输入
brew install rabbitmq，则可以安装RabbitMQ了，Mac端安装还是比较容易的。这里需要注意的是，你可能需要安装Homebrew这个工具，关于如何安装请自行查找相关文章，本篇不再说明。 - 使用浏览器，在网址栏输入
localhost:15672，如果你看到下图，那么说明你安装成功。
二、集成RMQClient
- 在podfile里面输入pod RMQClient
pod install
三、Hello World
首先来了解几个概念，下面是百度百科的资料:
Broker：简单来说就是消息队列服务器实体。
Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。
Queue：消息队列载体，每个消息都会被投入到一个或多个队列。
Binding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key：路由关键字，exchange根据这个关键字进行消息投递。
vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。
producer：消息生产者，就是投递消息的程序。
consumer：消息消费者，就是接受消息的程序。
channel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务。
消息队列的使用过程大概如下：
（1）客户端连接到消息队列服务器，打开一个channel。
（2）客户端声明一个exchange，并设置相关属性。
（3）客户端声明一个queue，并设置相关属性。
（4）客户端使用routing key，在exchange和queue之间建立好绑定关系。
（5）客户端投递消息到exchange。
exchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里。
exchange也有几个类型，完全根据key进行投递的叫做Direct交换机，例如，绑定时设置了routing key为”abc”，那么客户端提交的消息，只有设置了key为”abc”的才会投递到队列。对key进行模式匹配后进行投递的叫做Topic交换机，符号”#”匹配一个或多个词，符号””匹配正好一个词。例如”abc.#”匹配”abc.def.ghi”，”abc.”只匹配”abc.def”。还有一种不需要key的，叫做Fanout交换机，它采取广播模式，一个消息进来时，投递到与该交换机绑定的所有队列。
我们做完上面的准备工作，那么就可以开始撸代码了。
在你的ViewController文件里包含头文件，#import <RMQClient/RMQClient.h>，然后写一个发送一个接收的方法。
3.1 发送方法
- (void)send
{
RMQConnection * conn = [[RMQConnection alloc] initWithUri:@"amqp://wubb:123456@192.168.76.78" delegate:[RMQConnectionDelegateLogger new]];
// RMQConnection * conn = [[RMQConnection alloc] initWithDelegate:[RMQConnectionDelegateLogger new]];
[conn start];
id<RMQChannel>channel = [conn createChannel];
RMQQueue * queue = [channel queue:@"hello"];
[channel.defaultExchange publish:[@"hello world" dataUsingEncoding:NSUTF8StringEncoding] routingKey:queue.name];
[conn close];
}
在上段代码中：
- 我们创建了一个连接，然后开始连接打开一个通道；
- 我们声明了一个队列，并建立了队列与通道之间的关系。
- 我们使用routingKey将消息发送到了channel的默认Exchange上。
3.1 如果不使用默认Exchange，那么我们则可以自己创建一个Exchange。
3.2 创建好Exchange后，使用routingkey将queue和Exchange建立绑定关系。
3.3 发送消息。
在这段代码里面，需要注意的是，如果你的控制台也就是后台服务是由别的同事搭的，你需要连接他的后台，那么你应该使用代码中我没有注释的那一行，带上URi参数过去，参数格式是：amqp(amqps)://账号:密码@主机(IP或域名):端口/vhost ，如果后台服务的端口和vhost都是默认的，那么则可省略，即像代码中那样就OK了；如果你是自己搭建的后台服务，则使用注释掉的那一行就行。
此处参数需要注意的是：amqp是不经过SSL或者TLS认证的，amqps则是需要SSL或者TLS认证的，这个地方一定要注意了，因为坑了我啊。。也怪我自己眼神不好，没看清。。。两个方法的详细说明，可以在库文件里面看到，这里就不列举出来了。
3.2 接收方法
- (void)receive
{
RMQConnection * conn = [[RMQConnection alloc] initWithUri:@"amqp://wubb:123456@192.168.76.78" delegate:[RMQConnectionDelegateLogger new]];
// RMQConnection * conn = [[RMQConnection alloc] initWithDelegate:[RMQConnectionDelegateLogger new]];
[conn start];
id<RMQChannel>channel = [conn createChannel];
RMQQueue * queue = [channel queue:@"hello"];
[queue subscribe:^(RMQMessage * _Nonnull message) {
NSLog(@"message:%@",[[NSString alloc] initWithData:message.body encoding:NSUTF8StringEncoding]);
}];
}
在接收方法的代码中：
- 创建连接，并打开通道
- 声明队列，此时的队列要和发送中的队列名相同
- 告诉服务器，我们订阅了queue这个队列的消息，当服务器发送消息时，那么我们就能在block里面收到这个消息了
此段代码我们要注意的是，接收不要关闭连接！！！敲黑板！！！
运行程序后，我们就会收到消息了。
好了，那么这篇文章就完了。
参考资料:
