在这篇文章中,我将讲述一下异步消息中的一些基本概念,在下篇文章中,你可以看到一些实现细节以及一些在springboot中使用rabbitMQ的代码块。
1.使用消息的目的
消息提供了一个让多个应用组件或软件甚至多个系统轻松整合的机制,它让系统之间的通信变得比较随意,异步。有很多协议都提供了这个特性,但是 AMQP协议确实最受欢迎并且健壮的。
2.AMQP
AMQP(Advanced Message Queuing Protocol) 就是一个RabbitMq用于实现消息的协议。虽然RabbitMQ也支持了许多其他协议,但是AMQP协议却是RabbitMq兼容性最强并且提供的特性最多的协议。
3.RabbitMQ
RabbitMQ是一个功能强大并且开源的消息代理器。它是世界上使用最广泛并且部署数量最多的消息代理器。这是它的官方网站:offical webSite
3.1 rabbitmq的安装
访问它的官方网站,你可以找到下载和安装连接,点击这个连接,你就可以进入下载和安装章节。你可以根据你使用的操作系统类型,来选择下载一个最合适的版本,然后进行安装。
注意一点,RabbitMQ需要Erlang环境才能运行,你可以为你所下载的RabbitMq去选择一个合适的Erlang版本。
3.2 RabbitMQ 的管理界面
安装完成之后,你可以随时访问RabbitMQ的管理界面,在这个管理界面中,你可以看到一些关于exchange、queue、bindings 以及 messages 的一些细节。 (如果你没有在安装的时候,改变端口号的话)默认的访问url地址是:http://localhost:15672,默认 默认的用户名是:guest,密码是:guest。
我推荐你在这个界面上玩一下,比如 向队列中发送消息,从队列中取出消息等等,这样就能感受一下,它到底是如何工作的啦。如果你不懂这些关键术语的话,那么不要担心,在下一节中,我们将详细介绍这些关键术语。
3.3 RabbitMQ的架构设计
Publisher -发布者
Binding -绑定
Exchange -交换机
Subscriber -订阅者
3.4RabbitMQ的关键术语:
Exchange(交互机):取出一个消息并且把它路由给一个或多个队列。路由算法决定了从exchange的的什么地方发出这个消息,同时,路由算法也取决于exchange的类型和规则也就是所谓的:"bindings"。
交互机类型:
(1). Direct 它的路由规则是: Direct会使用一个routing key来做路由,它会把消息路由给那些绑定到该exchange上并且routingkey相等的队列上。 目的: 这是默认的交互机类型 ,当一个消息需要发送给一个队列时,通常使用这种类型的交互机。
(2). Fanout 它的路由规则是: Fanout会把消息路由给所有绑定到该交互机上的队列。如果提供的有routing key的话,routingkey也会被忽视。 目的: 这非常适用于发布-订阅模式下广播特性。
(3). Topic 它的路由规则是: Topic会把消息路由给那些匹配routing key的队列。
目的: 这比较适用于处理那些基于某些条件下广播给特定队列的场景
(4). Headers 它的路由规则是: Headers在路由消息时,是基于消息头来做出抉择的。
目的: 这适用于那些点对点发送一些包含部分已知条件的消息。
下面用一张图来说明:
Topic : Topics是消息的主题部分。这些对于消息交换机message exchage来说都是可选的参数。
Bindings: "Bindings"就是把交换机exchange和队列queue粘合在一起的胶水,它都是一些路由算法的规则。
Queues : Queue队列是消息的容器。 它只受主机内存和磁盘的限制,在消息被发送给订阅者之前,队列是消息的最终目的地。
队列的属性:
name //队列名称
Durable //是否持久化该队列到磁盘上
Exclusive //如果不再使用就删除该队列
Auto-Delete //如果没有消费者订阅的话,就删除。
生产者: 生产者就是发送消息给队列的程序。
消费者: 消费者就是从队列中接收消息的程序。
4.RabbitMQ配置
可以使用 rabbitmq.conf文件来对rabbitMQ进行配置,文件的默认的存储路径取决于操作系统,windows上的路径是:%APPDATA%\RabbitMQ\。
5.总结:
我希望这篇文章讲述了RabbitMQ中的一些基本概念。在我的下一篇文章中,我将讲述如何使用springboot集成RabbitMQ消息代理器来提供一个异步的消息功能。