ActiveMQ-入门教程
什么是Apache ActiveMQ?
Apache ActiveMQ是最流行,功能最强大的开源消息传递和集成模式服务器。
在开始之前,我们将需要安装Java和ActiveMQ。
在Unix/Linux/MacOSX/macOS系统上安装
步骤1:安装Java SE
需要Java SE 1.6或者更高版本。
点击这里下载。
一旦安装了Java SE,您可以通过打开Terminal并执行以下命令来检查它的设置是否正确。
$java -version
您将看到以下输出
java version "1.8.0_102" Java(TM) SE Runtime Environment (build 1.8.0_102-b14) Java HotSpot(TM) 64-Bit Server VM (build 25.102-b14, mixed mode)
输出将根据安装的版本而有所不同。
需要注意的重要一点是,在上述情况下,已安装Java SE,其版本为1.8。
步骤2:安装ActiveMQ
从Apache ActiveMQ下载并安装ActiveMQ。
点击这里下载。
获取稳定版本。
对于Unix/Linux/Cygwin发行版,请下载apache-activemq-5.14.3-bin.tar.gz或者最新版本。
下载后解压缩文件。
样品路径
/Users/yusufshakeel/Documents/apache-activemq-5.14.3
可选步骤:安装Apache Ant
Apache Ant是帮助构建软件的Java库和命令行工具。
如果要构建和测试ActiveMQ附带的示例,则需要Apache Ant。
点击这里下载。
Apache Ant v1.9.x在运行时需要Java5。
虽然v1.10.x在运行时需要Java8。
对于Unix/Linux/Mac发行版,请下载apache-ant-1.10.1-bin.tar.bz2或者最新版本。
下载后解压缩文件。
样品路径
/Users/yusufshakeel/Documents/apache-ant-1.10.1
最后,确保设置$ANT_HOME环境变量并将其放入$PATH环境变量中。
打开终端并输入以下命令
$cd
现在使用vi命令打开.bash_profile
$vi .bash_profile
现在,在文件内部添加以下行。
按I键进入INSERT模式。
#Apache Ant export ANT_HOME=/Users/yusufshakeel/Documents/apache-ant-1.10.1 #Export to PATH export PATH=$ANT_HOME/bin:$PATH
PATH可能包含其他一些值。
进行更改时要小心。
完成后,按ESC键并输入:wq并按Enter
现在,通过在终端中执行以下命令来检查Ant是否已正确安装。
$ant -version Apache Ant(TM) version 1.10.1 compiled on February 2 2016
Ant版本可能取决于下载的版本。
ActiveMQ文件夹的内容
如何启动ActiveMQ?
重要文件/目录
检查ActiveMQ状态
activemq-all-5.14.3.jar
此jar文件包含所有ActiveMQ。
$cd /Users/yusufshakeel/Documents/apache-activemq-5.14.3 $./bin/activemq console
箱子
如何停止ActiveMQ?
此目录包含所有二进制/可执行文件。
conf
此目录包含ActiveMQ的与配置相关的文件。
数据
INFO: Loading '/Users/yusufshakeel/Documents/apache-activemq-5.14.3//bin/env' INFO: Using java '/usr/bin/java' INFO: Starting in foreground, this is just for debugging purposes (stop process by pressing CTRL+C) INFO: Creating pidfile /Users/yusufshakeel/Documents/apache-activemq-5.14.3//data/activemq.pid Java Runtime: Oracle Corporation 1.8.0_102 /Library/Java/JavaVirtualMachines/jdk1.8.0_102.jdk/Contents/Home/jre Heap sizes: current=62976k free=60026k max=932352k JVM args: -Xms64M -Xmx1G -Djava.util.logging.config.file=logging.properties -Djava.security.auth.login.config=/Users/yusufshakeel/Documents/apache-activemq-5.14.3//conf/login.config -Dcom.sun.management.jmxremote -Djava.awt.headless=true -Djava.io.tmpdir=/Users/yusufshakeel/Documents/apache-activemq-5.14.3//tmp -Dactivemq.classpath=/Users/yusufshakeel/Documents/apache-activemq-5.14.3//conf:/Users/yusufshakeel/Documents/apache-activemq-5.14.3//../lib/: -Dactivemq.home=/Users/yusufshakeel/Documents/apache-activemq-5.14.3/-Dactivemq.base=/Users/yusufshakeel/Documents/apache-activemq-5.14.3/-Dactivemq.conf=/Users/yusufshakeel/Documents/apache-activemq-5.14.3//conf -Dactivemq.data=/Users/yusufshakeel/Documents/apache-activemq-5.14.3//data Extensions classpath: [/Users/yusufshakeel/Documents/apache-activemq-5.14.3/lib,/Users/yusufshakeel/Documents/apache-activemq-5.14.3/lib/camel,/Users/yusufshakeel/Documents/apache-activemq-5.14.3/lib/optional,/Users/yusufshakeel/Documents/apache-activemq-5.14.3/lib/web,/Users/yusufshakeel/Documents/apache-activemq-5.14.3/lib/extra] ACTIVEMQ_HOME: /Users/yusufshakeel/Documents/apache-activemq-5.14.3 ACTIVEMQ_BASE: /Users/yusufshakeel/Documents/apache-activemq-5.14.3 ACTIVEMQ_CONF: /Users/yusufshakeel/Documents/apache-activemq-5.14.3/conf ACTIVEMQ_DATA: /Users/yusufshakeel/Documents/apache-activemq-5.14.3/data Loading message broker from: xbean:activemq.xml INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory@28feb3fa: startup date [Tue Nov 14 19:46:22 IST 2016]; root of context hierarchy INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[/Users/yusufshakeel/Documents/apache-activemq-5.14.3/data/kahadb] INFO | PListStore:[/Users/yusufshakeel/Documents/apache-activemq-5.14.3/data/localhost/tmp_storage] started INFO | Apache ActiveMQ 5.14.3 (localhost, ID:YUSUF-MacBook-Pro.local-58262-1487081799213-0:1) is starting INFO | Listening for connections at: tcp://YUSUF-MacBook-Pro.local:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector openwire started INFO | Listening for connections at: amqp://YUSUF-MacBook-Pro.local:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector amqp started INFO | Listening for connections at: stomp://YUSUF-MacBook-Pro.local:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector stomp started INFO | Listening for connections at: mqtt://YUSUF-MacBook-Pro.local:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector mqtt started WARN | [email protected]@3e6f3f28{/,null,STARTING} has uncovered http methods for path: / INFO | Listening for connections at ws://YUSUF-MacBook-Pro.local:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector ws started INFO | Apache ActiveMQ 5.14.3 (localhost, ID:YUSUF-MacBook-Pro.local-58262-1487081799213-0:1) started INFO | For help or more information please see: http://activemq.apache.org INFO | No Spring WebApplicationInitializer types detected on classpath INFO | ActiveMQ WebConsole available at http://0.0.0.0:8161/ INFO | ActiveMQ Jolokia REST API available at http://0.0.0.0:8161/api/jolokia/ INFO | Initializing Spring FrameworkServlet 'dispatcher' INFO | No Spring WebApplicationInitializer types detected on classpath INFO | jolokia-agent: Using policy access restrictor classpath:/jolokia-access.xml
该目录用于存储日志文件和消息数据。