ActiveMQ配置入门教程

488次阅读

没有评论

共计 3522 个字符，预计需要花费 9 分钟才能阅读完成。

生产环境下，ActiveMQ 的必要配置。

配置 web 管理页面的安全认证

默认的 web 页面用户名密码 admin:admin, 非常不安全,

编辑 jetty-realm.properties 文件,(用户: 密码, 组)

admin: admin123, admin
user: user123, user

编辑 jetty.xml, 查找 WebConsolePort

<bean id=”jettyPort” class=”org.apache.activemq.web.WebConsolePort” init-method=”start”>
<!– the default port number for the web console –>
<property name=”host” value=”192.168.0.31“/>
<property name=”port” value=”8161“/>
</bean>

编辑 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 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>

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

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

<transportConnector name=”openwire” uri=”tcp://192.168.0.10:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600″/>

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

<bean id=”mysql-ds” class=”org.apache.commons.dbcp2.BasicDataSource” destroy-method=”close”>
<property name=”driverClassName” value=”com.mysql.jdbc.Driver” />
<property name=”url” value=”jdbc:mysql://192.168.0.20/activemq?relaxAutoCommit=true” />
<property name=”username” value=”activemq” />
<property name=”password” value=”123456” />
<property name=”poolPreparedStatements” value=”true” />
</bean>

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

<persistenceAdapter>
<!–<kahaDB directory=”${activemq.data}/kahadb”/>–>
<jdbcPersistenceAdapter dataDirectory=”activemq-data” dataSource=”#mysql-ds”/>
</persistenceAdapter>

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

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

官方参考文档‍‍‍‍

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