JavaActiveMQ STOMPSSH：对方法sun.security.ssl.SSLSocketImpl.setHost的非法反射访问操作

Question

我正在为AmazonMQ编写一个简单的Java JMS QueueBrowser客户端，它通过< code>ssh运行带有< code>stomp协议的ActiveMQ(因此传输是< code>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();
        }
    }
}

由于所使用的传输方式，我得到了一个< code > javax . JMS . JMS exception exec epion(我假设是< code>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客户端，因为您使用的是< code > org . Apache . ActiveMQ . activemqconnectionfactory 。无论您在连接字符串中指定什么，客户端都将使用OpenWire协议。

STOMP不支持JMS公开的许多功能。STOMP尤其不支持队列浏览器。