分布式锁说明

Java中的锁：当多个线程去访问共享数据时，防止一些操作被覆盖（并发问题），这个时候就需要用到抢锁机制，抢到锁的线程才能进行操作，其余线程等待锁释放并抢到锁才能进行操作，例如Sychonized,Lock等。

分布式锁和java中的锁最大的区别在于共享资源是由多个进程去访问，这时候线程之间的锁机制就无法起到作用了，所以就需要引入一些可以被所有服务都能访问的外部服务来让实现锁，例如数据库，Redis，Zookeeper等

SpringBoot中实现

maven依赖

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

Redis配置

  # redis  
  redis:
    host: 192.168.0.100 # Redis服务器地址
    database: 0 # Redis数据库索引
    port: 6379 # Redis服务器连接端口
    password: XXX # Redis服务器连接密码
    timeout: 3000ms # 连接超时时间（毫秒）
    jedis:
      pool:
        max-active: 512 # 连接池最大连接数（使用负值表示没有限制）
        max-wait: -1ms # 连接池最大阻塞等待时间（使用负值表示没有限制）
        max-idle: 10 # 连接池中的最大空闲连接
        min-idle: 10 # 连接池中的最小空闲连接

Java代码实现

package com.framework.system.util;

import org.apache.commons.lang3.StringUtils;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.concurrent.TimeUnit;

/**
 * @description: redis获取分布式锁
 */
@Component
public class RedisUtilExt {

	/**
	 * 默认锁超时时间
	 */
	private final static long DEFAULT_TIMEOUT = 30000;

	@Resource(name = "stringRedisTemplate")
	private RedisTemplate<String, String> stringRedisTemplate;

	/**
	 * 获取redis锁
	 * 
	 * @param key
	 * @return
	 */
	public boolean getLock(String key) {
		// value值为系统当前时间
		if (stringRedisTemplate.opsForValue().setIfAbsent(key, String.valueOf(System.currentTimeMillis()))) {
			// 设置超时时间 防止死锁
			stringRedisTemplate.expire(key, DEFAULT_TIMEOUT, TimeUnit.MILLISECONDS);
			return true;
		}
		// 获取上锁时间，判断锁是否超时，超时则删除key（redis重启会造成重启时间内一些过期的key未被清理）,防止死锁
		String valueTime = stringRedisTemplate.opsForValue().get(key);
		if (StringUtils.isNotEmpty(valueTime)
				&& System.currentTimeMillis() - Long.parseLong(valueTime) > DEFAULT_TIMEOUT) {
			// 释放锁，再次抢锁
			unLock(key);
			return getLock(key);
		}
		return false;
	}

	/**
	 * 释放锁
	 * 
	 * @param key
	 */
	public void unLock(String key) {
		stringRedisTemplate.opsForValue().getOperations().delete(key);
	}

}

在业务中的应用

import com.framework.system.util.RedisUtilExt;
@Autowired
	private RedisUtilExt redisUtilExt;
  // 省略。。。
  if (!redisUtilExt.getLock("SYNC_DATA"))
			return;
  // 业务代码。。。