開始的時(shí)候項(xiàng)目沒有添加互斥鎖，用的依然是老的思路，在并發(fā)量增加的情況下，遇到了很多的問題，包括數(shù)據(jù)庫重復(fù)讀等，想了下考慮增加 互斥鎖來排序?qū)蝹€(gè)資源的操作。

　　

@Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) @Documented @Order(1) public @interface DistributeLock {LockType type() default LockType.Id;enum LockType {Id,Function;} }

　　? 實(shí)現(xiàn)了兩個(gè)方式，用注解+Aspect的方式 和 try(Closeable){} 的方式確保鎖的釋放。

?　　 實(shí)現(xiàn)依托于redis的?

String result = conn.set(key, value, "NX", "PX", expire);
　　方法，該方法在單節(jié)點(diǎn)和集群下都可用。我測試用的單節(jié)點(diǎn)生產(chǎn)cluster集群都測試通過。
　　
　　 public class MutexLock implements Closeable {RedisCache redisCache;// private boolean isWorkFine = false;private String key;private final String DEFAULT_PREFIX = "DEFAULT";public boolean isWorkFine() {return isWorkFine;}public MutexLock(String prefix, Long id) throws EirException{redisCache = ApplicationContextHelper.getBean(RedisCache.class);if (redisCache == null) {System.out.println("枷鎖 redis 未開啟");return;}this.key = (StringUtil.isNullOrEmpty(prefix) ? DEFAULT_PREFIX : prefix) + ":" + id;Boolean tryGetLock = new RedisUtils(redisCache).setnx(key);if (tryGetLock != null && tryGetLock) {isWorkFine = true;}if (tryGetLock != null && !tryGetLock) {throw new EirException("當(dāng)前資源正忙");}}/*** Closes this stream and releases any system resources associated* with it. If the stream is already closed then invoking this* method has no effect.* <p>* <p> As noted in {@link AutoCloseable#close()}, cases where the* close may fail require careful attention. It is strongly advised* to relinquish the underlying resources and to internally* <em>mark</em> the {@code Closeable} as closed, prior to throwing* the {@code IOException}.** @throws IOException if an I/O error occurs*/@Overridepublic void close() {try {if (isWorkFine) {new RedisUtils(redisCache).releaseLock(this.key);}} catch (Exception e) {e.printStackTrace();}}

?

　　redisUtils 中在getLock的時(shí)候 設(shè)置了等待時(shí)間，5秒鐘，超過之后會(huì)返回“資源正忙”， 鎖也加了超時(shí)時(shí)間， 避免死鎖問題。

測試代碼就不貼了。
　　

　　總結(jié)下來這個(gè)應(yīng)該是最廉價(jià)實(shí)惠的互斥鎖方案了。

　　

轉(zhuǎn)載于:https://www.cnblogs.com/Confirm/p/10131189.html

總結(jié)

以上是生活随笔為你收集整理的JAVA 分布式环境 Redis互斥锁的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。