1.3开始使用ActiveMQ

开始使用ActiveMQ

    开始使用ActiveMQ并不难。你只要启动代理器并确保它能接受连接和发送消息。ActiveMQ有一些自带的例子能够帮你完成这个任务，不过首先你必须安装Java和下载ActiveMQ。

    在这部分，你将下载和安装Java SE，下载和安装ActiveMQ，检查ActiveMQ目录，然后第一次启动ActiveMQ。

 

1.3.1下载和安装Java SE

    ActiveMQ 要求Sun Java SE 1.5或以上。在开始这部分前，必须先安装。如果你没有，请从下面的地址下载并安装(for Linux,Solaris,Windows)。http://www.oracle.com/technetwork/java/javase/downloads/index.html.如果你是Mac OS X系统，你应该已经装有Java SE。如果没有，请从下面网址下载。URL: http://developer.apple.com/java/download/。

    一旦你安装完毕，你必须测试下是否安装正确。你可以打开一个终端或命令行输入下面的命令。

 最终的输出可能因你操作系统的不同而有的区别。这个命令告诉我们两件事：J2SE已正确安装，版本是1.6。如果你没有看见类似的输出，在进入下一步之前你必须使它正确。

 

下载和安装Ant

    Ant可以用来构建和运行ActiveMQ自带例子。Ant可以从Apache Ant网址下载。URL: http://ant.apache.org/
bindownload.cgi.

    点击链接地址并选择正确的压缩包。（tar包是Linux和Unix，zip是Windows）。请按照下列地址安装Ant。URL: http://ant.apache.org/manual/install.html。确保你设置好$ANT_HOME环境变量，并将$ANT_HOME/bin放到$PATH环境变量里。安装完毕后你可以运行下面的命令查看Ant版本。

$ ant -version
Apache Ant version 1.8.1 compiled on April 30 2010

你可能使用Ant的不同版本，不过这没关系。一旦Ant输出如上信息，你就可以确定Java SE和Ant都安装正确。

 

1.3.2下载ActiveMQ

    ActiveMQ可以从Apache ActiveMQ网站下，URL: http://activemq.apache.org/download.html.

    点击地址到5.4.1版本，你可以看到tar和zip格式包。（tar包是Linux和Unix，zip是Windows）。下载完后解压。当你做完这步时，你必须正确安装了Java SE。然后你就可以看一下ActiveMQ目录。

 

1.3.3检查ActiveMQ目录

    从命令行进入apache-activemq-5.4.1目录，输入如下命令。

 目录内容直白地显示了出来：

• LICENSE----Apache Software Foundation(ASF)要求的一个文件.包含ActiveMQ使用的所有库的许可证.
• NOTICE----ASF要求的另一个文件.包含ActiveMQ使用的所有库的版权信息.
• README.txt 一个包含一些URL的文档,使新手可以使用ActiveMQ.
• WebConsole-README.txt----包含使用ActiveMQ web console使用说明.
• activemq-all-5.4.1.jar---一个jar包包含ActiveMQ所有东西。放在这里是方便你使用它。
• bin----包含二进制或可运行文件。ActiveMQ启动脚本就放在里面。
• conf--ActiveMQ所有的配置信息。
• data--日志和持久化文件存储地方。
• docs--包含一个简单的index.html，该文件指向ActiveMQ网站。
• example----ActiveMQ例子。我们用这些例子来简单的测试ActiveMQ。
• lib----所有ActiveMQ所需库。
• user-guide.html----一个简单指引启动ActiveMQ和运行例子。
• webapps----ActiveMQ web console和一些网络演示。

下一部分将启动ActiveMQ并用这些例子验证它。

 

1.3.4启动ActiveMQ

    下载和解压后，ActiveMQ已经可以使用。二进制包提供一个基础的配置使你能够启动并运行我们将要用到的例子。所以请照下面运行ActiveMQ。

 

$ ./bin/activemq console
INFO: Using default configuration
(you can configure options in one of these file: /etc/default/activemq
/Users/bsnyder/.activemqrc)
INFO: Invoke the following command to create a configuration file
./bin/activemq setup [ /etc/default/activemq | /Users/bsnyder/.activemqrc ]
INFO: Using java '/System/Library/Frameworks/JavaVM.framework/Home/bin/java'
INFO: Starting in foreground, this is just for debugging purposes
(stop process by pressing CTRL+C)
Java Runtime: Apple Inc. 1.6.0_20
/System/Library/Frameworks/JavaVM.framework/Versions/1.6.0/Home
Heap sizes: current=258880k free=253105k max=258880k
JVM args: -Xms256M -Xmx256M
-Dorg.apache.activemq.UseDedicatedTaskRunner=true
-Djava.util.logging.config.file=logging.properties
-Dcom.sun.management.jmxremote
-Dactivemq.classpath=/Users/bsnyder/amq/apache-activemq-5.4.1/conf;
-Dactivemq.home=/Users/bsnyder/amq/apache-activemq-5.4.1
-Dactivemq.base=/Users/bsnyder/amq/apache-activemq-5.4.1
ACTIVEMQ_HOME: /Users/bsnyder/amq/apache-activemq-5.4.1
ACTIVEMQ_BASE: /Users/bsnyder/amq/apache-activemq-5.4.1
Loading message broker from: xbean:activemq.xml
WARN | destroyApplicationContextOnStop parameter is deprecated,
please use shutdown hooks instead
INFO | PListStore:/Users/bsnyder/amq/apache-activemq-5.4.1/data/localhost/
tmp_storage started INFO | Using Persistence Adapter:
KahaDBPersistenceAdapter[/Users/bsnyder/amq/apache-activemq-5.4.1/data/
kahadb]
INFO | KahaDB is version 2
INFO | Recovering from the journal ...
INFO | Recovery replayed 1 operations from the journal in 0.029 seconds.
INFO | ActiveMQ 5.4.1 JMS Message Broker (localhost) is starting
...
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:

INFO | Started SelectChannelConnector@0.0.0.0:8161

 

注意：这本书使用的例子是Mac OS X,一个Unix操作系统。对于Windows用户，不要用‘console’参数。应使用如下命令

C:\apache-activemq-5.4.1>bin\activemq

请注意在windows下启动activemq命令是不包含console的，这对本书的所有例子都一样。

 

刚才的命令启动了ActiveMQ代理器和一些连接器，使得客户端可以通过一些诸如TCP，SSL，STOMP，XMPP协议连接进来。请注意现在ActiveMQ已经启动，并且客户端可以通过TCP 61616端口连接进来。这些都是可以配置的，我们将在第4章讨论。现在，上面的输出说明了ActiveMQ已启动并可以使用。现在应用让它处理一些消息了。最好的方法是使用ActiveMQ自带的例子来发送和接收消息。下一部分将一步一步教你做。