ActiveMQ菜鸟入门教程

2017-03-14 - 1559 Words - 2,778 Views - 0 Goods - Nothing

ActiveMQ是Apache的一个开源项目,它是一个能力强劲的开源消息总线,也是一个中间件产品。它是JMS的一个实现。
在介绍ActiveMQ之前,先来复习一下J2EE中的JMS规范。
JMS是Java Message Service的简称,用来发送异步消息,在不同系统和不同的模块之间我们可以利用它实现集成。
JMS有两个好处,第一个就是让模块之间或者系统之间的耦合度降低,第二个是异步通信。
JMS的消息机制有2种模型,一种是Point to Point,表现为队列的形式。发送的消息,只能被一个接收者取走;另一种是Topic,可以被多个订阅者订阅,类似于群发。

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

  • ConnectionFactory,用于jms client获取与jms provider的连接。不同的jms产品,对这个接口有不同的实现,比如说ActiveMQ,这个接口的实现类是ActiveMQConnectionFactory
  • Connection,是由ConnectionFactory产生的,表示jms client与jms provider的连接
  •  Session,是由Connection产生的,表示一个会话。Session是关键组件,Message、Producer/Consumer、Destination都是在Session上创建的
  •  Message,这个组件很好理解,就是传输的消息,里面包括head、properties、body,其中head是必选的
  •  Destination,是消息源,对发送者来说,就是消息发到哪里;对接收者来说,就是从哪里取消息。Destination有2个子接口,Queue和Topic,分别对应上面提到的2种模型
  • MessageProducer,是消息发送者,创建这个组件的代码类似:

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

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

ActiveMQ菜鸟入门教程

 

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

1.下载ActiveMQ

去官方网站下载:http://activemq.apache.org/

2.运行ActiveMQ

解压缩apache-activemq-5.5.1-bin.zip,然后双击apache-activemq-5.5.1binactivemq.bat运行ActiveMQ程序。

启动ActiveMQ以后,登陆:http://localhost:8161/admin/,创建一个Queue,命名为SongLiGuo_FirstQueue(如果这里创建了程序就不用创建)

3.创建Eclipse项目并运行

创建project:ActiveMQ-5.5,并导入apache-activemq-5.5.1lib目录下需要用到的jar文件,项目结构如下图所示:

ActiveMQ菜鸟入门教程

3.1.Sender.java

3.2.Receiver.java

4.注意事项

项目所引用的jar最后在ActiveMQ下的lib中找

5.测试结果

运行sender,在运行完sender以后,我们可以看到如下console
ActiveMQ菜鸟入门教程
我们再切换到receiver运行后的console,如下图所示:

ActiveMQ菜鸟入门教程

 

6.我们可以在http://localhost:8161/admin/queues.jsp看到消息发送和接收情况

ActiveMQ菜鸟入门教程

转载请注明原文链接:首页 -> 技术交流 -> JAVA开发 -> ActiveMQ菜鸟入门教程
  • 支付宝打赏
  • 微信打赏

China.BeiJing

如果说人生是自我编写的程序,那么青春就是其中意味深长的代码