1、特点
先进先出、先进后出
消息服务中间件来提升系统异步通信、扩展解耦能力2、运用场景
异步任务
注册和发发对应的信息做成两步分隔。中间由消息队列连接
区分线程池的异步。使用消息中间件注册后不需要等待。线程池需要等待所有完成
应用解耦
订单系统调用库存的接口参数多。如果参数变化需要更改代码。使用消息队列。把参数写入消息队列。库存系统取消息队列获取参数。这样不需要更改代码。
流量控制
大并发下。用原先处理流程。会导致系统处理慢,后台系统阻塞,系统资源耗尽,机器宕机。
使用消息队列。请求都进入消息队列。前台先给处理完成。后台慢慢处理。
3、概述
消息代理:安装了消息中间件的服务器
目的地:
1、队列:点对点消息通信(单体应用一样)
2、主题:发布(publish)/订阅(subscribe)消息通信
点对点:
消息发送者发送消息,消息代理将其放入一个队列中,消息接收者从队列中获 取消息内容,消息读取后被移出队列 消息只有唯一的发送者和接受者,但并不是说只能有一个接收者 发布订阅式: 发送者发送消息到主题,多个接受者监听这个主题,那么就会在消息到达时同时收到消息 JMS JAVA消息服务 基于JVM消息代理的规范。ActiveMQ、HornetMQ是JMS实现 AMQP (Advanced Message Queuing Protocol) 高级消息队列协议,也是一个消息代理的规范,兼容JMS RabbitMQ是AMQP的实现4、概念
Message:
消息是不具名的,它有消息头和消息体组成。消息体是不透明的(不是显示获取的),而消息头则有一系列的可选属性组成 ,这些属性包括routing-key(路由键) ,priority(相对于其他消息的优先权) 、delivery-mode(指出改消息可能需要持久性存储)等
Publisher:
消息的生产者,是一个想交换器发布小区的客户端应用程序
Exchange:
交换器,用来接受生成着发送的消息并将这些消息路由给服务器中的队列。
Exchange有4中类型:direct(默认),fanout,topic,和headers,不同类型的Exchange转发消息的策略有所有区别
Queue:
消息队列,用来保存消息知道发送给消费者。它是消息的容器,也是消息的终点,一个消息可投入一个或多个队列。消息一直在队列里面,等待消费者连接到这个队列将其取走
Binding
绑定,用户消息队列和交换器之间的关联,一个绑定就是基于路由键将交换器和消息队列连接起来的,所以可以将交换器理解成一个有绑定构成的路由表。
Exchange和Queue的绑定可以是多对多得关系
Connection:
网络连接,一个TCP连接
Channel:
信道,多路复用连接中的一条独立的双线数据流通道。信道是建立在真实的TCP连接内的虚拟连接,AMQP命令都是通过信道发出去的。不管是发布消息、订阅队列还是接收消息,这些动作都是通过信道完成。因为对于操作系统来说建立和销毁TCP都是非常昂贵的开销,所以引入了信道的概念,以复用一条TCP连接。
Consumer:
消息的消费者,表示一个从消息队列中取得消息的客户端应用程序。
Broker:
表示消息队列服务器实体
Virtual Host
虚拟主机,表示一批交互器,消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个vhost本质上就是一个mini版的RabbitMQ服务器。用有自己的队列、交换器、绑定和权限机制。vhost是AMQP概念的基础。必须在连接是指定,RabbitMQ默认的vhost是/
5、Docker安装RabbitMQ
docker run -d --name rabbitmq -p 5671:5671 -p 5672:5672 -p 4369:4369 -p 25672:25672 -p 15671:15671 -p 15672:15672 rabbitmq:management
6、RabbitMQ运行机制
AMQP 中的消息路由: AMQP 中消息的路由过程和 Java 开 发者熟悉的 JMS 存在一些差别, AMQP 中增加了 Exchange 和 Binding 的角色。生产者把消息发布 到 Exchange 上,消息最终到达队列 并被消费者接收,而 Binding 决定交 换器的消息应该发送到那个队列。
7、Exchange类型
Exchange分发消息时根据类型的不同分发策略有区别,目前共四种类型: direct 、 fanout 、 topic 、 headers 。 headers 匹配 AMQP 消息的 header 而不是路由键, headers 交换器和 direct 交换器完全一致,但性能差很多,目前几乎用不到了,所以直接 看另外三种类型: Direct (直接的)Exchange: (类 似于sql语句的=查询 select * from Bindings where bingding-key =routing key ) 消息中的路由键( routing key )如果和 Binding 中的 binding key 一致, 交换器 就将消息发到对应的队列中。路由键与队 列名完全匹配,如果一个队列绑定到交换 机要求路由键为“dog” ,则只转发 routing key 标记为“ dog” 的消息,不会转发 “dog.puppy” ,也不会转发“ dog.guard” 等等。它是完全匹配、单播的模式。路由键(routing key)为dog 根据绑定关系Bindings完全匹配dog 到指定队列Queues
Fanout (扇出)Exchange (类型于sql语句查询 * select * from Bindings )
(发布到所有跟这个交换器绑定的队列里)
每个发到 fanout 类型交换器的消息都 会分到所有绑定的队列上去。fanout 交 换器不处理路由键,只是简单的将队列 绑定到交换器上,每个发送到交换器的 消息都会被转发到与该交换器绑定的所 有队列上。很像子网广播,每台子网内 的主机都获得了一份复制的消息。 fanout 类型转发消息是最快的。
Topic (主题)Exchange (Exchange 就是对应的库名如mysql库,类似于sql语句的like 模糊查询,Bindings 就是表 ,bingding-key 就是字段列 ,routtiing key 就是参数 select * from Bindings where bingding-key like '%routtiing key %')
topic 交换器通过模式匹配分配消息的 路由键属性,将路由键和某个模式进行 匹配,此时列需要绑定到一个模式上。 它将路由键和绑定键的字符串切分成单 词,这些单词之间用点隔开 。它同样也 会识别两个通配符:符号“#” 和符号 “* ”。 # 匹配 0 个或多个单词, * 匹配一 个单词。总结:一个消息的流程



