java消息中间件

为什么要使用消息中间件

传统的消息传递,只能从应用端将消息发送到接受端,问题是当接受端宕机或出现错误,不在接受消息造成消息的丢失.为了避免这种情况的发生采用消息中间件

采用后如图下:

消息中间件给我们带来的好处

解耦:
异步:
横向扩展:当一台服务器处理不过来消息时,可以采用增加服务器方式 消费消息
安全可靠:消息不会丢失
顺序保证:

概述

中间件:非底层操作系统,非业务应用软件,不是直接给最终用户使用的,不能直接给客户带来价值的软件统称为中间件.
消息中间件:关注数据的发送和接受,利用高效可靠的异步消息传递机制集成的分布式系统

JMS介绍
Java消息服务(Java Message Service)即JMS,是一个Java平台中关于面向消息中间件的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信.
AMQP
AMQP是一个体统消息服务的应用层表中协议,基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同开发语言等条件的限制.

常见的消息中间件

JMS消息模式

队列模型

客户端包括生产者和消费者
队列中的消息只能被一个消费者消费
消费者可以随时消费队列中的消息

主题模型

客户端包括发布者和订阅者
主题中的消息被所有订阅者消费
消费者不能订阅之前就发送到主题中的消息

JMS规范

ConnectionFactory用于创建连接到消息中间件的连接工厂
Connection代表了应用程序和消息服务器之间的通信链条
Destination指消息发布和接受的地点,包括队列或主题
Session 表示一个单线程的上下文,用于发送和接收消息
MessageConsumer由会话创建,用于接收发送到目标的消息
MessageProducer由会话创建,用于发送消息到目标
Message是在消费者和生产者之间传送的对象,消息通,一组消息属性,一个消息体.

链接工厂—>创建链接—>创建一次会话

会话–>创建生产者将消息发送到目的地

会话–>会话创建消费者到目的地取消息