xinglun 2020-06-02
以 apache-activemq-5.15.12-bin.tar.gz 为例,修改activemq.xml
在 <broker> 节点内的 <systemUsage> 节点前面新增如下xml片段:
<plugins> <simpleAuthenticationPlugin> <users> <authenticationUser username="gfstack" password="gfstack" groups="users, admins" /> </users> </simpleAuthenticationPlugin> </plugins>
重启activemq生效
代码修改:
在定义activemq连接池的时候添加用户密码信息即可,示例如下:
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN" "http://www.springframework.org/dtd/spring-beans-2.0.dtd"> <beans> <!-- 配置生产者连接池 --> <bean id="producerConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop"> <property name="connectionFactory"> <bean class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL"> <value>${activemq.url}</value> </property> <property name="userName"> <value>gfstack</value> </property> <property name="password"> <value>gfstack</value> </property> </bean> </property> <property name="maxConnections" value="${producer.maxConnections}"></property> <property name="maximumActiveSessionPerConnection" value="${producer.maximumActiveSessionPerConnection}"></property> <property name="idleTimeout" value="${producer.idleTimeout}"></property> </bean> <!-- 配置消费者连接池 --> <bean id="consumerConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop"> <property name="connectionFactory"> <bean class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL"> <value>${activemq.url}</value> </property> <property name="userName"> <value>gfstack</value> </property> <property name="password"> <value>gfstack</value> </property> </bean> </property> <property name="maxConnections" value="${consumer.maxConnections}"></property> <property name="maximumActiveSessionPerConnection" value="${consumer.maximumActiveSessionPerConnection}"></property> <property name="idleTimeout" value="${consumer.idleTimeout}"></property> </bean> </beans>