Windows下redis线程池的搭建及使用

Windows下redis线程池的搭建及使用

首先要在本地安装redis，官方只支持Linux版，windows64版本也有，请自行下载（）

下载完之后测试安装是否成功（.html）若成功后，则开始代码上的测试。

redis的配置文件为：

redis.pool.maxActive=1024redis.pool.maxIdle=200redis.pool.maxWait=stOnBorrow=stOnReturn=true#IP
redis.ip=127.0.0.1     
#Port
redis.port=6379

 其中，每一个redis服务都会有一个端口，默认为6379端口，IP则表示redis的安装路径IP。

 搭建Redis的线程池：

public class RedisPoolManager {private static JedisPool pool;static {ResourceBundle bundle = Bundle("redis");if (bundle == null)throw new IllegalArgumentException("[redis.properties] is not found");JedisPoolConfig config = new JedisPoolConfig();config.setMaxTotal(Integer.String("redis.pool.maxActive")));config.setMaxIdle(Integer.String("redis.pool.maxIdle")));config.setMaxWaitMillis(Long.String("redis.pool.maxWait")));config.setTestOnBorrow(Boolean.String("stOnBorrow")));config.setTestOnReturn(Boolean.String("stOnReturn")));pool = new JedisPool(config, String("redis.ip"), Integer.String("redis.port")));}/*** Get Jedis resource from the pool* @return*/public static Jedis createInstance() {Jedis jedis = Resource();
//        jedis.auth("will");return jedis;}/*** Return the resource to pool* @param jedis*/public static void returnResource(Jedis jedis) {urnResource(jedis);}}

