activemq入门安装启动和配置文件简单讲解

activemq入门安装启动和配置文件简单讲解

1.下载activemq，这里以windows版本为例

下载官网：http://activemq.apache.org/activemq-5145-release.html

2.解压zip，进入conf目录找到核心配置文件activemq.xml

楼主这里会添加一点优化配置。与解压出来的xml略有不同，请看注释

<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> 
<!-- 使用系统属性作为变量 -->
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<value>file:${activemq.conf}/credentials.properties</value>
</property>
</bean>

<!-- 允许访问服务器日志 -->
<bean id="logQuery" class="io.fabric8.insight.log.log4j.Log4jLogQuery"
lazy-init="false" scope="singleton"
init-method="start" destroy-method="stop">
</bean>

<!-- 用于配置ActiveMQ代理 -->
<broker xmlns="http://activemq.apache.org/schema/core" brok
4000
erName="localhost" dataDirectory="${activemq.data}">

<!--此处，我们使用的是”>”通配符，上述配置为每个队列、每个Topic配置了一个最大2mb的队列，并且使用了”optimizedDispatch=true”这个策略，
该策略会启用优化了的消息分发器，直接减少消息来回时的上下文以加快消息分发速度。-->
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" >
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="50000"/>
</pendingMessageLimitStrategy>
</policyEntry>
<policyEntry queue=">" producerFlowControl="false" optimizedDispatch="true" memoryLimit="2mb">
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>

<!--managementContext用于配置如何暴露于ActiveMQ JMX。默认情况下,启动ActiveMQ使用MBean服务器JVM-->
<managementContext>
<managementContext createConnector="false"/>
</managementContext>

<!-- 为确保扩展配置既可以处理大量连接也可以处理海量消息队列,我们可以使用JDBC或更新更快的KahaDB消息存储。默认情况下ActiveMQ使用KahaDB消息存储。-->
<persistenceAdapter>
<kahaDB directory="${activemq.data}/kahadb"/>
</persistenceAdapter>
<!-- ActiveMQ支持三种持久化策略：AMQ、KAHADB、JDBC。-->

<!-- AMQ 它是一种文件存储形式，具有写入快、容易恢复的特点，采用这种方式持久化消息会被存储在一个个文件中，每个文件默认大小为32MB，如果一条消息超过32MB，那么这个值就需要设大。当一个文件中所有的消息被“消费”掉了，那么这文件会被置成“删除”标志，并且在下一个清除开始时被删除掉。-->

<!--KAHADB 相比AMQ来説，KAHADB速度没有AMQ快，可是KAHADB具有极强的垂直和横向扩展能力，恢复时间比AMQ还要短，因此从5.4版后ActiveMQ默认使用KAHADB作为其持久化存储。而且在作MQ的集群时使用KAHADB可以做到Cluster+Master Slave的这样的完美高可用集群方案。-->

<!-- JDBC
即ActiveMQ默认可以支持把数据持久化到DB中，如：MYSQL、ORACLE等。-->

<!-- ActiveMQ的内存配置 -->
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage percentOfJvmHeap="70" />
</memoryUsage>
<storeUsage>
<storeUsage limit="100 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="50 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>

<!-- 连接器协议和端口 -->
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>

<!-- 摧毁spring上下文在关闭停止jetty -->
<shutdownHooks>
<bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" />
</shutdownHooks>

</broker>

<import resource="jetty.xml"/>

</beans>

3.进入bin目录执行，windows64 执行InstallService.bat，安装成windows服务。

4.启动activemq.bat。如下图，然后访问

http://127.0.0.1:8161/admin/

默认用户名/密码为admin/admin





5.启动后的ActiveMQ的数据在data目录。

ActiveMQ运行日志：activemq.log

6.ActiveMQ的日志配置在conf目录下。（可以修改）

log4j.properties