使用Spring来创建一个简单的工作流引擎2

　　与大多数过程式后台进程相比，工作流的解决方案真正的突出了高度强壮的错误处理。错误处理句柄可以单独地处理每个活动。这种类型的句柄在单一活动级别提供了细致的错误处理。如果没有单独处理单个活动的错误处理句柄，那么全局工作流处理器的错误处理句柄将会处理出现的问题。例如，如果在工作流处理过程中的任意时刻，一个没有被处理的错误出现了，那么它将会向外传播，被使用defaultErrorHandler属性装配的ErrorHandler Bean处理。

　　更复杂的工作流框架将工作流转换之间的状态持久化存储到数据库中。在这篇文章中，我们仅仅对状态转换是自动完成的工作流感兴趣。状态信息仅仅在实际工作流运行时在ProcessContext中得到。在ProcessContext中，你仅仅能看到ProcessContext的接口的两个方法：

public interface ProcessContext extends Serializable {
      public boolean stopProcess();   
      public void setSeedData(Object seedObject);
   }

　　用于航线例子工作流的具体的ProcessContext类是RateDropContext类。RateDropContext类封装了用于执行航线费率降低工作流必须的数据。

　　到现在为止，经由缺省的ApplicationContext的作用，所有bean实例都已经成了单例。但是，对于每一个航线工作流的调用，我们必须创建一个新的RateDropContext类的实例。为了处理这种需求，需要配置SequenceProcessor，采用全限定类名作为processContextClass属性的值。对于每个工作流的执行，SequenceProcessor使用指定的类名从spring检索ProcessorContext类的一个新的实例。为了使这种机制能够起作用，非单件的spring bean或者类型org.iocworkflow.test.sequence.simple.SimpleContext的原型必须存在于ApplicationContext中（完整的列表，参见rateDrop.xml）。

　　播种工作流

　　既然我们知道怎样使用spring来组装一个简单的工作流，就让我们集中精力使用种子数据(seed data)示例工作流的过程。要明白怎样开始工作流，看一看在实际接口Processor上表现的方法：

public interface Processor {
      public boolean supports(Activity activity);
      public void doActivities();
      public void doActivities(Object seedData);
      public void setActivities(List activities);
      public void setDefaultErrorHandler(ErrorHandler defaultErrorHandler);
   }

　　大多数情况下，工作流需要一些初始化激活才能开始。开始一个处理过程有两个选项：doActivities（ObjectseedData）方法或者无参数的doActivities（）。下面的代码列表是包含在样例代码中为SequenceProcessor而实现的doActivities（）：

public void doActivities(Object seedData) {
   //Retrieve injected by Spring
   List activities = getActivities();
   //Retrieve a new instance of the Workflow ProcessContext
   ProcessContext context = createContext();
   if (seedData != null)
      context.setSeedData(seedData);
   //Execute each activity in sequential order
   for (Iterator it = activities.iterator(); it.hasNext();) {
      Activity activity = (Activity) it.next();
      try {
            context = activity.execute(context);
      } catch (Throwable th) {
         //Determine if an error handler is available at the activity level
         ErrorHandler errorHandler = activity.getErrorHandler();
         if (errorHandler == null) {
            getDefaultErrorHandler().handleError(context, th);
            break;
         } else {
            //Handle error using default handler
            errorHandler.handleError(context, th);
         }
      }
            //Ensure it's ok to continue the process
      if (processShouldStop(context, activity))
         break;
      }
   }

　在这个航空费用减少的例子中，工作流过程的种子数据包括航线信息和费率减少的信息。使用容易测试的航线工作流例子，通过doActivities（Object seedData）方法发出种子数据并激活一个单一的工作流过程是简单的：