java - 传输方案未识别：[amqp]

Question

我正在尝试将 AMQP 与 ActiveMQ 一起使用，但出现以下错误

Transport scheme NOT recognized: [amqp]

这是我的代码

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
        "amqp://localhost:61616");

Connection connection = null;
try {
    connection = connectionFactory.createConnection();
    connection.start();

    Session session = connection.createSession(false,
            Session.AUTO_ACKNOWLEDGE);

    Queue queue = session.createQueue("somequeue");

    MessageProducer producer = session.createProducer(queue);

    // We will send a small text message saying 'Hello'
    TextMessage message = session.createTextMessage();
    message.setText("Publishing : New Message ");
    producer.send(message);

    connection.close();
} catch (Exception e) {

}

Answer 1

请注意，ActiveMQ 中的 AMQP 仅在服务器中实现，而不在 JMS 客户端中实现。JMS 客户端实际上实现了“默认”OpenWire 协议（以及 JVM 内部传输）。

您应该使用其他一些客户端库来使用 AMQP 与 ActiveMQ 通信，例如ActiveMQ 推荐的Apache QPID。