尝试连接到Openshift上部署的ActiveMQ Artemis时，连接被拒绝

Question

我们有一个Openshift项目（项目1），其中我们使用图像设置了一个AMQ Artemis代理：amq-amq-broor-7-tech-preview/amq-broor-71-openshif。作为基本映像，我们没有任何配置，例如SSL或TLS。为了进行设置，我们使用了以下示例：https://github.com/jboss-container-images/jboss-amq-7-broker-openshift-image/blob/amq71-dev/templates/amq-broker-71-basic.yaml

在Openshift上部署映像后，我们有以下内容：

• broer-amq-amqp（5672/TCP 5672）无路由
• brobro-amq-jolokia（8161/TCP 8161）https://broker-amq-jolokia-project1.192.168.99.105.nip.io
• broor-amq-mqtt（1883/TCP 1883）无路由
• broor-amq-Stump（61613/TCP 61613）无路由
• broor-amq-tcp（61616/TCP 61616）无路由

在Java中，我们尝试从另一个Openshift服务连接到代理，但收到以下错误：

[org.apache.activemq.transport.failover.FailoverTransport] (ActiveMQ Task-1) Failed to connect to [tcp://broker-amq-amqp-project1.192.168.99.105.nip.io:61616?keepAlive=true] after: 230 attempt(s) with Connection refused (Connection refused), continuing to retry.

Java代码：

user = "example";
password = "example";

String address = "queue/example";

InitialContext context = new InitialContext();

queue = (Queue) context.lookup(address);
ConnectionFactory cf = (ConnectionFactory) context.lookup("ConnectionFactory");
try (Connection connection = cf.createConnection(user, password);) {
    connection.start();
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
}

JNDI属性文件

java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory
java.naming.provider.url=failover:(tcp://broker-amq-amqp-project1.192.168.99.105.nip.io:61616?keepAlive=true)?randomize=false
queue.queue/example=example/strings

Answer 1

看起来好像您正在尝试使用OpenShift路由连接到代理，而没有为相关服务定义路由。您（或安装程序）为Jolokia定义了一个路由，但没有代理的路由。

这里不会显示有用的错误消息，因为任何以正确域结尾的主机名都将连接到OpenShift路由器。然而，如果没有有效的路由，路由器将不知道如何处理连接，并且可能只是将某种毫无意义的错误数据包返回给JMS客户机。

如果您尝试从与代理相同的OpenShift命名空间中的另一个应用程序连接到代理，则不需要通过路由器进行连接——只需使用服务名称（大概是broer-amq-tcp）和服务端口显式地在您的JMS设置中。

如果您从同一集群中不同OpenShift命名空间中的另一个应用程序连接到代理，您可能能够配置网络子系统以允许跨命名空间直接连接到服务。不幸的是，在安装OpenShift后设置起来有点繁琐。

如果您是从OpenShift命名空间外部连接到代理，并且不能直接使用服务，则必须通过路由进行连接，并且必须使用加密连接。这并不一定是为了安全——路由器将从SSL头读取SNI信息，以确定如何路由请求。

因此，您需要为代理的SSL端口创建服务，为该服务创建路由，从代理导出服务器证书，将这些证书导入您的客户端，并将客户端配置为通过路由器使用SSL连接URI。显然，如果可以的话，直接使用服务更容易；）

所有这些设置步骤都在Red Hat的OpenShift文档AMQ7中进行了描述：

https://access.redhat.com/documentation/en-us/red_hat_amq/7.5/html/deploying_amq_broker_on_openshift/index

尽管我不能否认，那份文件中有很多信息需要仔细阅读。