使用 Open Liberty 的反应式消息传递 AMQP 和服务总线答案

【问题标题】：Reactive messaging AMQP and Service Bus with Open Liberty使用 Open Liberty 的反应式消息传递 AMQP 和服务总线
【发布时间】：2019-11-09 09:29:02
【问题描述】：

Open Liberty 带有 mpReactiveMessaging-1.0 功能，其中包括一个 Kafka 连接器。

我想与 Azure 服务总线集成，我使用 Smallrye AMQP 连接器（版本 1.0.8）。

当尝试使用@Outgoing-annotation 发送到服务总线队列时，我得到了

javax.net.ssl.SSLHandshakeException: Failed to create SSL connection

这是我在调试 Smallrye 实现时发现的。

我查看了 Proton、vert.x 和 Azure 服务总线 AMQP 文档，但找不到示例或说明我的一组 MP 配置属性用于工作的 AMQP 服务总线连接有什么问题。

mp.messaging.outgoing.servicebus.address=xxxxxxx 
mp.messaging.outgoing.servicebus.connector=smallrye-amqp
mp.messaging.outgoing.servicebus.host=xxxxx.servicebus.windows.net
mp.messaging.outgoing.servicebus.port=5672
mp.messaging.outgoing.servicebus.username=my_saspolicyname
mp.messaging.outgoing.servicebus.password=the_saskey
mp.messaging.outgoing.servicebus.use-ssl=true
mp.messaging.outgoing.servicebus.hostname-verification-algorithm=''
mp.messaging.outgoing.servicebus.containerId=mycontainer
mp.messaging.outgoing.servicebus.amqp-use-ssl=true

【问题讨论】：

标签： azureservicebus open-liberty smallrye-reactive-messaging

【解决方案1】：

默认情况下，Open Liberty 不信任 Java 提供的标准 CA 证书列表。我不熟悉 Azure 服务总线，但由于我在文档中找不到有关配置证书的任何内容，因此我假设它使用由受信任机构签署的证书。

在这种情况下，您可能需要将此添加到您的 server.xml 以告知 OpenLiberty 信任 Java 中包含的 CA 证书。

<ssl id="defaultSSLConfig" trustDefaultCerts="true"/>

此选项是在 Open Liberty 版本 19.0.0.12 中添加的

【讨论】：

可能！会尝试并回来！