并发请求后触发后续流程

在分布式系统中，多个并发的请求可能需要在完成特定条件后触发后续流程。以下是一个应用场景：

假设客户端需要执行两个操作：

• 将状态更新为已完成
• 从第三方服务获取并记录一个值

这两个操作可以并发执行，但在它们都完成后，需要触发另一个流程。

解决方案：状态队列

为了感知这两个操作都已完成，我们可以使用状态队列（例如 Redis）。类似于消息队列，该队列允许将状态信息存储在可序列化的数据结构中。

步骤：

1. 客户端上报和第三方回调：当客户端修改数据库状态为已完成或从第三方服务获取值时，它们会将更新写入状态队列。
2. 状态更新：状态队列中的信息会被定期检查。当队列中包含了客户端上报和第三方回调的信息时，表示这两个操作都已完成。
3. 触发流程：当检测到状态队列中信息已更新后，可以触发后续流程。后续流程可以是一个函数、通知或其他处理任务。

优点：

• 并发感知：该方案无需考虑操作执行顺序，因为它通过状态检查而不是事件序列来感知完成。
• 分布式性：状态队列通常是分布式的，这意味着它可以跨多个服务器实例进行扩展。
• 可扩展性：可以添加更多的前置操作或后续流程，只需将它们添加到状态队列中即可。