1.RabbitMQ简介
RabbitMQ是流行的开源消息队列系统,用erlang语言开发。RabbitMQ是AMQP(高级消息队列协议)的标准实现。
2.应用场景
在项目中,将一些无需即时返回且耗时的操作提取出来,进行了异步处理(请求与动作分离),而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量等
3.基本概念
Broker:简单来说就是消息队列服务器实体。
Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。
Queue:消息队列载体,每个消息都会被投入到一个或多个队列。
Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key:路由关键字,exchange根据这个关键字进行消息投递。
vhost:虚拟主机,一个broker里可以开设多个vhost,用作不同用户的权限分离。
producer:消息生产者,就是投递消息的程序。
consumer:消息消费者,就是接受消息的程序。
channel:消息通道,在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务
4.消息的递交流程
消息的递交流程
1.消息生产者投递消息
2.消息根据Exchange(消息交换机)确定消息需要入的对列
3.消息投递给消费者
5.消息的一生
生产者: 消费者:
链接到RabbitMQ 链接到RabbitMQ
获取信道 获取信道
声明交换器 声明交换器
创建消息 绑定对列与交换器
发布消息 消息消费
关闭信道 关闭信道
关闭连接 关闭链接
6.RabbitMQ的三种Exchange
http://melin.iteye.com/blog/691265 作者:melin 图片来自网络,感谢前辈的付出
1.Direct Exchange
图片来源于网络如果 routing key 匹配, 那么Message就会被传递到相应的queue中。其实在queue创建时,它会自动的以queue的名字作为routing key来绑定那个exchange。
2.Fanout Exchange
图片来源网络只需要简单的将队列绑定到交换机上。一个发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。很像子网广播,每台子网内的主机都获得了一份复制的消息。Fanout交换机转发消息是最快的。
3.Topic Exchange
图片来源于网络将路由键和某模式进行匹配。此时队列需要绑定要一个模式上。符号“#”匹配一个或多个词,符号“*”匹配不多不少一个词。因此“audit.#”能够匹配到“audit.irs.corporate”,但是“audit.*”
最后
这一篇先熟悉下基本概念,知道消息是怎么传递的,并且了解交换器的特性,下一篇介绍
Spring Boot RabbitMQ的环境搭建
网友评论