JMS消息代理

    JMS（Java Messaging Service）即Java消息服务，是Java平台上有关面向消息中间件的技术规范，它便于消息系统中的Java应用程序进行消息交换，并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发。

1．JMS元素

1）JMS消息代理实现

连接面向消息中间件的，JMS消息代理接口的一个实现。JMS的消息代理实现可以是Java平台的JMS实现，也可以是非Java平台的面向消息中间件的适配器。开源的JMS实现有Apache ActiveMQ、JBoss 社区所研发的 HornetQ、The OpenJMS Group的OpenJMS等等实现。

2）JMS客户

生产或消费基于消息的Java应用程序或对象。

3）JMS生产者

创建并发送消息的JMS客户。

4）JMS消费者

接收消息的JMS客户。

5）JMS消息

包括可以在JMS客户之间传递的数据对象。

6）JMS队列

一个容纳那些被发送的等待阅读的消息区域。

7）JMS主题

一种支持发送消息给多个订阅者的机制。

2．JMS的应用接口

1）ConnectionFactory接口（连接工厂）

    用户用来创建到JMS消息代理实现的连接的被管对象。

2）Connection 接口（连接）

    连接代表了应用程序和消息服务器之间的通信链路。

3）Destination接口（目的地）

目的地是一个包装了消息目的地标识符的被管对象，消息目的地是指消息发布和接收的地点，或者是队列，或者是主题。JMS管理员创建这些对象，可以创建两种类型的目的地，点对点模型的队列，以及发布者/订阅者模型的主题。

4）Session接口（会话）

    表示一个单线程的上下文，用于发送和接收消息。

5）MessageConsumer接口（消息消费者）

由会话创建的对象，用于接收发送到目的地的消息。

6）MessageProducer接口（消息生产者）

由会话创建的对象，用于发送消息到目的地。

7）Message接口（消息）

是在消费者和生产者之间传送的对象，也就是说从一个应用程序传送到另一个应用程序。一个消息有三个主要部分：

一、ActiveMQ安装与实例

本节我们使用JMS的一种实现ActiveMQ讲解JMS实例。因此，需要事先安装ActiveMQ（注意需要安装jdk）。读者可访问http://activemq.apache.org/下载符合自己的ActiveMQ，Windows版本的apache-activemq-5.16.5-bin.zip。该版本的ActiveMQ，解压缩即可完成安装。

    解压缩后，双击“apache-activemq-5.16.5\bin\win64”下的“wrapper.exe”或“activemq.bat”启动ActiveMQ，如图8.4所示。然后，通过“http://localhost:8161”运行ActiveMQ的管理界面，管理员账号和密码默认为admin/admin，如图8.5所示。

  JMS的自动配置

    Spring Boot对JMS的自动配置位于org.springframework.boot.autoconfigure.jms包下，支持JMS的实现有ActiveMQ和Artemis。

以ActiveMQ为例，Spring Boot为我们定义了ActiveMQConnectionFactory的Bean作为连接，并通过以“spring.activemq”为前缀的属性配置ActiveMQ的连接属性，主要包含：

spring.activemq.broker-url= tcp://localhost:61616

spring.activemq.user=

spring.activemq.password=

spring.activemq.in-memory=true

另外，Spring Boot在JmsAutoConfiguration自动配置类中为我们配置了JmsTemplate；并且在JmsAnnotationDrivenConfiguration配置类中，为我们开启了注解式消息监听的支持，即自动开启@EnableJms。

【例8-1】使用JMS的实现ActiveMQ进行两个应用系统间的点对点式通信。

1．创建基于Apache ActiveMQ5的Spring Boot应用

ch8_1Sender（消息发送者）

2．配置ActiveMQ的消息代理地址

3．定义消息

4．发送消息

5．创建消息接收者（ch8_1Receive）

6．定义消息监听器接收消息

7．运行测试

ActiveMQ安装视频