可以设置为使Java过期的全局分布式锁

作者: 昵称不能为空
发布时间: 2024-12-17 10:08:25 (16天前)
转自：

3 条回复

0#
回复此人
枫 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 这个如何？ <a href="http://www.gemstone.com/docs/5.5.0/product/docs/japi/com/gemstone/gemfire/distributed/DistributedLockService.html" rel="nofollow"> http://www.gemstone.com/docs/5.5.0/product/docs/japi/com/gemstone/gemfire/distributed/DistributedLockService.html </A> </p> <P> 它的 <code> lock </code> 方法似乎有你需要的： </p> <P> <code> public abstract boolean lock(Object name, long waitTimeMillis, long leaseTimeMillis) </code> </p> <P> 尝试获取名为name的锁。获取锁定后立即返回true。如果锁当前由分布式系统中的此进程或任何其他进程中的另一个线程持有，或者系统中的另一个线程已锁定整个服务，则此方法在放弃并返回false之前一直尝试获取最多等待waitMillis的锁。如果获取了锁，则会一直保持锁定，直到调用unlock（对象名称），或者直到从授予锁定起已经过了leaseTimeMillis毫秒 - 以先到者为准。 </p> </DIV>

编辑
1#
回复此人
浮华丶 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 实际上，据我所知 <a href="https://github.com/deftlabs/mongo-java-distributed-lock" rel="nofollow"> 蒙戈-Java的分布式锁 </A> 有能力通过使用到期锁定 <a href="https://github.com/deftlabs/mongo-java-distributed-lock/blob/master/src/main/com/deftlabs/lock/mongo/DistributedLockOptions.java" rel="nofollow"> <code> DistributedLockOptions.setInactiveLockTimeout() </code> </A> </p> <P> 我还没有尝试过，但我想我会...... </p> <P> 编辑：我现在也尝试过，它运作良好...... </p> <pre> <code> String lockName = "com.yourcompany.yourapplication.somelock"; int lockTimeoutMilliSeconds = 500; String dbURI = CWConfig.get().getMongoDBConfig().getDbURI(); DistributedLockSvcFactory lockSvcFactory = new DistributedLockSvcFactory(new DistributedLockSvcOptions(dbURI)); DistributedLockSvc lockSvc = lockSvcFactory.getLockSvc(); DistributedLock lock = lockSvc.create(lockName); lock.getOptions().setInactiveLockTimeout(lockTimeoutMilliSeconds); try { lock.lock(); // Do work } finally { lock.unlock(); } </code> </pre> </DIV>

编辑

登录后才能参与评论