Jedis使用java操作Redis

2019-11-06 06:44:53
字體：大中小
來源：轉載
供稿：網友
引入包：
	<dependency>		<groupId>redis.clients</groupId>		<artifactId>jedis</artifactId>		<version>2.6.1</version>	</dependency>
常量配置:
public class RedisConfig {	//可用連接實例的最大數目，默認值為8；    //如果賦值為-1，則表示不限制；如果pool已經分配了maxActive個jedis實例，則此時pool的狀態為exhausted(耗盡)。    public static int MAX_ACTIVE = 1024;     //控制一個pool最多有多少個狀態為idle(空閑的)的jedis實例，默認值也是8。    public static int MAX_IDLE = 200;     //等待可用連接的最大時間，單位毫秒，默認值為-1，表示永不超時。如果超過等待時間，則直接拋出JedisConnectionException；    public static long MAX_WAIT = 10000;     public static int TIMEOUT = 10000;     public static int RETRY_NUM = 5;}
JedisUtil 獲取Jedis實例及關閉資源
import java.util.HashMap;import java.util.Map;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;public class JedisUtil {	PRivate JedisUtil() {	}	private static class RedisUtilHolder{        private static final JedisUtil instance = new JedisUtil();    }     public static JedisUtil getInstance(){        return RedisUtilHolder.instance;    }	private static Map<String, JedisPool> maps = new HashMap<String, JedisPool>();	private static JedisPool getPool(String ip, int port) {		String key = ip + ":" + port;		JedisPool pool = null;		if (!maps.containsKey(key)) {			JedisPoolConfig config = new JedisPoolConfig();			// config.setMaxActive(RedisConfig.MAX_ACTIVE); //最大連接數			config.setMaxTotal(RedisConfig.MAX_ACTIVE);  //最大連接數			config.setMaxIdle(RedisConfig.MAX_IDLE); ////控制一個pool最多有多少個狀態為idle(空閑的)的jedis實例。			// config.setMaxWait(RedisConfig.MAX_WAIT);			//表示當borrow(引入)一個jedis實例時，最大的等待時間，如果超過等待時間，則直接拋出JedisConnection			config.setMaxWaitMillis(RedisConfig.MAX_WAIT);			config.setTestOnBorrow(true); //jedis調用borrowObject方法時，是否進行有效檢查			config.setTestOnReturn(true); //調用returnObject方法時，是否進行有效檢查 			pool = new JedisPool(config, ip, port, RedisConfig.TIMEOUT);			maps.put(key, pool);		} else {			pool = maps.get(key);		}		return pool;	}		public Jedis getJedis(String ip,int port){		Jedis jedis=null;		int count=0;		do{			try {				count++; 				jedis=getPool(ip, port).getResource();			} catch (Exception e) {				getPool(ip, port).returnBrokenResource(jedis);			}		}while(jedis==null && count<RedisConfig.RETRY_NUM);		return jedis;	}		public void closeJedis(Jedis jedis,String ip,int port){		if(jedis != null)        {            getPool(ip,port).returnResource(jedis);        }	}}
測試類：
import java.util.HashMap;import java.util.Map;import java.util.concurrent.TimeUnit;import redis.clients.jedis.Jedis;import redis.clients.jedis.SortingParams;public class Test {	private static final String ip = "192.168.150.129";	private static final int port = 6379;	private static Jedis jedis = null;	public static void main(String[] args) throws InterruptedException {		JedisUtil jedisUtil = JedisUtil.getInstance();		jedis=jedisUtil.getJedis(ip, port);//		testKey();//		testString();//		testNumber();//		testList();//		testSet();//		testSortedSet();//		testHash();		testSort();		jedisUtil.closeJedis(jedis, ip, port);		System.out.println("測試完畢");	}		//鍵操作	public static void testKey() throws InterruptedException{		System.out.println("清空數據："+jedis.flushDB());		System.out.println("判斷某個key是否存在："+jedis.exists("username"));		System.out.println("新增用戶："+jedis.set("username", "zhangsan"));		System.out.println("新增密碼："+jedis.set("passWord", "123"));		System.out.println("系統存在的key:"+jedis.keys("*"));		System.out.println("刪除password:"+jedis.del("password"));		System.out.println("判斷是否存在password："+jedis.exists("password"));		System.out.println("設置userName過期時間為5s:"+jedis.expire("username", 5));		TimeUnit.SECONDS.sleep(2);		System.out.println("查看userName剩余時間："+jedis.ttl("username"));		System.out.println("移除username生存時間："+jedis.persist("username"));		System.out.println("查看userName剩余時間："+jedis.ttl("username"));		System.out.println("查看username值的類型："+jedis.type("username"));	}		//string操作	public static void testString() throws InterruptedException{		jedis.flushDB();		System.out.println("========增加數據==========");		System.out.println(jedis.set("key1", "value1"));		System.out.println(jedis.set("key2", "value2"));		System.out.println(jedis.set("key3", "value3"));		System.out.println("刪除key2:"+jedis.del("key2"));		System.out.println("獲取key2:"+jedis.get("key2"));		System.out.println("修改key1:"+jedis.set("key1", "valueChanged"));		System.out.println("獲取key1的值："+jedis.get("key1"));		System.out.println("在key3的后面追加值："+jedis.append("key3", "End"));		System.out.println("key3的值："+jedis.get("key3"));		System.out.println("增加多個鍵值對："+jedis.msetnx("key01","value01","key02","value02","key03","value03"));		System.out.println("獲取多個鍵值對："+jedis.mget("key01","key02","key03"));		System.out.println("刪除多個鍵值對："+jedis.del("key01","key02","key03"));		System.out.println("獲取多個鍵值對："+jedis.mget("key01","key02","key03"));				jedis.flushDB();		System.out.println("=======新增鍵值對防止覆蓋原先值==========");		System.out.println(jedis.setnx("key1", "value1"));		System.out.println(jedis.setnx("key2", "value2"));		System.out.println(jedis.setnx("key2", "value2-new"));		System.out.println(jedis.get("key1"));		System.out.println(jedis.get("key2"));				System.out.println("==========新增鍵值對并設置有效時間=========");		System.out.println(jedis.setex("key3", 3, "value3"));		System.out.println(jedis.get("key3"));		TimeUnit.SECONDS.sleep(3);		System.out.println(jedis.get("key3"));				System.out.println("==========獲取原值更新為新值=========");		System.out.println(jedis.getSet("key2", "abcdefg"));		System.out.println(jedis.get("key2"));				System.out.println("=========截取字符串===========");		System.out.println(jedis.getrange("key2", 1, -1));	}		//數字操作	public static void testNumber(){		jedis.flushDB();		jedis.set("key1", "1");		jedis.set("key2", "2");		System.out.println("key1的值："+jedis.get("key1"));		System.out.println("key2的值："+jedis.get("key2"));		System.out.println("key1的值加1："+jedis.incr("key1"));		System.out.println("獲取key1的值："+jedis.get("key1"));		System.out.println("key2的值減1:"+jedis.decr("key2"));		System.out.println("獲取key2的值："+jedis.get("key2"));		System.out.println("key1的值加上整數5："+jedis.incrBy("key1", 5));		System.out.println("獲取key1的值："+jedis.get("key1"));		System.out.println("key2的值減去5："+jedis.decrBy("key2", 5));		System.out.println("獲取key2的值："+jedis.get("key2"));	}		//list操作	public static void testList(){		jedis.flushDB();		System.out.println("============添加一個list==========");		jedis.lpush("collections", "arrayList","vector","stack","hashMap");		jedis.lpush("collections", "hashSet");		jedis.lpush("collections", "treeSet");		jedis.lpush("collections", "linkedHashSet");		System.out.println("collecions的內容："+jedis.lrange("collections", 0, -1));		System.out.println("collecions區間0-3的內容："+jedis.lrange("collections", 0, 3));		System.out.println("=========================");		//刪除列表指定的值，第二個參數為刪除的個數（有重復時），后add的先被刪除，類似于出棧		System.out.println("刪除指定元素個數："+jedis.lrem("collections", 2, "arrayList"));		System.out.println("collections的內容："+jedis.lrange("collections", 0, -1));		System.out.println("刪除0-3區間之外的元素："+jedis.ltrim("collections", 0, 3));		System.out.println("collections的內容："+jedis.lrange("collections", 0, -1));		System.out.println("列表出棧(左端)："+jedis.lpop("collections"));		System.out.println("collections的內容："+jedis.lrange("collections", 0, -1));		System.out.println("從列表右端添加元素："+jedis.rpush("collections", "list1"));		System.out.println("collections的內容："+jedis.lrange("collections", 0, -1));		System.out.println("列表出棧(右端)："+jedis.rpop("collections"));		System.out.println("collections的內容："+jedis.lrange("collections", 0, -1));		System.out.println("修改指定下標的元素："+jedis.lset("collections", 0, "list0"));		System.out.println("collections的內容："+jedis.lrange("collections", 0, -1));		System.out.println("=========================");		System.out.println("collections的長度："+jedis.llen("collections"));		System.out.println("獲取下標為2的元素："+jedis.lindex("collections", 2));		System.out.println("===========================");		jedis.lpush("sortedList", "3","6","2","0","7","4");		System.out.println("sortedList排序前："+jedis.lrange("sortedList", 0, -1));		System.out.println("sortedList排序后："+jedis.sort("sortedList"));			}		//set操作	public static void testSet(){		jedis.flushDB();		System.out.println("==========向集合中添加元素=============");		jedis.sadd("set", "e0","e2","e3","e4","e5","e6","e7");		jedis.sadd("set", "e6");		jedis.sadd("set", "e6");		System.out.println("set的元素為："+jedis.smembers("set"));		System.out.println("刪除一個元素："+jedis.srem("set", "e0"));		System.out.println("set的元素為："+jedis.smembers("set"));		System.out.println("刪除兩個元素："+jedis.srem("set", "e2","e3"));		System.out.println("set的元素為："+jedis.smembers("set"));		System.out.println("隨機的移除集合的一個元素："+jedis.spop("set"));		System.out.println("隨機的移除集合的一個元素："+jedis.spop("set"));		System.out.println("set的元素為："+jedis.smembers("set"));		System.out.println("set包含元素的個數："+jedis.scard("set"));		System.out.println("某個元素是否在集合中："+jedis.sismember("set", "e0"));		System.out.println("某個元素是否在集合中："+jedis.sismember("set", "e4"));		System.out.println("某個元素是否在集合中："+jedis.sismember("set", "e5"));		System.out.println("=================================");		System.out.println(jedis.sadd("set1", "a","b","c","d","e","f"));		System.out.println(jedis.sadd("set2", "a","b","c","d","e"));		System.out.println(jedis.smove("set1", "set3", "a"));		System.out.println(jedis.smove("set1", "set3", "b"));		System.out.println(jedis.smembers("set1"));		System.out.println(jedis.smembers("set3"));		System.out.println("===================集合運算====================");		System.out.println(jedis.smembers("set1"));		System.out.println(jedis.smembers("set2"));		System.out.println("set1和set2的交集："+jedis.sinter("set1", "set2"));		System.out.println("set1和set2的并集："+jedis.sunion("set1", "set2"));		System.out.println("set1和set2的差集："+jedis.sdiff("set1", "set2"));	}		//sortedSet操作	public static void testSortedSet(){		jedis.flushDB();		Map map = new HashMap();		map.put("key2",1.2 );		map.put("key3",4.0);		map.put("key4",5.0);		map.put("key5",0.2);		System.out.println(jedis.zadd("zset", 3, "key1"));		System.out.println(jedis.zadd("zset", map));		System.out.println("所有元素："+jedis.zrange("zset", 0, -1));		System.out.println("所有元素："+jedis.zrangeWithScores("zset", 0, -1));		System.out.println("所有元素："+jedis.zrangeByScore("zset", 0, 100));		System.out.println("所有元素："+jedis.zrangeByScoreWithScores("zset", 0, 100));		System.out.println("zset中key2的分值："+jedis.zscore("zset", "key2"));		System.out.println("zset中key2的排名："+jedis.zrank("zset", "key2"));		System.out.println("刪除key3元素："+jedis.zrem("zset", "key3"));		System.out.println("所有元素："+jedis.zrange("zset", 0, -1));		System.out.println("元素的個數："+jedis.zcard("zset"));		System.out.println("分值在1-4之間的元素個數："+jedis.zcount("zset", 1, 4));		System.out.println("key2的分值加上5："+jedis.zincrby("zset", 5, "key2"));		System.out.println("key3的分值加上4："+jedis.zincrby("zset", 4, "key3"));		System.out.println("所有元素："+jedis.zrange("zset", 0, -1));	}		//hash操作	public static void testHash(){		jedis.flushDB();		Map<String, String> map=new HashMap<String, String>();		map.put("key1", "value1");		map.put("key2", "value2");		map.put("key3", "value3");		map.put("key4", "value4");		jedis.hmset("hash", map);		jedis.hset("hash", "key5", "value5");		System.out.println("散列hash的所有鍵值對為："+jedis.hgetAll("hash"));		System.out.println("散列hash的所有鍵為："+jedis.hkeys("hash"));		System.out.println("散列hash的所有值為："+jedis.hvals("hash"));		System.out.println("key6保持的值加一個整數，若不存在則創建："+jedis.hincrBy("hash", "key6", 6));		System.out.println("散列hash的所有鍵值對為："+jedis.hgetAll("hash"));		System.out.println("key6保持的值加一個整數，若不存在則創建："+jedis.hincrBy("hash", "key6", 3));		System.out.println("散列hash的所有鍵值對為："+jedis.hgetAll("hash"));		System.out.println("刪除一個或多個鍵值對："+jedis.hdel("hash", "key2"));		System.out.println("散列hash的所有鍵值對為："+jedis.hgetAll("hash"));		System.out.println("鍵值對的個數："+jedis.hlen("hash"));		System.out.println("判斷是否存在key2:"+jedis.hexists("hash", "key2"));		System.out.println("判斷是否存在key3:"+jedis.hexists("hash", "key3"));		System.out.println("獲取hash中的值："+jedis.hmget("hash", "key3"));		System.out.println("獲取hash中的值："+jedis.hmget("hash", "key3","key4"));	}		//排序操作	public static void testSort(){		jedis.flushDB();		jedis.lpush("collections", "ArrayList","Vector","Stack","HashMap","WeakHashMap","LinkedHashMap");		System.out.println("collections的內容為："+jedis.lrange("collections", 0, -1));		SortingParams sortingParams = new SortingParams();		System.out.println(jedis.sort("collections", sortingParams.alpha()));		System.out.println("==============================");		jedis.lpush("sortedList", "3","6","2","0","7","4");		System.out.println("排序前："+jedis.lrange("sortedList", 0, -1));		System.out.println("升序："+jedis.sort("sortedList", sortingParams.asc()));		System.out.println("降序："+jedis.sort("sortedList", sortingParams.desc()));		System.out.println("===============================");		jedis.lpush("userList", "55");		jedis.lpush("userList", "22");		jedis.lpush("userList", "11");		jedis.lpush("userList", "33");		jedis.hsetnx("user:55", "name", "66");		jedis.hsetnx("user:33", "name", "55");		jedis.hsetnx("user:22", "name", "33");		jedis.hsetnx("user:11", "name", "79");		jedis.hsetnx("user:11", "name", "24");		jedis.hsetnx("user:22", "add", "beijing");		jedis.hsetnx("user:33", "add", "shanghai");		jedis.hsetnx("user:55", "add", "guangzhou");		sortingParams=new SortingParams();		sortingParams.get("user:*->name");		sortingParams.get("user:*->add");		System.out.println(jedis.sort("userList",sortingParams));			}}