重要文档
RabbitMQ 官网
RabbitMQ 官网 -- RabbitMQ Tutorials
RabbitMQ GitHub
RabbitMQ 中文文档
RabbitMQ 在线模拟器，可以帮助理解Exchange／queue／binding概念。
参考文档一：RabbitMQ与AMQP协议详解
参考文档二：RabbitMq（一）走进RabbitMq
一、AMQP-高级消息队列协议
1.1、什么是AMQP
AMQP，即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。Erlang中的实现有 RabbitMQ等。-- 百度百科
基于AMQP协议的常见消息中间件有QPID、RabbitMQ、ActiveMQ等等。
1.2、为什么要用AMQP
- 我们的目标是实现一种在全行业广泛使用的标准消息中间件技术，以便降低企业和系统集成的开销，并且向大众提供工业级的集成服务。
- 我们的宗旨是通过AMQP，让消息中间件的能力最终被网络本身所具有，并且通过消息中间件的广泛使用发展出一系列有用的应用程序。
1.3、基本元素
- Broker: 接收和分发消息的应用，RabbitMQ Server就是Message Broker。
- Virtual host: 出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中，类似于网络中的namespace概念。当多个不同的用户使用同一个RabbitMQ server提供的服务时，可以划分出多个vhost，每个用户在自己的vhost创建exchange／queue等。
- Connection: publisher／consumer和broker之间的TCP连接。断开连接的操作只会在client端进行，Broker不会断开连接，除非出现网络故障或broker服务出现问题。
- Channel: 如果每一次访问RabbitMQ都建立一个Connection，在消息量大的时候建立TCP Connection的开销将是巨大的，效率也较低。Channel是在connection内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的channel进行通讯，AMQP method包含了channel id帮助客户端和message broker识别channel，所以channel之间是完全隔离的。Channel作为轻量级的Connection极大减少了操作系统建立TCP connection的开销。
- Exchange: message到达broker的第一站，根据分发规则，匹配查询表中的routing key，分发消息到queue中去。常用的类型有：direct (point-to-point), topic (publish-subscribe) and fanout (multicast)。
- Queue: 消息最终被送到这里等待consumer取走。一个message可以被同时拷贝到多个queue中。
- Binding: exchange和queue之间的虚拟连接，binding中可以包含routing key。Binding信息被保存到exchange中的查询表中，用于message的分发依据。
1.4、典型的“生产／消费”消息模型
『生产／消费』模型
生产者发送消息到broker server（RabbitMQ）。在Broker内部，用户创建Exchange／Queue，通过Binding规则将两者联系在一起。Exchange分发消息，根据类型／binding的不同分发策略有区别。消息最后来到Queue中，等待消费者取走。
1.5、Exchange类型
Direct型
单播型： 在路由键和绑定键完全匹配的消息和队列之间建立转发通道
单播型
Message中的“routing key”如果和Binding中的“binding key”一致， Direct exchange则将message发到对应的queue中。
Fanout型
广播型： 将消息和当前所有队列(和当前exchange建立绑定)之前建立转发通道
广播型
每个发到Fanout类型Exchange的message都会分到所有绑定的queue上去。
Topic 型
组播型 ： 路由键和绑定键是模糊匹配的，匹配规则如下
组播型
根据routing key，及通配规则，Topic exchange将分发到目标queue中。
Routing key中可以包含两种通配符，类似于正则表达式：
格式：
<elem>.<color>.<specific>
*: 匹配一个单词，表示该处必须有一个单词
#: 匹配任意个单词，表示该处有没有单词都行
示例： 消息路由键为*.color.#将与队列绑定键为parameter.color或者parameter.color.red匹配
二、iOS项目导入RabbitMQ
2.1、创建项目
- podfile
platform :ios, '8.0'
target:"RabbitMQ_iOS_demo" do
use_frameworks!
pod "RMQClient"
end
- 终端运行如下：
终端
- 仅仅安装了一个“RMQClient”，会顺带安装另外两个需要的库
项目中多出两个库
·
网友评论