Java消息中间件---基础篇

学习慕课网java消息中间件记些笔记

1.概述

中间件 
非底层操作系统软件，非业务应用软件，不是直接给最终用户使用的，不能直接给客户带来价值的软件统称为中间件。 
消息中间件 
管制关注于数据的发送和接收，利用高效可靠的异步消息传递机制集成分布式系统。 
优点 
① 解耦 ② 异步 ③ 横向扩展 ④ 安全可靠 ⑤ 顺序保证（比如kafka） 
jms 
java消息服务(Java Message Service)即JMS，是一个Java平台中关于面向消息中间件的api，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信 
什么是AMQP 
AMQP(advanced message queuing protocol)是一个提供统一消息服务的应用层标准协议，基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同开发语言等条件的限制 
常见消息中间件 

activeMQ（支持多语言，实现jms1.1，j2ee1.4规范），RabbitMQ（支持更多语言，基于AMQP规范），kafka(高吞吐量，分布式，分区,O(1)磁盘顺序提供消息持久化) 

JMS消息模式 
队列模式 
客户端包括生产者和消费者 
队列中的消息只能被一个消费者消费 
消费者可以随时消费队列中的消息 
主题模式 
客户端包括发布者和订阅者 
主题中的消息被所有订阅者消费 
消费者不能消费订阅之前就发送到主题中的消息 
JMS编码接口 
ConnectionFactory 用于创建连接到消息中间件的连接工厂 
Connection 代表了应用程序和消息服务器之间的通信链路 
Destination 指消息发布和接收的地点，包括队列或主题 
Session 表示一个单线程的上下文，用于发送和接收消息 
MessageConsumer 由会话创建，用于接收发送到目标的消息 
MessageProducer 由会话创建，用于发送消息到目标 
Message 是在消费者和生产者之间传送的对象，消息头，一组消息属性，一个消息体 
流程 

2.安装activeMQ

官网 ： http://activemq.apache.org/ 
第一种启动 
进入bin ，activemq.bat 启动 
进入浏览器 http://127.0.0.1:8161 
用户名密码默认为admin 
第二种以服务启动 
InstallService.bat以管理员身份运行 
服务中有ActiveMQ 
linux 
解压压缩包 
进入bin 输入 activemq start，启动完成

3.jms 演示

创建maven项目 
添加依赖

4.使用spring集成jms链接activeMQ

ConnectionFactory 用于管理连接的工厂 
JmsTemplate 用于发送和接收消息的模板类 
MessageListerner 消息监听器

ConnectionFactory 是spring 为我们提供的连接池 
两种连接池SingleConnectionFactory 和 CachingConnectionFactory 
SingleConnectionFactory 是对于jms建立请求，只会返回一个连接 
CachingConnectionFactory 实现了SingleConnectionFactory 的所有功能，还提供了缓存

JmsTemplate spring提供，线程安全，可以使用JmsTemplate 操作jms

MessageListerner 实现onMessage方法，接收Message参数