阅读完需：约 10 分钟
知识点整理
1.java消息服务:
不同系统之间的信息交换，是我们开发中比较常见的场景，比如系统A要把数据发送给系统B，这个问题我们应该如何去处理？ 1999年，原来的SUN公司领衔提出了一种面向消息的中间件服务–JMS规范（标准）；常用的几种信息交互技术(httpClient、hessian、dubbo、jms、webservice 五种).
2.JMS概述:
JMS即Java消息服务（Java Message Service的简称），是Java EE 的标准/规范之一。这种规范（标准）指出：消息的发送应该是异步的、非阻塞的。也就是说消息的发送者发送完消息后就直接返回了，不需要等待接收者返回后才能返回，发送者和接收者可以说是互不影响。所以这种规范（标准）能够减轻或消除系统瓶颈，实现系统之间去除耦合，提高系统的整体可伸缩性和灵活性。JMS只是Java EE中定义的一组标准API，它自身并不是一个消息服务系统，它是消息传送服务的一个抽象，也就是说它定义了消息传送的接口而并没有具体实现。
3.ActiveMQ概述:
我们知道JMS只是消息服务的一组规范和接口，并没有具体的实现，而ActiveMQ就是JMS规范的具体实现；它是Apache下的一个项目，采用Java语言开发；是一款非常流行的开源消息服务器.
4.ActiveMQ与JMS关系:
我们知道，JMS只是定义了一组有关消息传送的规范和标准，并没有真正实现，也就说JMS只是定义了一组接口而已；就像JDBC抽象了关系数据库访问、JPA抽象了对象与关系数据库映射、JNDI抽象了命名目录服务访问一样，JMS具体的实现由不同的消息中间件厂商提供，比如Apache ActiveMQ就是JMS规范的具体实现，Apache ActiveMQ才是一个消息服务系统，而JMS不是。
5.ActiveMQ环境搭建
- ActiveMQ运行需要Java的支持，首先需要配置Java环境变量；
- 切换到解压后的activemq的bin目录下 cd /usr/local/apache-activemq-5.15.2 去启动
- 切换到bin目录下，启动：./activemq start ;关闭：./activemq stop
- 启动后有两个端口号，一个是web控制台:8161，一个是消息服务broker连接端口：61616
- web管理控制台admin URL地址：http://localhost:8161 默认登录账号 admin 密码 admin，注意：Linux防火前要关闭 ;通过这个地址可以即时访问交互信息.如下图:
- 消息服务broker URL地址 : tcp://localhost:61616
6.Java消息队列JMS整体设计结构
基本要素:1、生产者producer ; 2、消费者consumer ; 3、消息服务broker
JMS两种消息传送模式
- 点对点（ Point-to-Point）：专门用于使用队列Queue传送消息；基于队列Queue的点对点消息只能被一个消费者消费，如多个消费者都注册到同一个消息队列上，当生产者发送一条消息后，而只有其中一个消费者会接收到该消息，而不是所有消费者都能接收到该消息。
- 发布/订阅（Publish/Subscribe）：专门用于使用主题Topic传送消息。基于主题的发布与订阅消息能被多个消费者消费，生产者发送的消息，所有订阅了该topic的消费者都能接收到。
7.Java消息队列JMS API总体概览
- JMS API可以分为3个主要部分：
1、公共API：可用于向一个队列或主题发送消息或从其中接收消息；
2、点对点API：专门用于使用队列Queue传送消息；
3、发布/订阅API：专门用于使用主题Topic传送消息。
JMS公共API:
在JMS公共API内部，和发送与接收消息有关的JMS API接口主要是：ConnectionFactory/Connection/Session/Message/Destination/MessageProducer/MessageConsumer .
它们的关系是：一旦有了ConnectionFactory，就可以创建Connection，一旦有了Connection，就可以创建Session，而一旦有了Session，就可以创建Message、MessageProducer和MessageConsumer。
JMS点对点API:
点对点（p2p）消息传送模型API是指JMS API之内基于队列（Queue）的接口：QueueConnectionFactory/QueueConnection/QueueSession/Message/Queue/QueueSender/QueueReceiver. 从接口的命名可以看出，大多数接口名称仅仅是在公共API接口名称之前添加Queue一词。一般来说，使用点对点消息传送模型的应用程序将使用基于队列的API，而不使用公共API 。
JMS发布/订阅API:
发布/订阅消息传送模型API是指JMS API之内基于主题（Topic）的接口：TopicConnectionFactory/TopicConnection/
TopicSession/Message/Topic/TopicPublisher/TopicSubscriber. 由于基于主题（Topic）的JMS API类似于基于队列（Queue）的API，因此在大多数情况下，Queue这个词会由Topic取代。
8.ActiveMQ消息类型
1、TextMessage 文本消息：携带一个java.lang.String作为有效数据(负载)的消息，可用于字符串类型的信息交换；
2、ObjectMessage 对象消息：携带一个可以序列化的Java对象作为有效负载的消息，可用于Java对象类型的信息交换；
3、MapMessage 映射消息：携带一组键值对的数据作为有效负载的消息，有效数据值必须是Java原始数据类型（或者它们的包装类）及String。即：byte, short, int, long, float, double, char, boolean, String
4、BytesMessage 字节消息 ：携带一组原始数据类型的字节流作为有效负载的消息；
5、StreamMessage 流消息：携带一个原始数据类型流作为有效负载的消息，它保持了写入流时的数据类型，写入什么类型，则读取也需要是相同的类型；
9. ActiveMQ事务消息和非事务消息
消息分为事务消息和非事务消息
1、事务消息：创建会话Session使用transacted=true
connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
2、非事务消息：创建会话Session使用transacted=false
connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
事务消息必须在发送和接收完消息后显式地调用session.commit();
事务性消息，不管设置何种消息确认模式，都会自动被确认；与设置的确认机制无关,但官方推荐事务性消息使用事务确认机制.
10.ActiveMQ消息确认机制
消息只有在被确认之后，才认为已经被成功消费，然后消息才会从队列或主题中删除。消息的成功消费通常包含三个阶段：
(1)、客户接收消息；(2)、客户处理消息;(3)、消息被确认；
确认机制前面提过一下,共有四种:
(1)、Session.AUTO_ACKNOWLEDGE；客户（消费者）成功从receive方法返回时，或者从MessageListener.onMessage方法成功返回时，会话自动确认消息,然后自动删除消息.
(2)、Session.CLIENT_ACKNOWLEDGE；客户通过显式调用消息的acknowledge方法确认消息,。 即在接收端调用message.acknowledge();方法,否则,消息是不会被删除的.
(3)、Session. DUPS_OK_ACKNOWLEDGE ；不是必须确认，是一种“懒散的”消息确认，消息可能会重复发送，在第二次重新传送消息时，消息头的JMSRedelivered会被置为true标识当前消息已经传送过一次，客户端需要进行消息的重复处理控制。
(4)、 Session.SESSION_TRANSACTED；事务提交并确认。
11.ActiveMQ持久化消息与非持久化消息
messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);//不持久化
messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);//持久化的，当然activemq发送消息默认都是持久化的
说明:
设置完后,如果为持久化,那么消息在没有被消费前都会被写入本地磁盘kahadb文件中保存起来,即使服务器宕机,也不会影响
消息.如果是非持久化的,那么,服务一旦宕机之类的情况发生,消息即会被删除.
ActiveMQ默认是持久化的.
12.ActiveMQ消息过滤
ActiveMQ提供了一种机制，可根据消息选择器中的标准来执行消息过滤，只接收符合过滤标准的消息；
生产者可在消息中放入特有的标志，而消费者使用基于这些特定的标志来接收消息；
1、发送消息放入特殊标志：
message.setStringProperty(name, value);
2、接收消息使用基于特殊标志的消息选择器:
MessageConsumer createConsumer(Destination destination, String messageSelector);
注：消息选择器是一个字符串，语法与数据库的SQL相似，相当于SQL语句where条件后面的内容；
13. ActiveMQ消息接收方式
同步接收:receive()方法接收消息叫同步接收,在不使用循环方法时接收端代码执行一次即结束.
异步接收:使用监听器接收消息，这种接收方式叫异步接收,接收端会一直处于监听状态,只要有消息产生,即会接收消息.
更详细的内容：
