本篇文章探讨了JAVA从入门到精通之实战Spring4+ActiveMQ5整合实现消息队列(生产者+消费者)，希望阅读本篇文章以后大家有所收获，帮助大家对相关内容的理解更加深入。

     最近公司做了一个以信息安全为主的项目，其中有一个业务需求就是，项目定时监控操作用户的行为，对于一些违规操作严重的行为，以发送邮件(FoxMail)的形式进行邮件告警，可能是多人，也可能是一个人，第一次是以单人的形式，,直接在业务层需要告警的地方发送邮件即可，可是后边需求变更了，对于某些告警邮件可能会发送多人，这其中可能就会有阻塞发邮件的可能，直到把所有邮件发送完毕后再继续做下边的业务，领导说这样会影响用户体验，发邮件的时候用户一直处于等待状态，不能干别的事情。最后研究说用消息队列，当有需要发送邮件告警的时候,就向队列中添加一个标识消息，ActiveMQ通过监听器的形式，实时监听队列里边的小时，收到消息后，判断是不是需要发送告警的标识，是的话就自行就行发送邮件！这是就研究的消息队列ActiveMQ,下边就是具体内容：

1.ActiveMQ

   1.1). ActiveMQ

         ActiveMQ是Apache所提供的一个开源的消息系统，完全采用Java来实现，因此，它能很好地支持J2EE提出的JMS（Java Message Service,即Java消息服务）规范。JMS是一组Java应用程序接口，它提供消息的创建、发送、读取等一系列服务。JMS提供了一组公共应用程序接口和响应的语法，类似于Java数据库的统一访问接口JDBC,它是一种与厂商无关的API，使得Java程序能够与不同厂商的消息组件很好地进行通信。

   1. 2). Java Message Service(JMS)

      JMS支持两种消息发送和接收模型。

• 一种称为P2P(Ponit to Point)模型(点对点一对一)，即采用点对点的方式发送消息。P2P模型是基于队列的，消息生产者发送消息到队列，消息消费者从队列中接收消息，队列的存在使得消息的异步传输称为可能，P2P模型在点对点的情况下进行消息传递时采用。

• 另一种称为Pub/Sub(Publish/Subscribe，即发布-订阅)模型，发布-订阅模型定义了如何向一个内容节点发布和订阅消息，这个内容节点称为topic(主题)。主题可以认为是消息传递的中介，消息发布这将消息发布到某个主题，而消息订阅者则从主题订阅消息。主题使得消息的订阅者与消息的发布者互相保持独立，不需要进行接触即可保证消息的传递，发布-订阅模型在消息的一对多广播时采用。

    1.3). JMS术语

• Provider/MessageProvider：生产者

• Consumer/MessageConsumer：消费者

• PTP：Point To Point，点对点通信消息模型

• Pub/Sub：Publish/Subscribe，发布订阅消息模型

• Queue：队列，目标类型之一，和PTP结合

• Topic：主题，目标类型之一，和Pub/Sub结合

• ConnectionFactory：连接工厂，JMS用它创建连接

• Connnection：JMS Client到JMS Provider的连接

• Destination：消息目的地，由Session创建

• Session：会话，由Connection创建，实质上就是发送、接受消息的一个线程，因此生产者、消费者都是Session创建的

   1.4).ActiveMQ应用场景

　　类似送快递，快递员（producer）将快递（Message）放到指定地点（destination）后，就可以离开了，拿快递的人（customer）在接收到通知后，到指定地点（destination）去取快递（Message）就可以了。当然，取快递时可能要进行身份验证，这就涉及到创建连接（connection）时，需要指定用户名和密码了。还有就是，实际生活中，当快递员把快递放好之后，照理说应该通知客户去哪里取快递，而ActiveMq帮我们做好了一切，通知的工作Activemq会帮我们实现，而无需我们亲自编码通知消费者，生产者只需要将Message放到Mq中即可，通知消费者的工作，mq会帮我们处理

        用途就是用来处理消息，也就是处理JMS的。消息队列在大型电子商务类网站，如京东、淘宝、去哪儿等网站有着深入的应用，队列的主要作用是消除高并发访问高峰，加快网站的响应速度。

      在不使用消息队列的情况下，用户的请求数据直接写入数据库，高发的情况下，会对数据库造成巨大的压力，同时也使得系统响应延迟加剧，但使用队列后，用户的请求发给队列后立即返回。

    1.5).ActiveMQ下载

      1.6). 启动

/apache-activemq-5.15.3/bin/win64/目录下双击activemq.bat文件，在浏览器中输入//localhost:8161/admin/, 用户名和密码输入admin即可

2.Srping+ActiveMQ应用实例

   2,1). 项目结构

      2,2). 导入maven依赖,pom.xml文件

  1   2   4   4.0.0  5   6   www.cnblogs.com.hongmoshu  7   test_actmq  8   0.0.1-SNAPSHOT  9   war 10   test_actmq Maven Webapp 11   //www.example.com 12    13     14    15     4.1.8.RELEASE 16    17   18  19     20     21       22      23       junit 24       junit 25       4.11 26       test 27      28      29      30    31     jstl 32     jstl 33     1.2 34    35    36     javax.servlet 37     servlet-api 38     provided 39     2.5 40    41  42       43      44       org.springframework 45       spring-core 46       ${springframework} 47      48      49       org.springframework 50       spring-context 51       ${springframework} 52      53      54       org.springframework 55       spring-tx 56       ${springframework} 57      58      59       org.springframework 60       spring-webmvc 61       ${springframework} 62      63      64       org.springframework 65       spring-jms 66       ${springframework} 67      68      69      --> 70      71       org.apache.xbean 72       xbean-spring 73       3.16 74      75      76      77      78       org.apache.activemq 79       activemq-core 80       5.7.0 81      82      83       org.apache.activemq 84       activemq-pool 85       5.12.1 86      87      88      89      90       com.google.code.gson 91       gson 92       1.7.1 93      94      95        96      97         net.sf.json-lib 98         json-lib 99         2.4100         jdk15101     102     103   104 105   106     test_actmq107   108   109

     2,3). ActiveMQ的配置文件ActiveMQ.xml

 1 <?xml version=""1.0"" encoding=""UTF-8""?> 2 <beans xmlns=""//www.springframework.org/schema/beans"" 3        xmlns:xsi=""//www.w3.org/2001/XMLSchema-instance"" 4        xmlns:amq=""//activemq.apache.org/schema/core"" 5        xmlns:jms=""//www.springframework.org/schema/jms"" 6        xmlns:context=""//www.springframework.org/schema/context"" 7        xmlns:mvc=""//www.springframework.org/schema/mvc"" 8        xsi:schemaLocation="" 9         //www.springframework.org/schema/beans10         //www.springframework.org/schema/beans/s"
      本文由职坐标整理发布，学习更多的相关知识，请关注职坐标IT知识库！