Pipeline模式在分布式框架中经常可以看到，应用该模式可以使框架具有良好的灵活性。当我们需要构建一个系统用于处理并转换一串输入数据时，如果通过一个大的组件按部就班的来实现此功能，那么一旦需求发生变化，比如其中的两个处理步骤需要调换次序，或者需要加入或减去某些处理，系统将很难适应，甚至需要重写。而Pipeline模式则将一个个的处理模块相互分离，各自独立，然后按照需要将它们串联起来即可，此时前者的输出就会作为后者的输入。此时，每个处理模块都可以获得最大限度的复用。当需求发生变化时，我们只需重新组织各个处理模块的链接顺序，或者删除或加入新的处理模块即可。

例如我做的某个项目中,从输入到输出过程中,要对输入数据做不同的处理,如与某个模板合并(mergeFilter),删除其中的某些数据(deleteFilter),按照数据中的某个标识把数据分割(SplitFilter)以及把数据文件做为附件发送到指定的邮箱内(EmailFilter)等等;则可以把这些功能单独做为一个Filter(具有共同的接口),而在调用Filter时,又可分为两种模式:

1. 中心模式(central):

在这种模式中,每个Filter都从central接收输入,然后处理完后返回输出给central,由central调用下一个Filter,并把上一个

Filter 的输出作为下一个Filter的输入,以此类推,直到最后一个Filter.

2. 序列模式(sequence):

在这种模式中,首先由Central建立Filter sequence,然后把输入以及Filter 序列传递给第一个Filter,当Filter完成后,根据Filter

序列找到下一个Filter,并把生成的data以及Filter序列传递给下一个Filter,直到最后一个Filter.