java - 使用 SSL 连接到 Activemq

Question

我正在尝试以消息接收者的身份连接到我们的 ActiveMQ 服务器。首先，我尝试连接到本地 ActiveMQ，我下载它用于测试目的。这很有效，连接适用于以下内容:

private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);   
Connection connection = connectionFactory.createConnection();
connection.start();

现在我需要连接到服务器上的 ActiveMQ，并且我需要使用 SSL。我已经将 .crt key 导入 Java (cacert)，但不知道如何继续。我想我必须将 url 更改为如下内容:

url = "failover://ssl://<servername>:61617";

但仅此一项是行不通的。有没有人有任何提示，如何获得连接？提前致谢!

Answer 1

找到解决方案!

ActiveMQSslConnectionFactory connectionFactory = new ActiveMQSslConnectionFactory(url);
connectionFactory.setTrustStore("truststore.ts");
connectionFactory.setTrustStorePassword("password");

Connection connection = connectionFactory.createConnection();
connection.start();

您只需使用您的 CA 创建一个信任库。