Java ActiveMQ + STOMP + SSH：对方法 sun.security.ssl.SSLSocketImpl.setHost 的非法反射访问操作

Question

我正在为 AmazonMQ 编写一个简单的 Java JMS QueueBrowser 客户端，它使用 stomp 协议在 ssh 上运行 ActiveMQ（因此他的传输是 stomp+ssl ：

// java
import java.util.Enumeration;

// jms
import javax.jms.IllegalStateException;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.ConnectionFactory;
import javax.jms.Connection;

// activemq
import org.apache.activemq.ActiveMQConnectionFactory;

public class QueueBrowserExample {
    public static void main(String[] args) throws Exception {

        System.out.println("init");
        try {

            final String PORT = "61616";
            final String PROTOCOL = "stomp+ssl";
            final String HOST = "xxx.mq.us-east-1.amazonaws.com";
            final String connectionString = PROTOCOL + "://" + HOST + ":" + PORT;

            System.out.println("attempt to connect to " + connectionString);

            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(connectionString);
            Connection connection = connectionFactory.createConnection("admin", "admin");
            connection.start();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Queue queue = session.createQueue("Test");
            QueueBrowser queueBrowser = session.createBrowser(queue);
            Enumeration msgs = queueBrowser.getEnumeration();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

由于使用了传输，我得到了javax.jms.JMSException execepion（我假设是stomp+ssl）

javax.jms.JMSException: Could not create Transport. Reason: java.lang.IllegalArgumentException: Invalid connect parameters: {wireFormat.host=b-02b566af-1f0d-4d48-ad24-229a813a53fb-1.mq.us-east-1.amazonaws.com}
        at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:36)
        at org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:319)
        at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:332)
        at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:253)
        at QueueBrowserExample.main(QueueBrowserExample.java:37)
Caused by: java.lang.IllegalArgumentException: Invalid connect parameters: {wireFormat.host=b-02b566af-1f0d-4d48-ad24-229a813a53fb-1.mq.us-east-1.amazonaws.com}
        at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:122)
        at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:64)
        at org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:317)
        ... 3 more

ActiveMQ 后端正在使用 STOMP，我无权访问它。因此，我必须弄清楚如何“管理”队列（只看消息，不处理），然后我来到了 QueueBrowser 和 JMS。

Answer 1

不支持 JMS over STOMP。

请记住，JMS 只是一个 API。大多数经纪人之间的底层有线协议是不同的。在 ActiveMQ “Classic”（这是 Amazon MQ 使用的）中，您可以通过 OpenWire 协议或通过 AMQP（需要使用 Qpid JMS 库）使用 JMS。不支持 JMS over STOMP。

在这种情况下，您使用的是 OpenWire JMS 客户端，因为您使用的是org.apache.activemq.ActiveMQConnectionFactory。无论您在连接字符串中指定什么内容，客户端都将使用 OpenWire 协议。

STOMP 只是不支持 JMS 公开的大部分功能。 STOMP 尤其不支持队列浏览器。