@Resource
private RedisTemplate<String, String> redisTemplate;
// 超时时间，以毫秒为单位
private final long timeout = 2000;

@Test
public void testLock() {
    // 用于判断交易唯一性和合法性的Token，在交易执行之前先保存在服务端，
    // 并且下发给客户端，客户端会在执行交易之前把Token带上，没带Token的
    // 请求、Token不存在的服务端的请求、Token不正确的请求都视为非法请求
    String token = "...";
    String key = MD5Util.md5Of32(token);
    String lockKey = new StringBuilder(key).append("_lock").toString();
    boolean isGetKey = getLock(lockKey);
    if (!isGetKey) {
        log.warn("当前交易正在被处理中");
    }
    boolean handleSuccess = false;
    try {
        log.info("处理交易开始");
        String storedToken = redisTemplate.opsForValue().get(key);
        // 判断Token是否存在且合法
        if (!token.equals(storedToken)) {
            log.warn("指定的Token不存在.");
            return;
        }
        handleSuccess = true;
        log.info("处理交易结束");
    } catch (Exception e) {
        log.info("处理发生异常", e);
    } finally {
        if (handleSuccess) {
            // 限制了单个Token只能够执行一笔记交易，因而执行成功后将其删除
            List<String> keys = new ArrayList<String>();
            keys.add(key);// 限制了单个Token只能够执行一笔记交易，因而执行成功后将其删除
            keys.add(lockKey);// 用于表示锁的key删除，表示释放掉锁
            redisTemplate.delete(keys);
        } else {
            // 删除用于锁定的key
            redisTemplate.delete(lockKey);
        }
    }
}

/**
 * 原理是从redis中获取到的lockKey的值是不是存在，如果不存在表示写入的是当前值，表示锁获取成功；
 * 如果获取到的值存在，再判断是否已经超过了指定的期限，如果超过了指定的期限，则认为锁获取成功，否则认为锁获取失败；
 * 
 * @param lockKey 用于获取锁定的key
 * @return true表示获取到锁，false表示未获取到锁
 */
public boolean getLock(String lockKey) {
    long now = System.currentTimeMillis();
    // Redis的GetSet返回的值必须是字符串，否则会抛异常，因而将其转换为字符串
    String nowTime = String.valueOf(now);
    String oldTime = null;
    // 判断用于锁定的key是否已经被设置了值，如果被设置了值，则用于控制后续的处理逻辑不再进行
    if ((oldTime = redisTemplate.opsForValue().getAndSet(lockKey, nowTime)) != null) {
        // 检查锁lockKey的值是不是超过了设定的时间，如2秒钟，没有超过则返回，不继续处理后续的任务；
        // 注：这个逻辑有个问题，就是客户端在2秒钟之内不停的重试，就永远不会进入到后面的处理环节。
        // 不过针对正常的业务请求这个是可以约定的，针对非正常的请求，被拦截也很正常，所以这个问题不是问题。
        if (now - Long.parseLong(oldTime) < timeout) {
            return false;
        }
        return true;
    }
    return true;
}

/**
 * 根据setnx的命令的特性，如果写入数据成功，可以用于当示锁获取成功，写入失败表示未获取到锁
 * 
 * @param lockKey
 * @param value
 * @param expire
 * @return true表示获取到锁，false表示未获取到锁
 */
public boolean getLock(String lockKey) {
    long now = System.currentTimeMillis();
    // Redis的GetSet返回的值必须是字符串，否则会抛异常，因而将其转换为字符串
    String nowTime = String.valueOf(now);
    RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
    JedisCommands commands = (JedisCommands) connection.getNativeConnection();
    boolean con = false;
    do {
        con = false;
        // 返回1表示锁获取成功，返回0表示锁取失败
        String result = commands.set(lockKey, nowTime, "NX", "PX", expire);
        if ("1".equals(result)) {
            return true;
        } else {
            String oldTime = redisTemplate.opsForValue().get(lockKey);
            // 检查锁lockKey的值是不是超过了设定的时间，如2秒钟，如果超过了则继续尝试获取锁，直到获取到锁，或者数据未超期时退出；
            // 循环判断可以解决死锁的问题
            if (now - Long.parseLong(oldTime) >= expire) {// 数据已经过期了
                con = true;
            }
        }
    } while (con);
    return false;
}