麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久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九色视频在线播放 | 亚洲精中文字幕二区三区 | 免费毛片电影 | 欧美性猛交xxx乱大交3蜜桃 | av手机在线电影 | 免费看成人毛片 | 亚洲国产精品久久久 | 欧美日韩一区三区 | 欧美日本91精品久久久久 | 毛片毛片| 日本成人一二三区 | 国产免费v片 | 国产精品久久久久久久久久妇女 | 欧美一级黄色片免费观看 | 成人午夜影院 | 毛片视频网址 | 成人国产免费观看 | 91精选视频在线观看 | 国产毛片网 | 中国漂亮护士一级a毛片 | 91成人天堂久久成人 | 日本视频在线播放 | 天天看夜夜爽 | 日韩美女电影 | 免费人成年短视频在线观看网站 | 精品国产96亚洲一区二区三区 | 欧美在线观看视频网站 | 日韩在线播放一区二区 | 欧产日产国产精品99 | 久久免费视频精品 | 黄色aaa视频| 日本在线不卡一区二区 | 国产91久久久 | 中午字幕无线码一区2020 | 日韩精品免费一区二区三区 | a在线视频 | 久草在线资源视频 | 国产九色在线观看 | 久久人人爽人人爽人人片av高清 |