azure - azure-eventhubs 和 spring-cloud-azure-eventhubs-stream-binder 有什么区别？

Question

我的要求是使用 Spring 的 Azure 事件中心进行简单的发布-订阅。

在检查文档后，我发现了 2 篇文章演示了集成。 One uses azure-eventhubs图书馆和the other uses spring-cloud-azure-eventhubs-stream-binder.

两者有什么区别？

Answer 1

嗯，我是这样看的。我想说有3-4种方法可以做到这一点。您可以作为 Kafka/9093 或 AMQP/5671 连接到 Eventhub。我认为令人遗憾的是没有任何页面提供这方面的建议:

1. 首先，最基本的:azure-messaging-eventhubs库。我会放 azure-core和azure-core-amqp作为相关的。您可以使用azure-core连接进行健康检查，例如:EventHubClient.createFromConnectionStringSync(connectionString, Executors.newSingleThreadScheduledExecutor()); 。此方法为您提供了最大的灵 active ，但您将编写更多代码并自行处理配置属性。
2. 然后，您可能会看到 azure-spring-cloud-starter-eventhubs ，它有一个名为 spring-cloud-starter-azure-eventhubs-kafka 的 kafka 变体。 spring 库 azure-spring-cloud-stream-binder-eventhubs可能与此有关。该库需要特定的 application.properties配置(与 #3 不同)。我喜欢这个的一件事是它会延迟加载，即使 lib 无法连接，你的 spring-boot 服务也会启动，并且问题会在运行状况检查中显示。
3. 然后，有一个围绕 #1 中内容的包装器& #2 , spring-cloud-azure-eventhubs-stream-binder 。这个库有它自己的特殊application.properties配置(与 #2 不同)。它内置了健康检查，但我无法让它工作。使用此服务，如果无法建立连接来配置 Bean，您的服务将不会启动。
4. 也许您不想使用上述包装器库之一。在这种情况下，您可以只使用基本的 spring-kafka还。我举了一个例子:https://github.com/djangofan/kafka-on-azure