连接ActiveMQ Broker时遭遇Schema https not found异常求助

AI 小北

2026-6-25

解决方案：Schema https not found 异常处理

问题原因

ActiveMQConnectionFactory 不支持 https 作为连接协议前缀——ActiveMQ Artemis的JMS客户端使用原生消息协议（如tcp/ssl），而非HTTP/HTTPS协议，因此无法识别https schema，触发空指针异常。

修复步骤

1. 修改连接URL的协议前缀

将原URL的https://替换为正确的协议：

无加密连接：使用tcp://，示例：tcp://XXXXXX.com:61616（默认非加密端口为61616）
SSL加密连接：使用ssl://，示例：ssl://XXXXXX.com:61617（默认SSL端口为61617）

2. 配置SSL参数（若使用加密连接）

如果需要SSL加密通信，需为连接工厂添加SSL相关配置：

import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;

// 替换为修改后的URL，如ssl://XXXXXX.com:61617
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url, username, password);
// 启用SSL
connectionFactory.setSslEnabled(true);
// 设置信任库路径及密码（用于验证Broker证书）
connectionFactory.setTrustStorePath("/path/to/your/truststore.jks");
connectionFactory.setTrustStorePassword("your-truststore-password");
// 若Broker要求客户端证书认证，额外配置密钥库
// connectionFactory.setKeyStorePath("/path/to/your/keystore.jks");
// connectionFactory.setKeyStorePassword("your-keystore-password");

try (Connection connection = connectionFactory.createConnection()) {
    connection.start();
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Destination queue = session.createQueue(queueName);
    
    TextMessage message = session.createTextMessage(jsonData);
    message.setStringProperty("Content-Type", "application/json"); 

    MessageProducer producer = session.createProducer(queue);
    producer.send(queue, message);
} catch(JMSException e) {
    e.printStackTrace();
}