不可重入锁和可重入锁

类：BccSoaHelper
public startLockOnlyOne() throws Exception{

        String billCacheKey = createCacheKey(billId);
        try {
            // 第一层控制：手机号码
            addKeyAndValue2AllServer(billCacheKey, billCacheKey, expireSeconds);
        } catch (BusinessConcurrentControlException e) {
            ExceptionUtil.throwBusinessException(BsI18nResource.SOS11120180, billId);
        }
}

这个方法在下面的一个场景里面执行不会有问题，都可以很好的处理两个业务对同一个号码互斥执行的需求，如果两个方法并发执行，都进入到了临界区，那么会争用该全局锁，最后只有一个方法会执行成功；另外一个方法会直接抛异常，事务回滚，告知调用方此时有另外一个业务在执行，暂时不能执行当前业务

public method1OnSv1() throws Exception{
...临界区

    BccSoaHelper.startLockOnlyOne()；
...
}

public method2OnSv2() throws Exception{
...临界区
    BccSoaHelper.startLockOnlyOne()；
...
}

假如某个SV层同时调用了两次这个方法，这个SV的代码会因为抛出异常回滚，此时我们可以说这个锁是不可重入

public method1OnSv1() throws Exception{
...临界区
    ...假如某个逻辑里面执行了第一次订单受理
     //
     BccSoaHelper.startLockOnlyOne()；
    ...假如某个逻辑里面执行了第二次订单受理，必抛异常
     //
     BccSoaHelper.startLockOnlyOne()；
...
}

所以要对其再进行再一步的加深区分，使其可以重入；一般来说，出现上面所说的不可重入的情况的，都应该是在“同一个方法”执行过程中调用了两次该锁，而我们的SOA里面的SV的调用应该就是与该“同一个方法”类似，在这个SOA调用里面因为可能调用不同的中心不同的业务SV，而这个业务SV是否调用了该全局锁是不清楚的，所以有可能会因为该锁在同一个SOA的SV里面不可重入导致事务回滚，所以要实现同一个SOA调用里面的可重入。

然后巧妙的使用session管理器实现“同一个SOA”里面的可重入，因为session的生命周期刚好就贯穿整个SOA调用，使用其保存一些额外信息来区分是否是同一个SOA里面的调用正好不过，如果判断是同一个SOA第二次或者更多的对锁的调用，那么就不抛出异常，这样就可以实现可重入了，下面是完整的代码

public static void beginBusiCtrlForJX(String billId, long mainBusinessId, short expireSeconds) throws Exception {       
        String billCacheKey = createCacheKey(billId);
        String soaInvokeCacheKey = createCacheKey(getSoaInvokeBccUniqueIndex(billId));
        try {
            // 第一层控制：手机号码
            addKeyAndValue2AllServer(billCacheKey, billCacheKey, expireSeconds);
        } catch (BusinessConcurrentControlException e) {
            // 会进入此分支，代表已经通过了BillId进行了并发控制
            try {
                addKeyAndValue2AllServer(soaInvokeCacheKey, soaInvokeCacheKey, expireSeconds);
            } catch (BusinessConcurrentControlException e2) {// 如果此时抛异常，说明是单一SOA服务调用，同一session的同一个的第二次SOA调用也会在这里
                log.info("<<<<<<<<<<<<<<<<<<<<<单一SOA服务调用, 属于正常场景>>>>>>>>>>>>>>>>>>>>>");
                return;
            }
            try {
                BccUtil.delete(soaInvokeCacheKey);
            } catch (Exception e2) {
                log.error("<<<<<<<<<<<<<<<<<<<<<用户正在受理其他订单类业务，请稍后再试！>>>>>>>>>>>>>>>>>>>>>");
            }
            ExceptionUtil.throwBusinessException(BsI18nResource.SOS11120180, billId);
        } catch (Exception e) {
            log.error(ExceptUtil.getExceptionDtl(e));
        }
        try {
            addKeyAndValue2AllServer(soaInvokeCacheKey, soaInvokeCacheKey, expireSeconds);
        } catch (Exception e) {
            log.error("<<<<<<<<<<<<<<<<<<<<<并发控制失败>>>>>>>>>>>>>>>>>>>>>");
        }
    }


/**
     * 获取Soa服务调用对应的BCC并发控制唯一索引
     * 
     * @param billId
     * @return
     * @throws Exception
     */
    private static String getSoaInvokeBccUniqueIndex(String billId) throws Exception {
        Object bccUniqueIndexObject = SessionManager.getUser().get(BCC_UNIQUE_INDEX);
        String bccUniqueIndex = StringUtils.EMPTY;
        if (null == bccUniqueIndexObject) {
            bccUniqueIndex = generateBccUniqueIndex(billId);// 缓存中没有，则生成一条唯一索引值
            SessionManager.getUser().set(BCC_UNIQUE_INDEX, bccUniqueIndex);
        } else {
            bccUniqueIndex = (String) bccUniqueIndexObject;
        }
        return bccUniqueIndex;
    }

备注：session必须是全局共享的或者是每次都可以通过负载均衡到同一个web容器的，同时，如果memcached的异常则此锁会直接抛异常