现在的位置: 首页 > 综合 > 正文

初识ActiveMQ消息中间件

2013年11月06日 ⁄ 综合 ⁄ 共 1678字 ⁄ 字号 评论关闭

        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代码 :

                   

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

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

 

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

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

 

         

 

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

       前面说了它是Apahce开源项目,我们可以在这里进行下载

       http://activemq.apache.org/download.html解压即可。

 

        

 

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

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

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

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

 

        我们可以在管理控制台中创建一个消息队列:

       

 

         之后我们就可以用ActiveMQ做一个简单的实例。具体的代码就不贴出来了。提供一个下载地址:http://download.csdn.net/detail/lfsf802/5024430

         【有兴趣的朋友可以自行下载

抱歉!评论已关闭.