redis锁

1.锁代码

	private boolean first(String key) {
		return redisUtils.setIfAbsent(key, "syn", 30, TimeUnit.SECONDS);
	}

	private Object syn(String synkey, RedisSynHandle handle) {
		boolean first = false;
		try {
			first = first(synkey);
			if (first) {
				return handle.handle();
			} else {
				throw new StandardException("请求频繁");
			}
		} finally {
			if (first) {
				finalEnd(synkey);
			}
		}
	}

	private void finalEnd(String key) {
		if (StringUtils.isNotBlank(key)) {
			redisUtils.del(key);
		}
	}

	public interface RedisSynHandle {
		//业务处理
		Object handle();
	}

	/**
     * 保存 若key已存在返回false,反之返回true
     */
    public boolean setIfAbsent(String key, String value) {
        logger.debug("Redis setIfAbsent key:{},value:{}", key, value);
        Boolean result = redistemplate.opsForValue().setIfAbsent(key, value);
        return result != null && result;
    }

    /**
     * 保存 若key已存在返回false,反之返回true 同时设置有效时间
     */
    public boolean setIfAbsent(String key, String value, long time, TimeUnit timeUnit) {

        logger.debug("Redis setIfAbsent key:{},value:{},time:{},timeUnit:{}", key, value, time, timeUnit);
        try {
            return setIfAbsent(key, value);
        }finally {
            redistemplate.boundValueOps(key).expire(time, timeUnit);
        }
    }

2.使用

	@Override
	@Transactional(rollbackFor = Throwable.class)
	public Object refund(Xxx xxx) {
		return syn("xxx:xxx:xxx:refund:" + xxx.getId,()-> {
		});
	}