redis防止重复提交

不信网恋

//
　　
// Source code recreated from a .class file by IntelliJ>　　
// (powered by Fernflower decompiler)
　　
//
　　

　　
package com.pt.platform.core.redis.lock;
　　

　　
import com.pt.platform.core.ehcache.ObtainPropertiesInfo;
　　
import com.pt.platform.core.redis.JedisSentinelPool;
　　
import com.pt.platform.core.redis.lock.DistributedLock;
　　
import org.slf4j.Logger;
　　
import org.slf4j.LoggerFactory;
　　
import redis.clients.jedis.ShardedJedis;
　　
import redis.clients.util.SafeEncoder;
　　


　　
public>　　private static final Logger logger = LoggerFactory.getLogger(RedisLock.class);
　　private static final int DEFAULT_EXPIRE_TIME = 60;
　　private static final String LOCK_KEY_PREFIX = "REDIS_LOCK";
　　private JedisSentinelPool pool;
　　

　　public RedisLock() {
　　}
　　

　　public JedisSentinelPool getPool() {
　　return this.pool;
　　}
　　

　　public void setPool(JedisSentinelPool pool) {
　　this.pool = pool;
　　}
　　

　　public boolean getLock(String module, String bizKey, int expireTime) {
　　if(module != null && !"".equals(module) && bizKey != null && !"".equals(bizKey)) {
　　if(this.getPool() != null) {
　　ShardedJedis jedis = null;
　　String lockKey = this.getLockKey(module, bizKey);
　　

　　boolean var10;
　　try {
　　jedis = (ShardedJedis)this.getPool().getResource();//获取到数据源
　　long e = System.currentTimeMillis();
　　long result = jedis.setnx(SafeEncoder.encode(lockKey), SafeEncoder.encode(e + "")).longValue();
　　if(result == 1L) {
　　if(expireTime > 0) {
　　jedis.expire(SafeEncoder.encode(lockKey), expireTime);
　　if(logger.isDebugEnabled()) {
　　logger.debug("key：" + lockKey + " locked and expire time:" + expireTime + "s");
　　}
　　} else {
　　jedis.expire(SafeEncoder.encode(lockKey), 60);
　　if(logger.isDebugEnabled()) {
　　logger.debug("key：" + lockKey + " locked and expire time:" + 60 + "s");
　　}
　　}
　　

　　var10 = true;
　　return var10;
　　}
　　

　　if(logger.isDebugEnabled()) {
　　logger.debug("key：" + lockKey + " has already bean locked");
　　}
　　

　　var10 = false;
　　} catch (Exception var14) {
　　logger.error("lock error", var14);
　　boolean var7 = false;
　　return var7;
　　} finally {
　　this.getPool().returnResource(jedis);
　　}
　　

　　return var10;
　　} else {
　　logger.error("jedisSentinelPool is null");
　　return true;
　　}
　　} else {
　　logger.error("parameters is null");
　　return false;
　　}
　　}
　　

　　//删除key值释放锁
　　public void unLock(String module, String bizKey) {
　　if(module == null || "".equals(module) || bizKey == null || "".equals(bizKey)) {
　　logger.error("parameters is null");
　　}
　　

　　if(this.getPool() != null) {
　　ShardedJedis jedis = null;
　　String lockKey = this.getLockKey(module, bizKey);
　　

　　try {
　　jedis = (ShardedJedis)this.getPool().getResource();
　　jedis.del(SafeEncoder.encode(lockKey));
　　} catch (Exception var9) {
　　logger.error("unlock error", var9);
　　} finally {
　　this.getPool().returnResource(jedis);
　　}
　　} else {
　　logger.error("jedisSentinelPool is null");
　　}
　　

　　}
　　

　　//组装key值
　　private String getLockKey(String module, String bizKey) {
　　StringBuffer sb = new StringBuffer();
　　sb.append("REDIS_LOCK").append(":").append(ObtainPropertiesInfo.getValByKey("app.code")).append(":").append(module).append(":").append(bizKey);
　　return sb.toString();
　　}
　　
}