Jedis使用

1 <!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
2         <dependency>
3             <groupId>redis.clients</groupId>
4             <artifactId>jedis</artifactId>
5             <version>2.9.0</version>
6         </dependency>

 1 # *************** jedis connection parameters setting ************** #
 2 # redis server ip #
 3 redis.ip=127.0.0.1
 4 # redis server port #
 5 redis.port=6379
 6 # password
 7 redis.password=redis123
 8 
 9 # *************** jedis pool parameters setting ************** #
10 # jedis‘s max connected objects #
11 redis.pool.maxTotal=1000
12 # jedis‘s max saved idel objects #
13 redis.pool.maxIdle=10
14 # jedis‘s max waiting time when no object returnd #
15 redis.pool.maxWaitMillis=5000
16 # whether test when jedis is calling borrowObject() #
17 redis.pool.testOnBorrow=true
18 # whether test when jedis is calling returnObject() #
19 redis.pool.testOnReturn=true

 1 import redis.clients.jedis.Jedis;
 2 import redis.clients.jedis.JedisPool;
 3 import redis.clients.jedis.JedisPoolConfig;
 4 
 5 import java.io.IOException;
 6 import java.util.Properties;
 7 
 8 /**
 9  * Created by XA on 2017/11/6.
10  */
11 public class MyJedisPool {
12 
13     private volatile static JedisPool pool;
14     private static Jedis jedis;
15 
16     private static JedisPool getJedisPool() {
17         if(pool==null) {
18             synchronized (MyJedisPool.class) {
19                 if(pool==null) {
20                     try{
21                         Properties props = new Properties();
22                         props.load(MyJedisPool.class.getClassLoader().getResourceAsStream("config/redis.properties"));
23                         // create jedis pool instance
24                         JedisPoolConfig config = new JedisPoolConfig();
25                         // set property items of jedis pool
26                         config.setMaxTotal(Integer.valueOf(props.getProperty("redis.pool.maxTotal")));
27                         config.setMaxIdle(Integer.valueOf(props.getProperty("redis.pool.maxIdle")));
28                         config.setMaxWaitMillis(Integer.valueOf(props.getProperty("redis.pool.maxWaitMillis")));
29                         config.setTestOnBorrow(Boolean.valueOf(props.getProperty("redis.pool.testOnBorrow")));
30                         config.setTestOnReturn(Boolean.valueOf(props.getProperty("redis.pool.testOnReturn")));
31                         // instance
32                         pool = new JedisPool(config, props.getProperty("redis.ip"), Integer.valueOf(props.getProperty("redis.port")), 5000, props.getProperty("redis.password"));
33 
34                     }catch (IOException e) {
35                         e.printStackTrace();
36                     }
37                 }
38             }
39         }
40         return pool;
41     }
42 
43     // get jedis
44     public static Jedis getJedis() {
45         return getJedisPool().getResource();
46     }
47 
48     // recycle jedis
49     public synchronized static void recycleJedis(Jedis jedis) {
50         if(jedis!=null) {
51             jedis.close();
52         }
53     }
54 }

public static void main(String[] args){
        try{
            Jedis jedis = MyJedisPool.getJedis();
            Set<String> keys = jedis.keys("*");
            System.out.println(keys.size());
        }catch (Exception e) {
            e.printStackTrace();
        }finally {
            MyJedisPool.recycleJedis(jedis);
        }
        
    }

 1 @SuppressWarnings("unchecked")
 2     public static <T> T invokeJedisMethod(String methodName, Object[] args) {
 3         Jedis jedis = MyJedisPool.getJedis();
 4 
 5         T returnObject = null;
 6         try {
 7             Class[] argsTypes = new Class[args.length];
 8             for (int i = 0; i < args.length; i++) {
 9                 Class argClazz = args[i].getClass();
10                 if (argClazz.equals(HashMap.class)) {
11                     argsTypes[i] = Map.class;
12                 } else {
13                     argsTypes[i] = argClazz;
14                 }
15 
16             }
17             Method method = jedis.getClass().getDeclaredMethod(methodName, argsTypes);
18 
19             returnObject = (T) method.invoke(jedis, args);
20         } catch (Exception e) {
21             System.out.print(e.getStackTrace()[1].getClassName() + " --> " +
22                     e.getStackTrace()[1].getMethodName() + " --> " +
23                     e.getClass().getName() + "\n");
24             e.printStackTrace();
25         } finally {
26             MyJedisPool.recycleJedis(jedis);
27         }
28         return returnObject;
29     }