  单例模式建立起Redis管理器：（此处的管理器是在jedis基础上实现的自定义，你也可以直接使用jedis）

@Component("cacheManager")
public class CacheManager {private volatile static CacheManager uniqueCacheManager;private CacheManager(){}public static CacheManager getInstance(){if(uniqueCacheManager == null){synchronized (CacheManager.class){if(uniqueCacheManager == null){uniqueCacheManager = new CacheManager();}}}return uniqueCacheManager;}private Jedis jedis = ateInstance();Basic Functions(String related) - Start //*** If the value existed, will override the value* @param entries*/public void set(Map<String, String> entries) {for (Map.Entry<String, String> entry : Set()) {jedis.Key(), Value());}}/*** If the key exited, will override the value* @param key* @param value*/public void set(String key, String value) {jedis.set(key, value);}/**** @param entries*/public void setnx(Map<String, String> entries) {for (Map.Entry<String, String> entry : Set()) {jedis.Key(), Value());}}/*** Only set the value when the key not exist* @param key* @param value*/public void setnx(String key, String value) {jedis.setnx(key, value);}/*** Set the value to the key and specify the key's life cycle as seconds.* @param key* @param live* @param value*/public void setKeyLive(String key, int live, String value) {jedis.setex(key, live, value);}/*** Append the value to an existing key* @param key* @param value*/public void append(String key, String value) {jedis.append(key, value);}/*** Get the value by the given key* @param key* @return*/public String getValue(String key) {(key);}/*** Get the values of the specified keys* @param keys* @return*/public List<String>  keys) {(keys);}/*** remove the value by the key from the cache* @param key* @return*/public Long removeValue(String key) {return jedis.del(key);}/*** Delete the expected values from the cache* @param keys* @return*/public Long  keys) {return jedis.del(keys);}/*** Identify whether the key in the cache or not* @param key* @return*/public boolean exists(String key) {ists(key);}/*** Release the resource*/public void returnSource() {urnResource(jedis);}/*** Clear the cache*/public String clear() {return jedis.flushDB();}/*** Calculate the size of the cache* @return*/public long calculateSize() {return jedis.dbSize();}/*** Get and update the member by the key in the cache* @param key* @param value* @return*/public String getSet(String key, String value) {Set(key, value);}/**** @param key* @param startOffset* @param endOffset* @return*/public String getRange(String key, int startOffset, int endOffset) {ange(key, startOffset, endOffset);}Basic Functions(String related) - End /List Functions - Start //*** push the value to the given list** 将一个或多个值 value 插入到列表 key 的表头*如果有多个 value 值，那么各个 value 值按从左到右的顺序依次插入到表头：*比如说，对空列表 mylist 执行命令 LPUSH mylist a b c ，列表的值将是 c b a ，*这等同于原子性地执行 LPUSH mylist a 、 LPUSH mylist b 和 LPUSH mylist c 三个命令。*如果 key 不存在，一个空列表会被创建并执行 LPUSH 操作。*当 key 存在但不是列表类型时，返回一个错误。** @param listName* @param values* @return*/public long add2List(String listName,  values) {return jedis.lpush(listName, values);}/*** get the list size* @param listName* @return*/public long getListSize(String listName) {return jedis.llen(listName);}/*** Update the member on the index* @param listName* @param index* @param value*/public void updateList(String listName, int index, String value) {jedis.lset(listName, index, value);}/*** Get the value on the index* @param listName* @param index* @return*/public String getIndexValue(String listName, int index) {return jedis.lindex(listName, index);}/*** 根据参数 count 的值，移除列表中与参数 value 相等的元素。* count 的值可以是以下几种：*count > 0 : 从表头开始向表尾搜索，移除与 value 相等的元素，数量为 count 。*count < 0 : 从表尾开始向表头搜索，移除与 value 相等的元素，数量为 count 的绝对值。*count = 0 : 移除表中所有与 value 相等的值。** @param listName* @param count* @param value* @return*/public long removeLValue(String listName, int count, String value) {return jedis.lrem(listName, count, value);}/*** Remove the value out side of the range** @param listName* @param start* @param end* @return*/public String removeOutterValue(String listName, int start, int end) {return jedis.ltrim(listName, start, end);}/*** Pop the lists* @param listName* @return*/public String popList(String listName) {return jedis.lpop(listName);}/*** Get the specified list values** 返回列表 key 中指定区间内的元素，区间以偏移量 start 和 stop 指定。* 下标(index)参数 start 和 stop 都以 0 为底，也就是说，以 0 表示列表的第一个元素，以 1 表示列表的第二个元素，以此类推。* 你也可以使用负数下标，以 -1 表示列表的最后一个元素， -2 表示列表的倒数第二个元素，以此类推** 注意LRANGE命令和编程语言区间函数的区别假如你有一个包含一百个元素的列表，对该列表执行 LRANGE list 0 10 ，结果是一个包含11个元素的列表，这表明 stop 下标也在 LRANGE 命令的取值范围之内(闭区间)，  这和某些语言的区间函数可能不一致，比如Ruby的 w 、 Array#slice 和Python的 range() 函数** @param listName* @param start* @param end* @return*/public List<String> getListValues(String listName, long start, long end) {return jedis.lrange(listName, start, end);}/*** Get all of the values of the list** @param listName* @return*/public List<String> getAllListValues(String listName) {return jedis.lrange(listName, 0, -1);}/*** Sort the list* @param listName* @return*/public List<String> sort(String listName) {return jedis.sort(listName);}/**** @param key* @param params* @param dstKey* @return*/public Long sort(String key, SortingParams params, String dstKey) {return jedis.sort(key, params, dstKey);}List Functions - End /Set Functions - Start //*** Identify whether the member in the given set or not* @param setName* @param member* @return*/public boolean exists(String setName, String member) {return jedis.sismember(setName, member);}/*** Add the members to set* @param setName* @param members* @return*/public long add2Set(String setName,  members) {return jedis.sadd(setName, members);}/*** Get all of the values of the set** @param setName* @return*/public Set<String> getAllSetValues(String setName) {return jedis.smembers(setName);}/*** Remove members from the set** @param setName* @param members* @return*/public Long removeSValues(String setName, String ... members) {return jedis.srem(setName, members);}/*** Set Pop* @param setName* @return*/public String popSet(String setName) {return jedis.spop(setName);}/*** 交集* Get the intersection* @param sets* @return*/public Set<String>  sets) {return jedis.sinter(sets);}/*** 并集* Get the union set of the given sets* @param sets* @return*/public Set<String>  sets) {return jedis.sunion(sets);}/*** 差集* Get the difference set of the given sets** @param sets* @return*/public Set<String>  sets) {return jedis.sdiff(sets);}Set Functions - End /Sorted Set Functions - Start //*** 将一个或多个 member 元素及其 score 值加入到有序集 key 当中。* 如果某个 member 已经是有序集的成员，那么更新这个 member 的 score 值，并通过重新插入这个 member 元素，* 来保证该 member 在正确的位置上。*** @param ssetName - 如果 ssetName 不存在，则创建一个空的有序集并执行 ZADD 操作。*                     当 ssetName 存在但不是有序集类型时，返回一个错误。* @param score - 可以是整数值或者双精度浮点数，用于排序* @param member* @return*/public long add2SSet(String ssetName, double score, String member) {return jedis.zadd(ssetName, score, member);}/*** Return the size of the sorted set* @param sset* @return*/public long card(String sset) {ard(sset);}/*** Get the sub set* @param sset* @param start* @param end* @return*/public Set<String> getSubSet(String sset, long start, long end) {ange(sset, start, end);}/*** Get the index of the member* @param sset* @param member* @return*/public Double getIndex(String sset, String member) {return jedis.zscore(sset, member);}/*** Remove the members* @param sset* @param members* @return*/public Long removeSSValues(String sset, String ...members) {(sset, members);}/*** Get all of the values of the sorted set* @param sset* @return*/public Set<String> getAllSSValues(String sset) {ange(sset, 0, -1);}/**** @param sset* @param start* @param end* @return*/public Long countRange(String sset, double start, double end) {unt(sset, start, end);}Sorted Set Functions - End /Hash Map Functions - Start //*** Push the value to the map on the key* @param map* @param key* @param value* @return*/public long push(String map, String key, String value) {return jedis.hset(map, key, value);}/*** Identify whether the key exist or not* @param map* @param key* @return*/public boolean hexists(String map, String key) {return jedis.hexists(map, key);}/*** Get the value of the key* @param map* @param key* @return*/public String getValue(String map, String key) {return jedis.hget(map, key);}/*** Get the values of the keys** @param map* @param keys* @return*/public List<String> getHValues(String map,  keys) {return jedis.hmget(map, keys);}/*** Remove the values by the keys* @param map* @param keys* @return*/public Long removeHValues(String map, String ... keys) {return jedis.hdel(map, keys);}/*** Increment the value on the key for the map* @param map* @param key* @param value* @return*/public Long increment(String map, String key, long value) {return jedis.hincrBy(map, key, value);}/*** Get all of the keys of the map* @param map* @return*/public Set<String> getKeys(String map) {return jedis.hkeys(map);}/*** Get all of the values of the map* @param map* @return*/public List<String> getValues(String map) {return jedis.hvals(map);}public Long expire(String key, int seconds){pire(key,seconds);}Hash Map Functions - End //
}

