<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
 </dependency>

spring.redis.host=xxx
spring.redis.port=6379
spring.redis.database=0
spring.redis.password=xxx
spring.redis.timeout=10000

# 設(shè)置jedis連接池
spring.redis.jedis.pool.max-active=50
spring.redis.jedis.pool.min-idle=20

/**
 * @author Chkl
 * @create 2020/6/7
 * @since 1.0.0
 */
@Component
public class RedisConfig {
  /**
   * 改造RedisTemplate，重寫(xiě)序列化規(guī)則，避免存入序列化內(nèi)容看不懂
   * @param connectionFactory
   * @return
   */
  @Bean
  public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
    RedisTemplate redisTemplate = new RedisTemplate();
    redisTemplate.setConnectionFactory(connectionFactory);
    // 設(shè)置key和value的序列化規(guī)則
    redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer(Object.class));
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    return redisTemplate;
  }
}

@Component
public class RedisLock {

  @Autowired
  private StringRedisTemplate redisTemplate;

  private long timeout = 3000;

  /**
   * 上鎖
   * @param key 鎖標(biāo)識(shí)
   * @param value 線程標(biāo)識(shí)
   * @return 上鎖狀態(tài)
   */
  public boolean lock(String key, String value) {
    long start = System.currentTimeMillis();
    while (true) {
      //檢測(cè)是否超時(shí)
      if (System.currentTimeMillis() - start > timeout) {
        return false;
      }
      //執(zhí)行set命令
      Boolean absent = redisTemplate.opsForValue().setIfAbsent(key, value, timeout, TimeUnit.MILLISECONDS);//1
      //是否成功獲取鎖
      if (absent) {
        return true;
      }
      return false;
    }
  }
}

Boolean absent = redisTemplate.opsForValue().setIfAbsent(key, value, timeout, TimeUnit.MILLISECONDS);

@Component
public class RedisLock {
  @Autowired
  private StringRedisTemplate redisTemplate;

  @Autowired
  private DefaultRedisScript<Long> redisScript;

  private static final Long RELEASE_SUCCESS = 1L;


  /**
   * 解鎖
   * @param key 鎖標(biāo)識(shí)
   * @param value 線程標(biāo)識(shí)
   * @return 解鎖狀態(tài)
   */
  public boolean unlock(String key, String value) {
    //使用Lua腳本：先判斷是否是自己設(shè)置的鎖，再執(zhí)行刪除
    Long result = redisTemplate.execute(redisScript, Arrays.asList(key,value));
    //返回最終結(jié)果
    return RELEASE_SUCCESS.equals(result);
  }


  /**
   * @return lua腳本
   */
  @Bean
  public DefaultRedisScript<Long> defaultRedisScript() {
    DefaultRedisScript<Long> defaultRedisScript = new DefaultRedisScript<>();
    defaultRedisScript.setResultType(Long.class);
    defaultRedisScript.setScriptText("if redis.call('get', KEYS[1]) == KEYS[2] then return redis.call('del', KEYS[1]) else return 0 end");
    return defaultRedisScript;
  }
}

	/**
   * 保存文件分塊編號(hào)到redis
   * @param chunkNumber 分塊號(hào)
   * @param identifier 文件唯一編號(hào)
   * @return 文件分塊的大小
   */
  @Override
  public Integer saveChunk(Integer chunkNumber, String identifier) {
  	//從Redis獲取已經(jīng)存在的分塊編號(hào)集合
    Set<Integer> oldChunkNumber = (Set<Integer>) JSON.parseObject(redisOperator.get("chunkNumberList_"+identifier),Set.class);
    //如果不存在分塊集合，創(chuàng)建一個(gè)集合
    if (Objects.isNull(oldChunkNumber)) {
      Set<Integer> newChunkNumber = new HashSet<>();
      newChunkNumber.add(chunkNumber);
      redisOperator.set("chunkNumberList_"+identifier, JSON.toJSONString(newChunkNumber),36000);
      return newChunkNumber.size();
     //如果分塊集合已經(jīng)存在了，就添加一個(gè)編號(hào)
    } else {
      oldChunkNumber.add(chunkNumber);
      redisOperator.set("chunkNumberList_"+identifier, JSON.toJSONString(oldChunkNumber),36000);
      return oldChunkNumber.size();
    }
  }

/**
   * 保存文件分塊編號(hào)到redis
   * @param chunkNumber 分塊號(hào)
   * @param identifier 文件唯一編號(hào)
   * @return 文件分塊的大小
   */
  @Override
  public Integer saveChunk(Integer chunkNumber, String identifier) {
  	//通過(guò)UUID生成一個(gè)請(qǐng)求線程識(shí)別標(biāo)志作為鎖的value
    String threadUUID = CoreUtil.getUUID();
    //上鎖，以共享資源標(biāo)識(shí):文件唯一編號(hào),作為key，以線程標(biāo)識(shí)UUID作為value
    redisLock.lock(identifier,threadUUID);
    //從Redis獲取已經(jīng)存在的分塊編號(hào)集合
    Set<Integer> oldChunkNumber = (Set<Integer>) JSON.parseObject(redisOperator.get("chunkNumberList_"+identifier),Set.class);
    //如果不存在分塊集合，創(chuàng)建一個(gè)集合
    if (Objects.isNull(oldChunkNumber)) {
      Set<Integer> newChunkNumber = new HashSet<>();
      newChunkNumber.add(chunkNumber);
      redisOperator.set("chunkNumberList_"+identifier, JSON.toJSONString(newChunkNumber),36000);
      //解鎖
      redisLock.unlock(identifier,threadUUID);
      return newChunkNumber.size();
     //如果分塊集合已經(jīng)存在了，就添加一個(gè)編號(hào)
    } else {
      oldChunkNumber.add(chunkNumber);
      redisOperator.set("chunkNumberList_"+identifier, JSON.toJSONString(oldChunkNumber),36000);
      //解鎖
      redisLock.unlock(identifier,threadUUID);
      return oldChunkNumber.size();
    }
  }