一、ActiveMQ介绍 | 青啊青斯

一、JMS

jms是java消息服务接口规范，主要包含四大元素：生产者、消费者、消息、消息服务。
- 生产者：创建消息，并把消息发动到消息服务；
- 消费者：从消息服务接收消息；
- 消息服务：即MQ消息服务（broker），而生产者与消费者相对其均为客服端；
- 消息：整个消息服务的传输对象，消息包含消息头、消息属性、消息体；

jms消息传递模式有如下两种，
- 点对点消息传递模式（P2P）：消息发送到一个特殊队列(queue), 消费者从队列获取消息，一条消息只能被只能被一个消费者消费；
- 发布/订阅消息传递模式(publish-subscribe)：消息被发送到一个主题上(topic)，所有订阅了该主题的消费者，都能接收到消息。

JMS应用程序由如下基本模块组成
- 1.连接工厂对象，创建消息客户端(生产者、消费者)与消息服务端的连接(connection)；
- 2.连接对象，创建回话对象(session);
- 3.会话对象，创建生产者对象(producer)、消费者对象(consumer)以及消息对象(message)；
- 4.目的地(queue/topic)，点对点模式下目的地是队列(queue)，发布/订阅模式下目的地是主题(topic)，生产者把消息发送到目的地，消费者从目的地接收消息

Destination-目的地

总共有两大模式
- 队列（Queue）：队列是一种一对一的消息传递模式。在队列中，消息发送方（生产者）将消息发送到队列中，然后消息接收方（消费者）从队列中接收并处理消息。每条消息只会被一个消费者接收和处理，确保了消息的顺序性和唯一性。
- 主题（Topic）：主题是一种一对多的消息传递模式。在主题中，消息发送方（生产者）将消息发送到主题中，然后所有订阅该主题的消息接收方（消费者）都会收到该消息。每个消费者都可以独立地接收和处理消息，消息的传递是广播式的，可以实现发布-订阅模式。（类似公众号，N个人订阅，就有N个人收到消息）。

消息中间件是实现了jms规范的落地产品，目前市场上主流的消息中间件有 ActiveMQ、Kafka、RocketMQ、RabbitMQ等。企业开发中使用消息中间件的主要目的是 解决耦合调用、抵御洪峰流量(削峰)等。 以下主要讲解ActiveMQ的使用。

微服务架构后，链式调用是我们在写程序时候的一般流程,为了完成一个整体功能会将其拆分成多个函数(或子模块)，比如模块A调用模块B,模块B调用模块C,模块C调用模块D。但在大型分布式应用中，系统间的RPC交互繁杂，一个功能背后要调用上百个接口并非不可能，从单机架构过渡到分布式微服务架构的通例

系统之间接口耦合严重
- 举个例子：如果系统A要发送数据给系统B和系统C，发送给每个系统的数据可能有差异，因此系统A对要发送给每个系统的数据进行了组装，然后逐一发送；
- 当代码上线后又新增了一个需求：把数据也发送给D，新上了一个D系统也要接受A系统的数据，此时就需要修改A系统，让他感知到D系统的存在，同时把数据处理好再给D。在这个过程你会看到，每接入一个下游系统，都要对系统A进行代码改造，开发联调的效率很低。
面对大流量并发时，容易被冲垮
- 每个接口模块的吞吐能力是有限的，这个上限能力如果是堤坝，当大流量（洪水）来临时，容易被冲垮。
- 举个例子秒杀业务：上游系统发起下单购买操作，我就是下单一个操作下游系统完成秒杀业务逻辑（读取订单，库存检查，库存冻结，余额检查，余额冻结，订单生产，余额扣减，库存减少，生成流水，余额解冻，库存解冻）
等待同步存在性能问题
- RPC接口上基本都是同步调用，整体的服务性能遵循“木桶理论”，即整体系统的耗时取决于链路中最慢的那个接口。比如A调用B/C/D都是50ms，但此时B又调用了B1，花费2000ms，那么直接就拖累了整个服务性能。

面向消息的中间件（message-oriented middleware）MOM能够很好的解决以上问题，是指利用高效可靠的消息传递机制与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。
通过提供消息传递和消息排队模型在分布式环境下提供应用解耦，弹性伸缩，冗余存储、流量削峰，异步通信，数据同步等功能。
- 发送者把消息发送给消息服务器，消息服务器将消息存放在若干队列/主题topic中，在合适的时候，消息服务器回将消息转发给接受者。在这个过程中，发送和接收是异步的，也就是发送无需等待，而且发送者和接受者的生命周期也没有必然的关系；
- 尤其在发布pub/订阅sub模式下，也可以完成一对多的通信，即让一个消息有多个接受者。
ActiveMQ 是 Apache 推出的一款 开源免费的，完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现的消息中间件（Message Oriented Middleware,MOM）

消息发送者可以发送一个消息而无须等待响应。消息发送者将消息发送到一条虚拟的通道（主题或者队列）上；
消息接收者则订阅或者监听该爱通道。一条消息可能最终转发给一个或者多个消息接收者，这些消息接收者都无需对消息发送者做出同步回应。整个过程都是异步的。
这样的一种通信方式，就是所谓的“异步”通信方式，对于系统A来说，只需要把消息发送给MQ，然后系统B就会异步的去进行处理了，系统A不需要“同步”的等待系统B处理完成。
- 这样的好处是解耦

一、ActiveMQ介绍-LMLPHP