Java的嵌套队列

• Z时代
• 2024-01-10
• 分类：问答

更新：Java的嵌套队列

总之，我有一个消息发送从用户到服务的队列。 但是，当一个服务获得1000条消息时，比队列由 支配，它和其他服务在队列为空之前不会收到消息。我需要这种方法的解决方案。

我对我的BlockingQueue有问题。比方说，我有100个外部服务，我负责向他们发送消息来自用户。

用户 - >我 - >第三方。

我在我的应用程序中使用队列。当其中一个第三方服务不可用时发生问题：

• 从用户接收到任何第三方的消息。将它们保存在同一个队列中可以说Q1。
• 消费队列，识别第三方服务并发送给对应的第三方。
• 第三方之一不响应，超时。
• 保存无法将它们传送到数据库的消息。
• 定期从数据库获取未发送的消息并将它们放入我的Q1。
• 如果该第三方获得大量流量，可以说5000个消息（填满我的队列）比其他服务的非消息从我那里收到消息，直到此队列为空。但是当这个队列为空时，他们将不会收到消息，因为我将再次从DB获取消息并将它们放入队列中，其他服务将再次被阻塞。

Solutiouns，我认为到目前为止：

• 使用嵌套队列的业务ID，所以我会在一次5000级的消息找出封锁的服务，并将它们保存到数据库没有5000次消费从队列中的消息（可更因为消息将不会是为了，他们都是一起与其他服务于一体的队列）

如何有效地使用嵌套concurret队列（这是我使用的BlockingQueue），或者你认为此方案更好的解决方案？基本上我不想让第三方下降支配我的队列。我需要一个聪明的方法来分隔这些队列，可能会有成千上万的队列，因此为每个队列创建一个队列可能是无效的。

回答：

以上是 Java的嵌套队列 的全部内容， 来源链接： utcz.com/qa/266130.html