ActiveMQ-入门教程

时间:2020-02-23 14:37:36  来源:igfitidea点击:

什么是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

该目录用于存储日志文件和消息数据。