Spring Boot ActiveMQ如何设置访问密码

Spring Boot ActiveMQ如何设置访问密码

Apache ActiveMQ是Apache出品，是最流行的，能力很强的开源消息总线。默认情况下，程序连接ActiveMQ是不需要密码的，为了安装起见，需要设置密码，提高安全性。本文分享如何设置访问ActiveMQ的账号密码。

使用的ActiveMQ版本是apache-activemq-5.15.13。

一、设置控制台管理密码

ActiveMQ使用的是jetty服务器，找到 ActiveMQ安装目录下的\conf\jetty.xml文件：

注意：authenticate的属性默认为"true"，登录管理界面时需要输入账户和密码；如果是“false”，需要改为"true"。

修改管理界面登录时的用户名和密码，在conf/jetty-realm.properties文件中添加用户

## ---------------------------------------------------------------------------

## Licensed to the Apache Software Foundation (ASF) under one or more

## contributor license agreements. See the NOTICE file distributed with

## this work for additional information regarding copyright ownership.

## The ASF licenses this file to You under the Apache License, Version 2.0

## (the "License"); you may not use this file except in compliance with

## the License. You may obtain a copy of the License at

##

## http://apache.org/licenses/LICENSE-2.0

##

## Unless required by applicable law or agreed to in writing, software

## distributed under the License is distributed on an "AS IS" BASIS,

## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

## See the License for the specific language governing permissions and

## limitations under the License.

## ---------------------------------------------------------------------------

# Defines users that can access the web (console, demo, etc.)

# username: password [,rolename ...]

# admin: admin, admin

# user: user, user

wiener: wiener1237, admin

配置信息按顺序解释，分别是：用户名、密码、角色名

二、消息生产者和消费者密码认证

在\conf\activemq.xml中broker 标签最后添加生产者和消费者密码认证信息：

activemq.username和activemq.password的值在文件credentials.properties中配置，见如下步骤。

设置用户名密码，文件在\conf\credentials.properties

## ---------------------------------------------------------------------------

## Licensed to the Apache Software Foundation (ASF) under one or more

## contributor license agreements. See the NOTICE file distributed with

## this work for additional information regarding copyright ownership.

## The ASF licenses this file to You under the Apache License, Version 2.0

## (the "License"); you may not use this file except in compliance with

## the License. You may obtain a copy of the License at

##

## http://apache.org/licenses/LICENSE-2.0

##

## Unless required by applicable law or agreed to in writing, software

## distributed under the License is distributed on an "AS IS" BASIS,

## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

## See the License for the specific language governing permissions and

## limitations under the License.

## ---------------------------------------------------------------------------

# Defines credentials that will be used by components (like web console) to access the broker

# activemq.username=system

# activemq.password=manager

# guest.password=password

activemq.username=wiener

activemq.password=wiener1237

guest.password=password

三、java端配置用户名密码

验证代码是在《【Spring Boot】ActiveMQ 发布/订阅消息模式介绍》的基础上做重构，除了新增类ActiveMQConfig之外，修改部分均用红色字体标注。配置application.properties连接信息：

## URL of the ActiveMQ broker. Auto-generated by default. For instance `tcp://localhost:61616`

# failover:(tcp://localhost:61616,tcp://localhost:61617)

# tcp://localhost:61616

spring.activemq.broker-url=tcp://localhost:61616

spring.activemq.in-memory=true

spring.activemq.pool.enabled=false

#默认值false，表示point to point（点到点）模式，true时代表发布订阅模式，需要手动开启

spring.jms.pub-sub-domain=true

spring.activemq.user=wiener

spring.activemq.password=wiener1237

在项目中配置 ActiveMQ连接属性，新增ActiveMQConfig类：

import org.apache.activemq.ActiveMQConnectionFactory;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.jms.config.DefaultJmsListenerContainerFactory;

import org.springframework.jms.config.JmsListenerContainerFactory;

/**

* 配置 ActiveMQ

*

* @author east7

* @date 2020/6/23 11:27

*/

@Configuration

public class ActiveMQConfig {

@Value("${spring.activemq.user}")

private String usrName;

@Value("${spring.activemq.password}")

private String password;

@Value("${spring.activemq.broker-url}")

private String brokerUrl;

@Bean

public ActiveMQConnectionFactory connectionFactory() {

System.out.println("password =========== " + password);

return new ActiveMQConnectionFactory(usrName, password, brokerUrl);

}

/**

* 设置点对点模式，和下面的发布订阅模式二选一即可

* @param connectionFactory

* @return

*/

@Bean

public JmsListenerContainerFactory> jmsListenerContainerQueue(ActiveMQConnectionFactory connectionFactory){

DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();

bean.setConnectionFactory(connectionFactory);

return bean;

}

@Bean

public JmsListenerContainerFactory> jmsListenerContainerTopic(ActiveMQConnectionFactory connectionFactory){

//设置为发布订阅模式, 默认情况下使用生产消费者方式

DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();

bean.setPubSubDomain(true);

bean.setConnectionFactory(connectionFactory);

return bean;

}

}

bean.setPubSubDomain(true)配置会覆盖properties文件中spring.jms.pub-sub-domain的属性值，故可以在properties不设置spring.jms.pub-sub-domain属性。另外，这种配置方式可以在系统中同时使用点对点和发布/订阅两种消息模式。修改订阅者：

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.jms.annotation.JmsListener;

import org.springframework.stereotype.Component;

import javax.jms.JMSException;

/**

* 消费者

*/

@Component

public class Subscriber1 {

private static Logger logger = LoggerFactory.getLogger(Subscriber1.class);

/**

* 订阅 topicListener1，仅仅加入containerFactory即可

*

* @param text

* @throws JMSException

*/

@JmsListener(destination = "topicListener1", containerFactory = "jmsListenerContainerTopic")

public void subscriber(String text) {

logger.info("Subscriber1 收到的报文：{}", text);

}

}

containerFactory 的值 "jmsListenerContainerTopic" 会自动匹配到ActiveMQConfig中的函数JmsListenerContainerFactory> jmsListenerContainerTopic(ActiveMQConnectionFactory connectionFactory)。 Subscriber2同样修改即可，代码省略。如果containerFactory 的值设置为jmsListenerContainerQueue，则开启了点到点消息模式。

测试函数还可以使用topicTest()。下面提供一个新的测试途径——在controller中测试。新增方法

@Autowired

private Publisher publisher;

@GetMapping("/sendTopicmsg")

public String sendTopicMsg(String msg) {

// 指定消息发送的目的地及内容

Destination destination = new ActiveMQTopic("topicListener2");

for (int i = 0; i < 8; i++) {

publisher.publish(destination, msg + i);

}

return msg + " 发送完毕";

}

执行结果省略。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。