java - 使用 Java 和 AMQP 1.0 连接到 Windows Server (1.1) 上的服务总线

Question

我要问的问题已经有人问了here前。 David Ingham 给出了答案 this Microsoft Document . Sentinel 已确认该解决方案有效。

但是，我也遇到了同样的问题。我严格按照 Microsoft 文档进行操作，但是，仍然有同样的问题。

冒着冗余的风险，问题是当使用 Qpid-JMS 客户端库(版本 0.22 或 0.26)连接到 Windows Server 上的Service Bus (1.1)时(不是 Azure)，并遵循 Microsoft 的所有指示，包括

1. 生成 RootCA 证书并将其应用于 Java 信任库
2. 使用您的 Windows 登录用户名/密码
3. 使用 amqps://[user]:[pwd]@FQDN/[namespace] 连接工厂字符串
4. 使用 [namespace]/[queuename] 作为您的物理队列名称。

上下文查找、连接创建、 session 创建都可以正常工作。但是当需要创建 MessageProducer 或 MessageConsumer 时，我会遇到错误。

对于 MessageProducer 创建(不管是队列还是主题)我总是得到

Caused by: org.apache.qpid.amqp_1_0.client.Sender$SenderCreationException:
Peer did not create remote endpoint for link, target: testns/testq1
at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:171)

对于 MessageConsumer 的创建，我得到

javax.jms.JMSException
at org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.createClientReceiver(MessageConsumerImpl.java:164)
at org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:120)

以下是我尝试过的几种方法。

1. 我的服务总线安装在 Windows 2012 服务器上。我的客户端正在从另一个 Windows 2012 服务器运行。但我也已将客户端移动到服务总线运行的服务器，但没有解决。 (所以这不是位置问题)
2. 当我从信任库中取出证书时，我得到了一个相应的错误。当我把它插回去时，错误就消失了。 (所以这不是证书问题)
3. 当我故意拼错 Windows 用户名或密码时，出现身份验证错误。否则错误消失。 (所以这不是用户/密码问题)
4. 看来我在连接字符串中明确键入端口号 5671 并不重要。在任何一种情况下，连接创建都可以正常工作。 (所以这不是连接问题)
5. 在连接字符串或队列定义中定义命名空间似乎无关紧要。这两种情况都失败了。
6. 我已经下载了 Qpid-JMS-Client (0.22) 的源代码并逐步调试了调试器。目标(要连接的队列的地址)在创建连接时设置正确，但在离开同步块(synchronized block)后立即重置为空，这会导致错误(在 MessageProducer 的情况下)

我从原始 Microsoft 文档中遗漏了什么(名为 Sentinel 的用户确认它有效)？

如有任何帮助，我们将不胜感激。谢谢你，-多根阿泰

Answer 1

我们遇到了完全相同的错误并执行了您提到的所有步骤，结果相似。然而，我们连接到云中的 Azure 服务总线。事实证明错误消息非常具有误导性，幕后身份验证从未发生过。您可以通过提供不正确的密码进行验证，您仍将完成所有步骤，直到需要创建生产者或消费者，然后您将看到您提到的异常。

事实证明，问题是，如果我们使用 Azure 管理门户创建队列/主题，那么 AMQP 客户端无法正确连接，我们不断收到“Peer...”异常。但是，如果我们使用 Microsoft 专有 api 以编程方式创建队列/主题，请参阅

http://azure.microsoft.com/en-us/documentation/articles/service-bus-java-how-to-use-queues/

然后 AMQP 客户端能够正常连接和发送/接收消息。

虽然它不是 Windows Server 上的服务总线，而是 Azure 服务总线，但我预计解决方案可能是相同的。如果它对您不起作用，请告诉我。