使用来自java的amqp连接windows服务总线时socket关闭

Question

我试图连接到服务总线的windows服务器使用java示例，这是在微软网站上提供的。

下面是我在此POC中使用的库

     <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-jms-client</artifactId>
        <version>0.26.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-amqp-1-0-client-jms</artifactId>
        <version>0.32</version>
    </dependency>

  return "amqps://" + SbSharedKey + ":" + SbSharedSecret + "@" + SbDomain + "/" + SbNamespace;

创建会话异常创建会话/生成器

java.net.socketException：在java.net.socketInputStream.socketRead0（本机方法）在java.net.socketInputStream.socketRead(SocketInputStream.java:116)javax.jms.jmsException：class java.net.socketException：由远程主机关闭的连接class java.net.socketInputStream.Read(socketInputStream.java:170)在

进程结束，退出代码为0

所以问题似乎只是与AMQP方面…您能告诉我使用来自Java的amqp连接到Windows server服务总线时要使用的库的正确版本吗

Answer 1

您在项目上使用了两个不同的AMQP JMS客户机库依赖项，所以我不知道到底发生了什么，但我的第一个猜测是，您最终使用了遗留的'qpid-amqp-1-0-client-jms'客户机，该客户机不受支持，而且肯定无法工作。我会删除它，并尝试使用Qpid JMS0.26.0客户机库，尽管我相信您可能需要一些其他URI选项，因为azure有一些特定的连接要求。