TransactionTemplate編程式事務管理方式的進階使用---自定義拓展模板類

1, 前面一篇的文章介紹了TransactionTemplate的基本使用方法.

　同事在其基礎上又做了一層封裝,這樣更貼合本公司的業務與規范.

 

2, 首先定義了兩個接口:

　　

ServiceTemplate ---->   對TransactionTemplate進行了封裝

public interface ServiceTemplate {

    /**
     * <pre> 無事務模板執行業務處理
     * 1. 異常捕獲，及分類處理
     * 2. 業務日志記錄
     * </pre>
     *
     * @param <T>
     * @param clazz  返回對象
     * @param action 業務操作回調的接口
     * @return       服務返回對象
     */
    <T> T executeWithoutTransaction(Class<? extends Result> clazz, ServiceCallback action);

    /**
     * <pre> 支持本地事務模板執行業務處理
     * 1. 本地事務封裝
     * 2. 異常捕獲，及分類處理
     * 3. 業務日志記錄
     * </pre>
     *
     * @param <T>
     * @param clazz  返回對象
     * @param action 業務操作回調的接口
     * @return       服務返回對象
     */
    <T> T execute(Class<? extends Result> clazz, ServiceCallback action);

}

ServiceCallback  ---->  對TransactionCallBack進行了封裝

public interface ServiceCallback {
    /**
     * <pre> 校驗
     * 對於校驗不通過，異常驅動返回
     * </pre>
     */
    void doLock();

    /**
     * <pre> 校驗
     * 對於校驗不通過，異常驅動返回
     * </pre>
     */
    void check();

    /**
     * <pre> 執行業務邏輯
     * </pre>
     * @return
     */
    Result executeService();
}

 

ServiceTemplate的具體實現如下:
　

public class ServiceTemplateImpl implements ServiceTemplate {

    /** 事務模板 */
    @Autowired
    private TransactionTemplate transactionTemplate;

    @Override
    public <T> T executeWithoutTransaction(Class<? extends Result> clazz,
                                           ServiceCallback action) {
        Result result = null;
        try {
            // 執行校驗
            action.check();
            //鎖操作
            action.doLock();

            // 執行處理邏輯
            result = action.executeService();
            //可以對結果進行初步校驗TODO
            

        } catch (自定義異常 e) {
            //打日志TODO
            return (T) result;

        } catch (Throwable e2) {
          //打日志TODO
            return (T) result;
        }

        return (T) result;
    }

    @Override
    @SuppressWarnings("unchecked")
    public <T> T execute(final Class<? extends Result> clazz, final ServiceCallback action) {
        T acResult = (T) transactionTemplate.execute(new TransactionCallback() {
            /**
             * @see org.springframework.transaction.support.TransactionCallback#doInTransaction(org.springframework.transaction.TransactionStatus)
             */
            public Object doInTransaction(TransactionStatus status) {

                Result result = null;

                try {

                    result = clazz.newInstance();
                    // 執行校驗邏輯
                    action.check();
           
                    //鎖操作
                    action.doLock();
               
                    // 執行處理邏輯
                    result = action.executeService();
                    // 返回值異常處理
                    if (result == null || !(result instanceof BaseResult)) {
                        throw new 自定義異常;
                    }

                } catch (自定義異常 e) {
                    // 業務異常捕獲, 回滾, 打日志TODO
                   
                    status.setRollbackOnly();
          
                    return result;
                } catch (Throwable e2) {
                    // 系統異常捕獲, 回滾, 打日志TODO
                    status.setRollbackOnly();
                    return result;
                }
                return result;
            }
        });
        return acResult;
    }

}

 

3, 在業務方法中使用ServiceTemplate, 通過構建ServiceCallBack匿名內部類的方式, 傳遞具體的業務代碼:

 public Result update(final BaseOrder baseOrder) {
        return serviceTemplate.execute(BooleanResult.class, new ServiceCallback() {
            @Override
            public void doLock() {
                //進行鎖操作
            }

            @Override
            public void check() {
              //進行校驗
            }

            @Override
            public Result executeService() {
                Result result = new Result();
                //具體的業務代碼
                return result;
            }
        });
    }

注意: 如果是不需要加事務的方法, 如查詢 ,那么調用serviceTemplate的executeWithoutTransaction即可