麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久99热浪潮_成人一区二区三区四区

首頁 > 數據庫 > Redis > 正文

淺析Redis分布式鎖

2020-10-28 21:34:54
字體:
來源:轉載
供稿:網友

近期工作遇到需要業務場景如下,需要每天定時推送給另一系統一批數據,但是由于系統是集群部署的,會造成統一情況下任務爭用的情況,所以需要增加分布式鎖來保證一定時間范圍內有一個Job來完成定時任務. 前期考慮的方案有采用ZooKeeper分布式任務,Quartz分布式任務調度,但是由于Zookeeper需要增加額外組件,Quartz需要增加表,并且項目中現在已經有Redis這一組件存在,所以考慮采用Redis分布式鎖的情況來完成分布式任務搶占這一功能

記錄一下走過的彎路.

第一版本:

@Override	public <T> Long set(String key,T value, Long cacheSeconds) {		if (value instanceof HashMap) {			BoundHashOperations valueOperations = redisTemplate.boundHashOps(key);			valueOperations.putAll((Map) value);			valueOperations.expire(cacheSeconds, TimeUnit.SECONDS);		}		else{		//使用map存儲		BoundHashOperations valueOperations = redisTemplate.boundHashOps(key);		valueOperations.put(key, value);		//秒		valueOperations.expire(cacheSeconds, TimeUnit.SECONDS);		}		return null;	}	@Override	public void del(String key) {		redisTemplate.delete(key);	}

采用set 和 del 完成鎖的占用與釋放,后經測試得知,set不是線程安全,在并發情況下常常會導致數據不一致.

第二版本:

/**   * 分布式鎖   * @param range 鎖的長度 允許有多少個請求搶占資源   * @param key   * @return   */  public boolean getLock(int range, String key) {    ValueOperations<String, Integer> valueOper1 = template.opsForValue();    return valueOper1.increment(key, 1) <= range;  }  /**   * 初始化鎖, 設置等于0   * @param key   * @param expireSeconds   * @return   */  public void initLock(String key, Long expireSeconds) {    ValueOperations<String, Integer> operations = template.opsForValue();    template.setKeySerializer(new GenericJackson2JsonRedisSerializer());    template.setValueSerializer(new GenericJackson2JsonRedisSerializer());    operations.set(key, 0, expireSeconds * 1000);  }  /**   * 釋放鎖   * @param key   */  public void releaseLock(String key) {    ValueOperations<String, Integer> operations = template.opsForValue();    template.setKeySerializer(new GenericJackson2JsonRedisSerializer());    template.setValueSerializer(new GenericJackson2JsonRedisSerializer());    template.delete(key);  }

采用redis的 increament操作完成鎖的搶占.但是釋放鎖時,是每個線程都可以刪除redis中的key值. 并且initLock會降上一次的操作給覆蓋掉,所以也廢棄掉此方法

最終版本:

import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.connection.jedis.JedisConnection;import org.springframework.stereotype.Service;import org.springframework.util.ReflectionUtils;import redis.clients.jedis.Jedis;import java.lang.reflect.Field;import java.util.Collections;@Servicepublic class RedisLock {  private static final String LOCK_SUCCESS = "OK";  private static final String SET_IF_NOT_EXIST = "NX";  private static final String SET_WITH_EXPIRE_TIME = "PX";  private static final Long RELEASE_SUCCESS = 1L;  @Autowired  private RedisConnectionFactory connectionFactory;  /**   * 嘗試獲取分布式鎖   * @param lockKey 鎖   * @param requestId 請求標識   * @param expireTime 超期時間   * @return 是否獲取成功   */  public boolean lock(String lockKey, String requestId, int expireTime) {    Field jedisField = ReflectionUtils.findField(JedisConnection.class, "jedis");    ReflectionUtils.makeAccessible(jedisField);    Jedis jedis = (Jedis) ReflectionUtils.getField(jedisField, connectionFactory.getConnection());    String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);    if (LOCK_SUCCESS.equals(result)) {      return true;    }    return false;  }  /**   * 釋放分布式鎖   * @param lockKey 鎖   * @param requestId 請求標識   * @return 是否釋放成功   */  public boolean releaseLock(String lockKey, String requestId) {    String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";    Object result = getJedis().eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));    if (RELEASE_SUCCESS.equals(result)) {      return true;    }    return false;  }  public Jedis getJedis() {    Field jedisField = ReflectionUtils.findField(JedisConnection.class, "jedis");    ReflectionUtils.makeAccessible(jedisField);    Jedis jedis = (Jedis) ReflectionUtils.getField(jedisField, connectionFactory.getConnection());    return jedis;  }}

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 亚洲成人免费电影 | 久久情爱网 | 91九色福利 | 日日操夜 | 国产一区二区在线免费 | 欧美一级毛片一级毛片 | 天天操天天碰 | 久久久婷婷一区二区三区不卡 | 91精品国产综合久久久动漫日韩 | 在线a毛片免费视频观看 | 久久精品国产精品亚洲 | 免费国产一区二区视频 | 韩国一大片a毛片 | 蜜桃久久一区二区三区 | 7777久久香蕉成人影院 | 日本看片一区二区三区高清 | 国产免费传媒av片在线 | 在线播放免费人成毛片乱码 | 亚洲第一成人在线 | 中国hd高清xxxxvideo | 国产精品91在线 | 国产精品久久久久久238 | 在线观看一二三 | 中文字幕亚洲一区二区三区 | 欧美大穴 | 看免费一级毛片 | 9191色 | 羞羞的| 午夜精品区 | 一道本不卡一区 | 日韩字幕在线观看 | 国产一区二区在线观看视频 | 精品国产一区二区亚洲人成毛片 | 久久亚洲精品久久国产一区二区 | 日韩av片在线播放 | 国产黄色网 | 91国在线高清视频 | 欧美18—19sex性hd按摩 | 欧美亚洲啪啪 | 91精品国产99久久久久久红楼 | 欧美综合在线观看视频 |