类：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的异常则此锁会直接抛异常
