Spring 集成:MQTT 的入站和出站适配器

Spring Integration: inbound and outbound adapters to MQTT

我正在尝试将 MQTT 支持构建到我的 Spring 应用程序中。为此,我正在查看 Spring 提供的参考资料,可在此处找到 here.

他们提供了入站和出站通道适配器的示例代码,但我不清楚适配器的概念。我在网上找不到很多关于它的信息。

这些适配器到底是什么,为什么需要它们?

我需要在哪里定义这些适配器以及如何访问它们?

我使用 eclipse 作为我的 IDE 和 maven 作为我的构建工具。

适配器是 Spring Integration which is yet another Spring project that provides an implementation of the Enterprise Integration Patterns 的一个概念,它提供了一个抽象层来标准化您与外部系统集成的方式,无论它们是基于 JMS、FTP 还是您的情况下的 MQTT。

与许多其他 Spring 项目一样,它背后的驱动程序是松耦合和标准化,这将使您能够交换您的渠道提供者(例如,如果它的 JMS 提供者将 RabbitMQ 与 ActiveMQ 交换,或者副反之亦然),对其余代码的影响最小。

它与 Apache Camel 相当,如果您更熟悉它的话,这篇 comparison 读起来很有趣