Redis工具类

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.concurrent.locks.ReentrantLock;

public class RedisUtil{
    
	private static final ReentrantLock lock = new ReentrantLock();

    
	public static String getValue(String primaryKey)
	{
		Jedis jedis = RedisDB.getPool().getResource();
		lock.lock();// 加上锁
		try
		{
			if (jedis.exists(primaryKey)) // 如存在就拿出最大的primaryKey值
				return jedis.get(primaryKey);
		}
		finally
		{
			// 使用完后，将连接放回连接池
			RedisDB.getPool().returnResourceObject(jedis);
			lock.unlock();// 释放锁
		}
		return null;
	}

    
	public static void setValue(String primaryKey, String value,int validityTime)
	{
		Jedis jedis = RedisDB.getPool().getResource();
		lock.lock();// 加上锁
		try
		{
			if (value != null && !"".equals(value))
			{
				jedis.set(primaryKey, value);
				//设置有效时间
				if(validityTime > 0)
					jedis.expire(primaryKey, validityTime);
			}
		}
		finally
		{
			// 使用完后，将连接放回连接池
			RedisDB.getPool().returnResourceObject(jedis);
			lock.unlock();// 加上锁
		}
	}
}