ActiveMQ开启用户认证及消息持久化到数据库功能

1、开启用户认证机制

ActiveMQ默认是不开启用户认证机制的，如果需要开启则需要修改配置。

1. 首先打开activemq.xml，在broker下增加

<plugins>
<jaasAuthenticationPlugin configuration="activemq" />

<authorizationPlugin>
<map>
<authorizationMap>
<authorizationEntries>
<authorizationEntry queue=">" read="admins" write="admins" admin="admins" />
<authorizationEntry topic=">" read="admins" write="admins" admin="admins" />
</authorizationEntries>
</authorizationMap>
</map>
</authorizationPlugin>
</plugins>

authorizationEntry中配置队列（queue）或主题（topic）的read、write、admin分别需要什么角色。

>

表示统配。

2. 修改login.conf

activemq {
org.apache.activemq.jaas.PropertiesLoginModule required
org.apache.activemq.jaas.properties.user="users.properties"
org.apache.activemq.jaas.properties.group="groups.properties";
};

这里的activemq 要与

<jaasAuthenticationPlugin configuration="activemq" />

中configuration的值保持一致。

3. 修改users.properties

admin=admin

前面是用户名后面是密码

4. 修改groups.properties

admins=admin

前面是组名，后面是用户列表。多个用户之间用逗号分隔。

将消息持久化到数据库中

首先需要将mysql驱动、commons-dbcp、commons-pool这三个jar包放到activemq的lib目录下。

修改activemq.xml

<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#mysql-ds" useDatabaseLock="false"/>
</persistenceAdapter>

在broker外配置

<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://192.168.1.202:3306/activemq?relaxAutoCommit=true"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
<property name="maxActive" value="200"/>
<property name="poolPreparedStatements" value="true"/>
</bean>

然后创建数据库activemq。

修改mysql配置

[mysqld]
binlog_format=mixed