经常会使用到在一个事物中调用rpc的接口,在同一个事物还没有提交的时候,rpc的接口已经被执行过了,但是rpc的接口不受当前事物的控制,会造成数据错乱的问题。 那我们如何解决呢
public boolean tryLock(String lockName, long lockTimeout){ logger.info("请求分布式锁, 名称:{}, 超时:{}", lockName, lockName); ShardedJedis jedis = this.getJedis(); lockName = "_distribute_lock_" + lockName; try { int i = 0; while (true) { i++; logger.info("第{}次获得锁", i); long expires = DateUtils.current().getTime() + lockTimeout + 1; String expiresStr = String.valueOf(expires); //锁到期时间 if (jedis.setnx(lockName, expiresStr) == 1) { logger.info("获得 {} 锁成功", lockName); return true; } String currentValueStr = jedis.get(lockName); //redis里的时间 //判断是否为空,不为空的情况下,如果被其他线程设置了值,则第二个条件判断是过不去的 if (currentValueStr != null && Long.parseLong(currentValueStr) < System.currentTimeMillis()) { String oldValueStr = jedis.getSet(lockName, expiresStr); //获取上一个锁到期时间,并设置现在的锁到期时间, //只有一个线程才能获取上一个线上的设置时间,因为jedis.getSet是同步的 if (oldValueStr != null && oldValueStr.equals(currentValueStr)) { //如过这个时候,多个线程恰好都到了这里,但是只有一个线程的设置值和当前值相同,他才有权利获取锁 logger.info("获得超时锁 {} 成功", lockName); return true; } } Thread.sleep(100 * i); } } catch (Exception e) { logger.error("", e); } finally { this.returnRes(jedis); } return false; } public void releaseLock(String lockName){ lockName = "_distribute_lock_" + lockName; ShardedJedis jedis = this.getJedis(); try{ jedis.del(lockName); logger.info("释放分布式锁成功 {} ", lockName); }finally{ this.returnRes(jedis); } }