 测试类为：（copy了一个网上的例子）

public class testCacheManager {private @ResourceCacheManager cacheManager = Instance();@Beforepublic void init() {System.out.println(cacheManager.hashCode() + "");}@Testpublic void basicTest() {System.out.println("============= Basic1 ==========================");// 清空数据System.out.println(cacheManager.clear());System.out.ists("josh"));// 存储数据cacheManager.set("josh", "WangSheng");System.out.ists("josh"));System.out.Value("josh"));System.out.println("============= Basic 2 ==========================");// 若key不存在，则存储cacheManager.setnx("josh", "wang sheng");System.out.Value("josh"));// 覆盖数据cacheManager.set("josh", "wang sheng");System.out.Value("josh"));// 追加数据cacheManager.append("josh", "Lily");System.out.Value("josh"));System.out.println("============= Basic 3 ==========================");// 设置key的有效期，并存储数据cacheManager.setKeyLive("josh", 2, "WangSheng-Lily");System.out.Value("josh"));try {Thread.sleep(3000);System.out.Value("josh"));} catch (InterruptedException e) {System.out.println("Josh released  ... now ^_^");}System.out.println("============= Basic 4 ==========================");// 获取并更改数据Set("josh", "wang sheng");System.out.Value("josh"));System.out.println("============= Basic 5 ==========================");// 截取value的值System.out.Range("josh", 1, 3));cacheManager.set("MJ", "Jordan");System.out.Values("josh", "MJ"));System.out.println("============= Basic 6 ==========================");veValues(new String[]{"josh", "MJ"});System.out.Values("josh", "MJ"));}/*** List 是无序的，所以测试结果和expect的结果可能不一致** 还是是从-1开始？*/@Testpublic void listTest() {System.out.println("============= list1 ==========================");// 清空数据System.out.println(cacheManager.clear());// 添加数据cacheManager.add2List("ball", "Jordan");cacheManager.add2List("ball", "Maddie");cacheManager.add2List("ball", "AI");cacheManager.add2List("ball", "Yao");// The order should be : Yao, AI, Maddie, Jordan// 数组长度System.out.ListSize("ball"));System.out.AllListValues("ball"));System.out.ListValues("ball", 0, -1));System.out.println("============= list2 ==========================");// 修改列表中单个值cacheManager.updateList("ball", 1, "Allen Iversen");System.out.ListValues("ball", 0, 3));// 获取列表指定下标的值System.out.IndexValue("ball", 2));// 删除列表指定下标的值System.out.veLValue("ball", 1, "Yao"));System.out.AllListValues("ball"));// 删除区间以外的数据System.out.veOutterValue("ball", 0, 1));System.out.AllListValues("ball"));// 列表出栈System.out.println(cacheManager.popList("ball"));}@Testpublic void testSet() {System.out.println("========================= Set ====================");// 清空数据System.out.println(cacheManager.clear());// 添加数据cacheManager.add2Set("ball", "Jordan");cacheManager.add2Set("ball", "Maddie");cacheManager.add2Set("ball", "AI");cacheManager.add2Set("ball", "Yao");// 判断value是否在列表中System.out.ists("ball", "AI"));System.out.ists("ball", "Yao "));// 整个列表的值System.out.AllSetValues("ball"));// 删除指定的元素System.out.veSValues("ball", "Yao"));// 出栈System.out.println(cacheManager.popSet("ball"));// 整个列表的值System.out.AllSetValues("ball"));cacheManager.add2Set("bball", "Jordan");cacheManager.add2Set("bball", "Maddie");cacheManager.add2Set("bball", "AI");cacheManager.add2Set("bball", "Yao");cacheManager.add2Set("fball", "Jordan");cacheManager.add2Set("fball", "Ronaldo");cacheManager.add2Set("fball", "Rivaldo");cacheManager.add2Set("fball", "Cristiano Ronaldo");cacheManager.add2Set("fball", "Ronaldinho");// 交集System.out.println(cacheManager.intersection("bball", "fball"));// 并集System.out.println(cacheManager.union("bball", "fball"));// 差集System.out.println(cacheManager.diff("bball", "fball"));}@Testpublic void testHash() {System.out.println("=============  hash ==========================");// 清空数据System.out.println(cacheManager.clear());// 添加数据cacheManager.push("hball", "Jordan", "Chicago");cacheManager.push("hball", "Maddie", "Houston");cacheManager.push("hball", "AI", "Philadelphia");cacheManager.push("hball", "Yao", "Houston");// 判断某个值是否存在System.out.println(cacheManager.hexists("hball", "Yao "));System.out.println(cacheManager.hexists("hball", "AI"));// 获取指定的值System.out.Value("hball", "Jordan"));// 批量获取指定的值System.out.HValues("hball", "Jordan", "Maddie"));// 删除指定的值System.out.veHValues("hball", "Yao"));// 为key中的域 field 的值加上增量 increment, hash value must be a data value// System.out.println(cacheManager.increment("hball", "Jordan", 123l));// 获取所有的keysSystem.out.Keys("hball"));// 获取所有的valuesSystem.out.Values("hball"));}//    @Test
//    public void test(){
//        Jedis jedis = new Jedis("121.40.158.114",6379);
//        jedis.set("11","222");
//        pire("11",5);
//        System.out.("11"));
//    }
//
//    @Test
//    public void test2(){
//        Jedis jedis = new Jedis("121.40.158.114",6379);
//        System.out.("11"));
//    }
}

