0

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

简单地说，它应该是这样的：

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

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

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

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

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

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

我说的是“倒置”管道，因为与其从 A 到 ZI，不如从 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);

}

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

4

2 回答 2

2

您可以考虑使用策略模式：...在运行时选择算法...
但是如果您的流程组合过多，则需要实施的策略数量会增加，解决方案可能会很复杂。

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

于 2017-05-10T14:06:02.383 回答
0

那是装饰器模式吗

定义

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

于 2017-05-10T12:18:58.223 回答