ActiveMQ的安装及实例运行
本文主要介绍了ActiveMQ在Window OS上的安装以及安装完成后的运行实例。
一、安装过程
1、 下载ActiveMQ
在http://activemq.apache.org/download.html 上下载对应版本及OS的ActiveMQ。目前最新的版本是ActiveMQ5.3.1。
2、 安装前的准备
a、 首先确保已经安装了Jdk，并设置%JAVA_HOME%环境变量；
b、 安装ant编译环境，并设置%ANT_HOME%环境变量；
3、 将下载的ActiveMQ解压后安装放置在本地磁盘，本文放在D：/activemq下面。
4、 设置环境变量
在完成上述操作后，需要设置环境变量%ACMQ_HOME%。
至此，该ActiveMQ已经安装完成。
二、安装检验
在经过上述安装过程后，为了确保可以正常运行，通过如下的方式进行检验。
在ActiveMQ的安装目录下
$cd bin
$activemq
出现如下信息，即表明该ActiveMQ服务器已经成功启动。
Loading message broker from: xbean:activemq.xml
INFO | Using Persistence Adapter: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter@19fe451
INFO | Replayed 1 operations from the journal in 0.015 seconds.
INFO | ActiveMQ 5.3.0 JMS Message Broker (localhost) is starting
INFO | For help or more information please see: http://activemq.apache.org/
INFO | Listening for connections at: tcp://0.0.0.0:61616
INFO | Connector openwire Started
INFO | ActiveMQ JMS Message Broker (localhost, ID:zaniel-zhao--4547-1269405003937-0:0) started
INFO | Logging to org.slf4j.impl.JCLLoggerAdapter(org.mortbay.log) via org.mortbay.log.Slf4jLog
INFO | jetty-6.1.9
INFO | ActiveMQ WebConsole initialized.
INFO | Initializing Spring FrameworkServlet 'dispatcher'
INFO | ActiveMQ Console at http://0.0.0.0:8161/admin
INFO | Initializing Spring root WebApplicationContext
INFO | Connector vm://localhost Started
INFO | Camel Console at http://0.0.0.0:8161/camel
INFO | ActiveMQ Web Demos at http://0.0.0.0:8161/demo
INFO | RESTful file access application at http://0.0.0.0:8161/fileserver
INFO | Started SelectChannelConnector@0.0.0.0:8161
INFO | Kaha Store using data directory D:/activemq/bin/../data/localhost/tmp_storage
INFO | Slow KahaDB access: cleanup took 1063
INFO | Slow KahaDB access: cleanup took 1234
在example目录下运行如下命令：
$cd example
$ant consumer
在运行该命令后会出现如下信息，表明消息者客户端已经建立。
consumer:
[echo] Running consumer against server at $url = tcp://localhost:61616 for subject $subject = TEST.FOO
[java] Connecting to URL: tcp://localhost:61616
[java] Consuming queue: TEST.FOO
[java] Using a non-durable subscription
[java] We are about to wait until we consume: 2000 message(s) then we will shutdown
在另一个控制台上运行如下命令：
$ant producer
运行该命令后会出现向队列中发送消息，而且消费者控制台上会有消息不断输出，即表明该MQ已经成功安装，而且实例运行正确。
当然也可以运行如下的命令：
$ ant producer –Durl=tcp://127.0.0.1:61616
jopen 
jerry_shang 