| | |
|---|
| | | // jiedis原子性做拦截
|
|---|
| | | Jedis jedis = jedisPool.getResource();
|
|---|
| | | long threadId= Thread.currentThread().getId();
|
|---|
| | | LogHelper.test("进入拦截:"+cacheKey+"-"+threadId);
|
|---|
| | | try {
|
|---|
| | | Constant.waitingThreadSet.add(threadId);
|
|---|
| | | String result = null;
|
|---|
| | |
|---|
| | | while (StringUtil.isNullOrEmpty(result)) {
|
|---|
| | |
|
|---|
| | | result = jedis.set(cacheKey, "1", new SetParams().nx().ex(30));
|
|---|
| | | LogHelper.error("触发并发锁:" + cacheAlias);
|
|---|
| | | LogHelper.error("redis键:" + cacheKey);
|
|---|
| | | if (StringUtil.isNullOrEmpty(result)) {
|
|---|
| | | LogHelper.test("等待:"+threadId);
|
|---|
| | | try {
|
|---|
| | | Thread.sleep(50);
|
|---|
| | | } catch (InterruptedException e) {
|
|---|
| | |
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | | } else {
|
|---|
| | | LogHelper.test("获取到锁:"+threadId);
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|---|
| | | e.printStackTrace();
|
|---|
| | | LogHelper.errorDetailInfo(e);
|
|---|
| | | } finally {
|
|---|
| | | LogHelper.test("方法执行完毕:"+threadId);
|
|---|
| | | jedis.del(cacheKey);
|
|---|
| | | Constant.waitingThreadSet.remove(Thread.currentThread().getId());
|
|---|
| | | LogHelper.test("释放锁:"+threadId);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } finally {
|
|---|
