客户端有很多人来访问,业务系统抗不住了,就把前方发来的任务转换成消息队列,分发给子业务系统去执行,来降低业务系统的压力.
消息传递过程中有2个主体
1 消息的发送方 → 生产者
2 消息的接收方 → 消费者
同步消息:收到消息的回复再发新消息
*异步消息:不需要收到对方的回复就可以发新消息
1 JMS
2 AMQP
3 MQTT
JMS(java message service):一个规范,提供了与消息服务相关的API接口
JMS消息模型:
点对点模型:队列的消息只能被1个消费者消费
发布订阅模型:消息可以被多个消费者消费,生产者和消费者完全独立,不需要感知对方的存在
AMQP(advanced message queuing protocol) : 一种协议,高级消息队列协议 → 规范了网络交换的数据格式,兼容JMS
优点:跨平台
MQTT:消息队列遥测传输,专为小设备设计,是物联网生态系统主要成分之一
Kafka:一种高吞吐量的分布式发布订阅消息系统,提供实时消息功能
就记住:
以后的任务都可以转换成消息,再由另一方拿到消息去处理.
就好比以前你是打工的,你接到3个任务就去处理,
现在你招了几个小弟,你接到任务,把3个任务分别用消息的形式传达给小弟,让小弟替你去干活.
4种常用消息队列产品
