Solace Spring Cloud Stream Binder AMQP(S)答案

【问题标题】：Solace Spring Cloud Stream Binder AMQP(S)Solace Spring Cloud Stream Binder AMQP(S)
【发布时间】：2020-03-13 22:10:30
【问题描述】：

我想使用以下 URL amqps://localhost:5671 将我的 Spring Boot 应用程序连接到 Solace PubSub+ 实例。我想为此使用 Spring Cloud Stream 和 Solace Spring Cloud Stream Binder。

我在application.yml 中尝试了以下配置：

solace:
  java:
    host: amqps://localhost:5671
    clientUsername: admin
    clientPassword: admin

但这不起作用。我不断收到amqps 不是有效方案的错误。普通的amqp:// URI 也是如此。

我对 Solace Spring Cloud Stream Binder 的代码进行了更深入的研究，但我不确定这是否真的可行。上面的配置似乎只适用于 tcp:// 和 tcps:// URI，两者都会导致通过 Solace 专有的 SMF 协议发送消息。

这行得通：

solace:
  java:
    host: tcp://localhost:55555
    clientUsername: admin
    clientPassword: admin

...但不使用 AMQP 而是使用 SMF。

如何配置 Solace Spring Cloud Stream Binder 以通过 AMQP 和 AMQPS 进行通信？

【问题讨论】：

标签： solace

【解决方案1】：

来自 Solace 的 Spring Cloud Stream 绑定器不支持 AMQP。它们是使用 Solace Java API JCSMP 编写的，并使用您观察到的 SMF。

我不确定是否有使用 AMQP 1.0 的社区 SCS 绑定器。您是否有理由需要它在 AMQP 1.0 中工作？

【讨论】：

这是正确的。 Solace binder 仅通过 SMF 进行通信，因为它使用 JCSMP API，因此您的 SCSt 应用程序将通过 SMF 连接到代理。也就是说，请记住，Solace Brokers 会自动提供协议转换，因此您仍然可以让您的 SCSt 应用程序与使用 AMQP 或 MQTT 等其他协议的应用程序进行通信