流水线架构

Question

从OOP的角度看，如何实现管道架构？

为了更好地解释我自己：

Source -> Filter -> Filter -> Filter -> Sink

假设我们有一个名为PipelineStage的基类。如何实现Filter、Source和Sink？

我有两个想法：

使用ISource和ISink接口

使用来自过滤器的Sink和Source子类化

​

Answer 1

Source和Sink似乎过多，整体结构复杂。它们不需要是过滤器。

Source就是source，这就是它的功能。If知道从哪里获取数据，以及如何将其传递到管道。不要强迫他成为其他东西，而不是来源。

Sink也是如此。

如果你想要一些东西来验证输入-添加一个额外的验证过滤器。

Answer 2

请看一下责任链模式。您可以使用构建器模式基于一些规则来构建链，一旦构建，触发源，它将通过链到端(Sink)进行处理。断链问题很常见，但你仍然可以有办法处理它。