Java基础知识：初识ActiveMQ消息中间件

ActiveMQ是Apache的一个开源项目，它是一个能力强劲的开源消息总线，也是一个中间件产品。它是JMS的一个实现。

        在介绍ActiveMQ之前，先来复习一下J2EE中的JMS规范。

        JMS是java Message Service的简称，用来发送异步消息，在不同系统和不同的模块之间我们可以利用它实现集成。

        JMS有两个好处，第一个就是让模块之间或者系统之间的耦合度降低，第二个是异步通信。

        JMS的消息机制有2种模型，一种是Point to Point，表现为队列的形式。发送的消息，只能被一个接收者取走；另一种是Topic，可以被多个订阅者订阅，类似于群发。

        在JMS中有这样几个重要的核心接口和类：

       1. ConnectionFactory，用于jms client获取与jms provider的连接。不同的jms产品，对这个接口有不同的实现，比如说ActiveMQ，这个接口的实现类是ActiveMQConnectionFactory

       2. Connection，是由ConnectionFactory产生的，表示jms client与jms provider的连接

       3. Session，是由Connection产生的，表示一个会话。Session是关键组件，Message、Producer/Consumer、Destination都是在Session上创建的

      4. Message，这个组件很好理解，就是传输的消息，里面包括head、properties、body，其中head是必选的

      5. Destination，是消息源，对发送者来说，就是消息发到哪里；对接收者来说，就是从哪里取消息。Destination有2个子接口，Queue和Topic，分别对应上面提到的2种模型

      6. MessageProducer，是消息发送者，创建这个组件的代码类似：

             Java代码 :

[java]  

Destination dest =session.createQueue("dotaQueue");// 消息目的地    

MessageProducer producer =session.createProducer(dest);// 消息发送者    

        可以注意到，这里需要把Destination作为参数，传入createProducer()方法，这说明消息发送者是绑定到Destination上的，这个发送者发送的消息，会发送到这个绑定的Destination上

       7. MessageConsumer，是消息接收者，和Message Producer是相反的一种组件    

     对JMD有所了解之后，我们来看ActiveMQ。

        运行bin目录下的activemq.bat启动mq，mq会占用至少2个端口，默认的是61616和8161

        61616是等待jms client的连接，8161是ActiveMQ自带的一个web应用

        localhost:8161/demo，可以看到各种官方提供的例子

        localhost:8161/admin，是ActiveMQ的管理控制台