6.3.7. 例子

讓我們來看看在 Section 6.2.7, “例子” 提過併發鎖失敗重試的例子，如果使用schema對這個例子進行重寫是什麼效果。

因為併發鎖的關係，有時候business services可能會失敗（例如，死鎖失敗）。 如果重新嘗試一下，很有可能就會成功。對於business services來說，重試幾次是很正常的（Idempotent操作不需要使用者參與，否則會得出矛盾的結論） 我們可能需要透明的重試操作以避免讓客戶看見PessimisticLockingFailureException 例外被丟擲。 很明顯，在一個橫切多層的情況下，這是非常有必要的，因此通過切面來實現是很理想的。

因為我們想要重試操作，我們會需要使用到環繞通知，這樣我們就可以多次呼叫proceed()方法。 下面是簡單的切面實現（只是一個schema支援的普通Java 類）：

public class ConcurrentOperationExecutor implements Ordered {
   
   private static final int DEFAULT_MAX_RETRIES = 2;

   private int maxRetries = DEFAULT_MAX_RETRIES;
   private int order = 1;

   public void setMaxRetries(int maxRetries) {
      this.maxRetries = maxRetries;
   }
   
   public int getOrder() {
      return this.order;
   }
   
   public void setOrder(int order) {
      this.order = order;
   }
   
   public Object doConcurrentOperation(ProceedingJoinPoint pjp) throws Throwable { 
      int numAttempts = 0;
      PessimisticLockingFailureException lockFailureException;
      do {
         numAttempts++;
         try { 
            return pjp.proceed();
         }
         catch(PessimisticLockingFailureException ex) {
            lockFailureException = ex;
         }
      }
      while(numAttempts <= this.maxRetries);
      throw lockFailureException;
   }

}

請注意切面實現了 Ordered 介面，這樣我們就可以把切面的優先順序設定為高於事務通知（我們每次重試的時候都想要在一個全新的事務中進行）。 maxRetries 和 order 屬性都可以在Spring中配置。 主要的動作在 doConcurrentOperation 這個環繞通知中發生。 請注意這個時候我們所有的 businessService() 方法都會使用這個重試策略。 我們首先會嘗試處理，然後如果我們得到一個PessimisticLockingFailureException 異常，我們只需要簡單的重試，直到我們耗盡所有預設的重試次數。

對應的Spring配置如下：

<aop:config>

  <aop:aspect id="concurrentOperationRetry" ref="concurrentOperationExecutor">

    <aop:pointcut id="idempotentOperation"
        expression="execution(* com.xyz.myapp.service.*.*(..))"/>
       
    <aop:around
       pointcut-ref="idempotentOperation"
       method="doConcurrentOperation"/>
  
  </aop:aspect>

</aop:config>

<bean id="concurrentOperationExecutor"
  class="com.xyz.myapp.service.impl.ConcurrentOperationExecutor">
     <property name="maxRetries" value="3"/>
     <property name="order" value="100"/>  
</bean>

請注意我們現在假設所有的bussiness services都是idempotent。如果不是這樣，我們可以改寫切面，加上 Idempotent 註解，讓它只調用idempotent：

@Retention(RetentionPolicy.RUNTIME)
public @interface Idempotent {
  // marker annotation
}

並且對service操作的實現進行註解。這樣如果你只希望改變切面使得idempotent的操作會嘗試多次，你只需要改寫切入點表示式，這樣只有@Idempotent 操作會匹配：

  <aop:pointcut id="idempotentOperation"
		expression="execution(* com.xyz.myapp.service.*.*(..)) and
					@annotation(com.xyz.myapp.service.Idempotent)"/>