 输出结果为：

1338823963
============= Basic1 ==========================
OK
false
true
WangSheng
============= Basic 2 ==========================
WangSheng
wang sheng
wang shengLily
============= Basic 3 ==========================
WangSheng-Lily
null
============= Basic 4 ==========================
wang sheng
============= Basic 5 ==========================
ang
[wang sheng, Jordan]
============= Basic 6 ==========================
[null, null]
1338823963
========================= Set ====================
OK
true
false
[Maddie, Jordan, Yao, AI]
1
Jordan
[Maddie, AI]
[Jordan]
[Jordan, Maddie, Ronaldo, Rivaldo, Cristiano Ronaldo, Yao, Ronaldinho, AI]
[AI, Yao, Maddie]
1338823963
=============  hash ==========================
OK
false
true
Chicago
[Chicago, Houston]
1
[Jordan, AI, Maddie]
[Chicago, Houston, Philadelphia]
1338823963
============= list1 ==========================
OK
4
[Yao, AI, Maddie, Jordan]
[Yao, AI, Maddie, Jordan]
============= list2 ==========================
[Yao, Allen Iversen, Maddie, Jordan]
Maddie
1
[Allen Iversen, Maddie, Jordan]
OK
[Allen Iversen, Maddie]
Allen Iversen

 存在redis数据库的数据你可以通过来进行查看：