【问题标题】:Inverted pipeline/chain of responsibility pattern反向管道/责任链模式
【发布时间】:2017-05-10 12:15:45
【问题描述】:

我想知道是否有一种建立模式来控制我的应用程序将拥有的流程。

简单地说,应该是这样的:

  • 用户提供文件
  • 文件正在处理中
  • 用户收到处理后的文件

会有几个处理步骤,比如说 PreprocessingOne、PreprocessingTwo、PreprocessingThree 和 FinalProcessing。

当然,我们不控制用户提供的文件 - 它们需要不同数量的预处理步骤。

由于我的消息处理程序服务将位于单独的 API 中,因此出于性能原因,我不想调用它们只是为了返回“尚无法处理”或“不需要处理”。

同样,我不想在服务之间传递上传的文件。

理想情况下,我想通过评估内容并仅插入有意义的消息处理程序来动态设计文件的流程。

我说的是“倒置”管道,因为与其从 A 到 Z,我更愿意检查我需要从 Z 开始的哪些阶段,并且只插入最后一个阶段。

因此,如果上传的文件立即符合FinalProcessing 的条件,则流程将只是一个元素。

如果文件需要来自PreprocessingTwo,那么流程将是PreprocessingTwo > PreprocessingThree > FinalProcessing

所以,我想我可以实现类似的东西,但我不确定细节。

public interface IMessageHandler
   {
    void Process(IFile file);
   }


public interface IContentEvaluator 
{
     IList<IMessageHandler> PrepareWorkflow(IFile file);
}

public interface IPipelineExecutor
{
        void ExecuteWorkflow(IList<IMessageHandler> workflow, IFile file);
   }

然后在应用中

public void Start(IFile newFile)
{
    var contentEvaluator = new ContentEvaluator(this.availableHandlers); // would be DI
    var workflow = contentEvaluator.PrepareWorkflow(newFile);
    this.executor.ExecuteWorkflow(workflow, newFile);

}

您能否建议、推荐一些方法或进一步阅读?

【问题讨论】:

    标签: c# design-patterns pipeline chain-of-responsibility


    【解决方案1】:

    您可以考虑使用Strategy 模式:...在运行时选择算法...
    但是,如果您有太多的流程组合,那么需要实施的策略数量将会增加,并且解决方案可能会很复杂。

    另一种方法是使用SEDA:...将复杂的事件驱动应用程序分解为一组由队列连接的阶段...
    PreprocessingOne、PreprocessingTwo、PreprocessingThree 和 FinalProcessing 是阶段,可以通过将传出消息定向到不同队列来定义流。

    【讨论】:

      【解决方案2】:

      那是decorator pattern

      定义

      动态地为对象附加额外的职责。 装饰器为扩展子类提供了一种灵活的替代方案 功能。

      【讨论】:

        猜你喜欢
        • 1970-01-01
        • 1970-01-01
        • 2011-09-26
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 2011-04-12
        • 1970-01-01
        • 1970-01-01
        相关资源
        最近更新 更多