美文网首页
iOS RMQClient(RabbitMQ)第一章---Hel

iOS RMQClient(RabbitMQ)第一章---Hel

作者: 百里玄卿 | 来源:发表于2017-10-19 11:48 被阅读2102次

前言:这可能将会是关于RabbitMQ的一系列文章,博主也是刚接触,许多东西也不是很懂,如有错误,还请指正。

一、安装RabbitMQ Management

如果有后台已经帮你搭好了环境,你可以跳过这一步。

  1. 使用Mac终端,输入brew install rabbitmq,则可以安装RabbitMQ了,Mac端安装还是比较容易的。这里需要注意的是,你可能需要安装Homebrew这个工具,关于如何安装请自行查找相关文章,本篇不再说明。
  2. 使用浏览器,在网址栏输入localhost:15672,如果你看到下图,那么说明你安装成功。
正确安装RabbitMQ

二、集成RMQClient

  1. 在podfile里面输入pod RMQClient
  2. 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];
}

在上段代码中:

  1. 我们创建了一个连接,然后开始连接打开一个通道;
  2. 我们声明了一个队列,并建立了队列与通道之间的关系。
  3. 我们使用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]);
    }];  
}

在接收方法的代码中:

  1. 创建连接,并打开通道
  2. 声明队列,此时的队列要和发送中的队列名相同
  3. 告诉服务器,我们订阅了queue这个队列的消息,当服务器发送消息时,那么我们就能在block里面收到这个消息了

此段代码我们要注意的是,接收不要关闭连接!!!敲黑板!!!

运行程序后,我们就会收到消息了。

成功收到消息

好了,那么这篇文章就完了。

参考资料:

  1. RabbitMQ官方指导
  2. iOS RabbitMQ集成及使用

这里是写完的Demo

相关文章

网友评论

      本文标题:iOS RMQClient(RabbitMQ)第一章---Hel

      本文链接:https://www.haomeiwen.com/subject/iwquuxtx.html