基于流/响应式编程中的事务/请求-响应模式

问：

因此，在过去的几天里，我一直在阅读有关基于流程的编程（FBP）的文章，我也一直在阅读J. Paul Morrison关于它的书。但是，我觉得我仍然无法真正理解它。一般的概念是，您将编程视为某种装配线，其中的组件将一些数据包作为输入并生成一些数据包作为输出。您可以连接这些组件，数据包通过网络传输。虽然我完全明白它如何用于 ETL 类型的应用程序或批处理，但我不知道如何处理同步请求/响应模式或数据库事务等事情。

例如，假设我有一个作为 FPB 实现的 Web 服务器。此 Web 服务器有一个 GET /user/{id}，它应该返回一个 JSON，其中包含有关用户的一些信息。它还有一个 POST /user/{id}，您可以通过将一些 JSON 发送回服务器来更新用户。因此，以下是我想象此流程的样子：

我尝试拥有许多可重用的组件，而不是将处理请求的整个逻辑放入单个组件中。因此，有一个 HTTP 服务器组件，它将请求发送到调度程序组件，然后调度程序组件将请求分派到后续流中。在每个流中，请求由一个通用的“请求解析器”组件解析，该组件将请求的各个部分输出到流的其余部分。

上半部分非常简单，我从 DB 中读取具有给定 ID 的用户实体，将对象序列化为 JSON，然后将其发送回去。但是，在这一点上，我们不再真正引用HTTP请求，那么我怎么知道将此请求发送到哪里呢？

在下半部分，我们有一些额外的复杂性，因为我想以事务方式写入数据库。因此，首先启动一个事务（并行地将请求体解析为某个对象），然后从数据库中检索用户对象并与请求的输入合并。最后，它被写回数据库并提交事务。最后，呼叫者会响应一些“OK”状态。在这里，我还有一个额外的问题，即在提交事务时，我真的不知道要提交哪个事务。当然，在发送响应时，我不知道要将其发送到哪个请求。

因此，这两个问题似乎有一些共同点——一种跨越许多组件的“上下文”。在一个示例中，它是 HTTP 请求/响应上下文，在另一个示例中是事务上下文。在常规编程中，这些上下文通常在线程级别进行处理。由于请求在单个线程中运行，因此事务和请求上下文绑定到线程本地，因此只要所有内容都在同一线程中运行，就可以在任何地方访问它们。

在基于流程的编程中，每个组件都独立运行，理想情况下在单独的线程上运行。这实际上是一件关键的事情，因为它允许并行化和有效使用多个处理器。但是，当线程本地上下文不再存在时，如何在基于流的编程中处理这些问题？如果正确处理错误（我在示例中省略了这一点），这将变得更加复杂。

我认为，当你进行反应式编程时，大部分处理都是异步和多线程的，你也会遇到同样的问题，所以我想知道是否有模式可以处理这个问题。您是否有响应式编程或基于流程的编程的实际经验，并且对我如何解决这个问题有一些提示？