消息中间件哪些事

阅读文本大概需要3分钟。

一、消息中间件的产生的背景

1.在网络通讯中，Http请求默认采用同步请求方式，基于请求与响应模式

2.在客户端与服务器进行通讯时，客户端调用服务端接口后，必须等待服务端完成处理后返回结果给客户端才能继续执行，这种情况属于同步调用方式。

3.如果服务器端发生网络延迟、不可达的情况，可能客户端也会受到影响。

二、什么是消息中间件

消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。

目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ

实现方式:面向消息的中间件(MessageOrlented MiddlewareMOM)较好的解决了以上问题。发送者将消息发送给消息服务器，消息服务器将消息存放在若千队列中，

在合适的时候再将消息转发给接收者。这种模式下，发送和接收是异步的，发送者无需等待; 二者的生命周期未必相同: 发送消息的时候接收者不一定运行，

接收消息的时候发送者也不一定运行;一对多通信: 对于一个消息可以有多个接收者。

原理图

三、JMS介绍

1、什么是JMS

JMS是java的消息服务器，JMS的客户端之间可以通过JMS服务进行异步的消息传输,是一个Java平台中面向消息中间件的API

角色划分

1.提供者：实现JMS规范的消息中间件服务器 (存放消息容器)

2.客户端：发送或接收消息的应用程序

3.生产者/发布者：创建并发送消息的客户端（向消息容器存放消息）

4.消费者/订阅者：接收并处理消息的客户端

5.消息：应用程序之间传递的数据内容

6.消息模式：在客户端之间传递消息的方式，JMS中定义了主题和队列两种模式 点对点与发布订阅模式。

2、什么是消息模型

• Point-to-Point(P2P) --- 点对点（生产者发送一条消息到queue，只有一个消费者能收到）
• Publish/Subscribe(Pub/Sub)--- 发布订阅(发布者发送到topic的消息，只有订阅了topic的订阅者才会收到消息)

即点对点和发布订阅模型

P2P(点对点)

• p2p模型图

• 相关概念

1. 消息队列（Queue）
2. 发送者(Sender)
3. 接收者(Receiver)
4. 每个消息都被发送到一个特定的队列，接收者从队列中获取消息。队列保留着消息，直到他们被消费或超时。

• p2p特点

1. 每个消息只有一个消费者（Consumer）(即一旦被消费，消息就不再在消息队列中)
2. 发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列
3. 接收者在成功接收消息之后需向队列应答成功，如果你希望发送的每个消息都应该被成功处理的话，那么你需要P2P模式。

• 应用场景

A用户与B用户发送消息

Pub/Sub (发布与订阅)

• Pub/Sub模式图

• 相关概念

1.主题（Topic）

2.发布者（Publisher）

3.订阅者（Subscriber） 4.客户端将消息发送到主题。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。

• Pub/Sub的特点

每个消息可以有多个消费者

发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息，而且为了消费消息，订阅者必须保持运行的状态。

为了缓和这样严格的时间相关性，JMS允许订阅者创建一个可持久化的订阅。这样，即使订阅者没有被激活（运行），它也能接收到发布者的消息。 如果你希望发送的消息可以不被做任何处理、

或者被一个消息者处理、或者可以被多个消费者处理的话，那么可以采用Pub/Sub模型

消息的消费 在JMS中，消息的产生和消息是异步的。对于消费来说，JMS的消息者可以通过两种方式来消费消息。 ○ 同步 订阅者或接收者调用receive方法来接收消息，receive方法在能够接收到消息之前（或超时之前）将一直阻塞 ○ 异步 订阅者或接收者可以注册为一个消息监听器。当消息到达之后，系统自动调用监听器的onMessage方法。

• 发布订阅与点对点通讯方式区别：

点对点 只能保证一个消费者进行消费 一对一 发布订阅 只要集群服务订阅该主题都会受收到消息 一对多

source：https://www.cnblogs.com/cxyyh/p/10700437.html