ActiveMQ配置入门教程

admin: admin123, admin

user: user123, user

配置web管理页面的绑定IP和端口

编辑jetty.xml,查找WebConsolePort

<bean init-method="start">

<!-- the default port number for the web console -->

<property value="192.168.0.31"/>

<property value="8161"/>

</bean>

配置MQ连接的安全认证

编辑activemq.xml,在<broker>下加

<plugins>

<simpleAuthenticationPlugin>

<users>

<authenticationUser username="user" password="user123" groups="users" />

</users>

</simpleAuthenticationPlugin>

</plugins>

禁用不使用的连接协议

编辑activemq.xml,在<transportConnectors>中注销或删除不使用的<transportConnector>

<transportConnectors>

<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->

<transportConnector uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<!--<transportConnector uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<transportConnector uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<transportConnector uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

<transportConnector uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>-->

</transportConnectors>

上面我只保留了61616的openwire协议端口

绑定协议连接端口到指定IP

编辑activemq.xml,在<transportConnectors>下找到指定协议的配置,并修改0.0.0.0为要绑定的ip

<transportConnector uri="tcp://192.168.0.10:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

使用MySql作为持久化保存

编辑activemq.xml,在<beans>下插入如下bean配置

<bean destroy-method="close">

<property value="com.mysql.jdbc.Driver" />

<property value="jdbc:mysql://192.168.0.20/activemq?relaxAutoCommit=true" />

<property value="activemq" />

<property value="123456" />

<property value="true" />

</bean>

删除或注销掉<persistenceAdapter>下的<kahaD>,添加<jdbcPersistenceAdapter>

<persistenceAdapter>

<!--<kahaDB directory="${activemq.data}/kahadb"/>-->

<jdbcPersistenceAdapter dataDirectory="activemq-data" dataSource="#mysql-ds"/>

</persistenceAdapter>

配置基于JDBC的高可用环境

两个以上activemq使用一样的db配置,

‍‍‍‍客户端连接url为failover:(tcp://broker1:61616,tcp://broker2:61616)

官方参考文档‍‍‍‍

修改内存

linux下,修改bin/env的ACTIVEMQ_OPTS_MEMORY属性,Xms=最小内存,Xmx=最大内存

ACTIVEMQ_OPTS_MEMORY="-Xms64M -Xmx1G"

window下,修改activemq.bat,在 if "%ACTIVEMQ_OPTS%" == " 前设置

set ACTIVEMQ_OPTS=-Xms1G -Xmx1G

注册为Service

linux(RedHat,CentOS)下(),运行以下命令注册为service,并设置为开机自动启动

ln -snf bin/activemq /etc/init.d/activemq
chkconfig --add activemq
chkconfig activemq on

然后就可以使用如下service命令了

service activemq start|stop|status|restart

推荐阅读：

Spring+Log4j+ActiveMQ实现远程记录日志——实战+分析

Spring下ActiveMQ实战 

Linux系统下ActiveMQ 安装

Ubuntu下的ACTIVEMQ服务器

CentOS 6.5启动ActiveMQ报错解决

Spring+JMS+ActiveMQ+Tomcat实现消息服务

Linux环境下面ActiveMQ端口号设置和WEB端口号设置