因此,最近几天我一直在阅读有关基于流的编程 (FBP) 的内容,并且我还一直在阅读 J. Paul Morrison 的有关它的书。但是,我觉得我仍然无法真正理解它。一般概念是您将编程视为某种装配线,其中您的组件将一些数据包作为输入并产生一些数据包作为输出。您可以连接这些组件并通过网络传输数据包。虽然我完全了解这如何适用于 ETL 类型的应用程序或批处理,但我不知道如何使用它处理同步请求/响应模式或数据库事务之类的事情。
例如,假设我有一个实现为 FPB 的 Web 服务器。这个网络服务器有一个 GET /user/{id} ,它应该返回一个带有一些用户信息的 JSON。它还有一个 POST /user/{id} ,您可以在其中通过将一些 JSON 发送回服务器来更新用户。所以这就是我想象的这个流程的样子:
我试图拥有许多可重用的组件,而不是将处理请求的整个逻辑放入单个组件中。因此,有一个 HTTP 服务器组件将请求发送到调度程序组件,然后调度程序组件将请求分派到后续流中。在每个流程中,请求由通用“请求解析器”组件解析,该组件将请求的各个部分输出到流程的其余部分。
上半部分非常简单,我从 DB 中读取具有给定 ID 的用户实体,将对象序列化为 JSON,然后将其发回。然而,此时我们实际上并没有对 HTTP 请求的引用,那么我怎么知道将这个请求发送到哪里呢?
在下部,我们有一些额外的复杂性,因为我想以事务方式写入数据库。因此,首先启动一个事务(并行地将请求主体解析为某个对象),然后从数据库中检索用户对象并与来自请求的输入合并。最后,它被写回数据库并提交事务。最后,一些“OK”状态响应调用者。在这里,我还有一个额外的问题,即在提交事务时,我真的不知道要提交哪个事务。当然,在发送响应时,我不知道将其发送到哪个请求。
所以这两个问题似乎有一些共同点——一种跨越许多组件的“上下文”。在一个示例中,它是 HTTP 请求/响应上下文,而另一个示例是事务上下文。在常规编程中,这些上下文通常在线程级别处理。由于请求在单个线程中运行,因此事务和请求上下文绑定到线程本地,因此只要所有内容都在同一个线程中运行,它们就可以在任何地方访问。
在基于流的编程中,每个组件独立运行,理想情况下在单独的线程上运行。这实际上是一个关键的事情,因为它允许并行化和有效使用多个处理器。但是,当该线程本地上下文不再存在时,您如何在基于流的编程中处理这些问题?通过正确的错误处理(我在示例中省略了),这将变得更加复杂。
我认为,当您进行反应式编程时,大部分处理都是异步和多线程的,您也会遇到同样的问题,所以我想知道是否有模式来处理这个问题。您是否有反应式编程或基于流的编程的真实生活经验,并且对我如何解决这个问题有一些提示?