You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

如何在JMS中通过用户名/密码建立连接?

为JMS连接添加用户名/密码认证

你可以通过两种方式给ActiveMQ的JMS连接添加用户名和密码认证:

方式一:构造连接工厂时传入认证信息

直接在创建ActiveMQQueueConnectionFactory时,把用户名、密码和Broker地址一起传入:

public static QueueSession getQueueSession(String urlBroker, String username, String password) throws JMSException {
    // 传入用户名、密码和Broker地址初始化连接工厂
    QueueConnectionFactory connectionFactory = new ActiveMQQueueConnectionFactory(username, password, "tcp://" + urlBroker);
    QueueConnection connection = connectionFactory.createQueueConnection();
    return connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
}

方式二:创建连接时传入认证信息

保持连接工厂的初始化逻辑不变,在调用createQueueConnection方法时传入用户名和密码:

public static QueueSession getQueueSession(String urlBroker, String username, String password) throws JMSException {
    QueueConnectionFactory connectionFactory = new ActiveMQQueueConnectionFactory("tcp://" + urlBroker);
    // 创建连接时指定用户名和密码
    QueueConnection connection = connectionFactory.createQueueConnection(username, password);
    return connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
}

两种方式都能实现认证,按需选择即可。注意要确保传入的用户名和密码与ActiveMQ Broker端配置的认证信息一致,否则会连接失败。

内容的提问来源于stack exchange,提问作者user21871375

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.21 17:17:02