我们使用 Azure 服务总线将消息从一个服务发送到另一个服务。生产者在 1-2 小时内产生了大量的消息(几百万条)。结果,我们的服务总线(我们使用高级 Azure 服务总线)受到限制,并且我们在生产者和消费者方面收到错误。我想知道我们是否可以通过使用 Azure SDK(我们使用 ASB Java SDK)以某种方式检查 ASB 的负载,如果它很高,我们可以减慢将消息发送到队列/主题的服务。 我也知道我们可以添加更多高级单位,但这是我们将采取的最后一个选择。
我们使用什么:
- Azure 服务总线 Java SDK
- Java 9 和 Spring Boot 2.0
- Azure 服务总线高级版
你对我的案子有什么建议吗?任何建议——模式、框架、ASB SDK 功能都会很棒。