博客
关于我
强烈建议你试试无所不能的chatGPT，快点击我
在springmvc中配置jedis（转）
阅读量：6082 次
发布时间：2019-06-20

本文共 12203 字，大约阅读时间需要 40 分钟。

 

主要学习https://github.com/thinkgem/jeesite。一下代码均参考于此并稍作修改。

1.jedis

首先，需要添加jedis：

      
            
       
        redis.clients
             
       
        jedis
             
       
        2.8.0

2.applicationContext-jedis.xml

然后，springmvc完成基本配置。添加jedispool的bean即可。在spring容器中添加applicationContext-jedis.xml：

在applicationContext-jedis.xml中添加：

复制代码
复制代码

注解：参考的源码中的jedisPool配置只有三个参数：config，host，port。我复制后的结果总是getResource失败，因为我的redis添加了auth，所以猜测是不是没通过auth的原因。于是打开JedisPool的源码：

复制代码 
1 package redis.clients.jedis;  2   3 import java.net.URI;  4   5 import org.apache.commons.pool2.impl.GenericObjectPool;  6 import org.apache.commons.pool2.impl.GenericObjectPoolConfig;  7   8 import redis.clients.jedis.exceptions.JedisException;  9 import redis.clients.util.JedisURIHelper; 10 import redis.clients.util.Pool; 11  12 public class JedisPool extends Pool
       
         { 13  14   public JedisPool() { 15     this(Protocol.DEFAULT_HOST, Protocol.DEFAULT_PORT); 16   } 17  18   public JedisPool(final GenericObjectPoolConfig poolConfig, final String host) { 19     this(poolConfig, host, Protocol.DEFAULT_PORT, Protocol.DEFAULT_TIMEOUT, null, 20         Protocol.DEFAULT_DATABASE, null); 21   } 22  23   public JedisPool(String host, int port) { 24     this(new GenericObjectPoolConfig(), host, port, Protocol.DEFAULT_TIMEOUT, null, 25         Protocol.DEFAULT_DATABASE, null); 26   } 27  28   public JedisPool(final String host) { 29     URI uri = URI.create(host); 30     if (JedisURIHelper.isValid(uri)) { 31       String h = uri.getHost(); 32       int port = uri.getPort(); 33       String password = JedisURIHelper.getPassword(uri); 34       int database = JedisURIHelper.getDBIndex(uri); 35       this.internalPool = new GenericObjectPool
        
         (new JedisFactory(h, port, 36           Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, password, database, null), 37           new GenericObjectPoolConfig()); 38     } else { 39       this.internalPool = new GenericObjectPool
         
          (new JedisFactory(host, 40           Protocol.DEFAULT_PORT, Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, null, 41           Protocol.DEFAULT_DATABASE, null), new GenericObjectPoolConfig()); 42     } 43   } 44  45   public JedisPool(final URI uri) { 46     this(new GenericObjectPoolConfig(), uri, Protocol.DEFAULT_TIMEOUT); 47   } 48  49   public JedisPool(final URI uri, final int timeout) { 50     this(new GenericObjectPoolConfig(), uri, timeout); 51   } 52  53   public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, int port, 54       int timeout, final String password) { 55     this(poolConfig, host, port, timeout, password, Protocol.DEFAULT_DATABASE, null); 56   } 57  58   public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, final int port) { 59     this(poolConfig, host, port, Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE, null); 60   } 61  62   public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, final int port, 63       final int timeout) { 64     this(poolConfig, host, port, timeout, null, Protocol.DEFAULT_DATABASE, null); 65   } 66  67   public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, int port, 68       int timeout, final String password, final int database) { 69     this(poolConfig, host, port, timeout, password, database, null); 70   } 71  72   public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, int port, 73       int timeout, final String password, final int database, final String clientName) { 74     this(poolConfig, host, port, timeout, timeout, password, database, clientName); 75   } 76  77   public JedisPool(final GenericObjectPoolConfig poolConfig, final String host, int port, 78       final int connectionTimeout, final int soTimeout, final String password, final int database, 79       final String clientName) { 80     super(poolConfig, new JedisFactory(host, port, connectionTimeout, soTimeout, password, 81         database, clientName)); 82   } 83  84   public JedisPool(final GenericObjectPoolConfig poolConfig, final URI uri) { 85     this(poolConfig, uri, Protocol.DEFAULT_TIMEOUT); 86   } 87  88   public JedisPool(final GenericObjectPoolConfig poolConfig, final URI uri, final int timeout) { 89     this(poolConfig, uri, timeout, timeout); 90   } 91  92   public JedisPool(final GenericObjectPoolConfig poolConfig, final URI uri, 93       final int connectionTimeout, final int soTimeout) { 94     super(poolConfig, new JedisFactory(uri, connectionTimeout, soTimeout, null)); 95   } 96  97   @Override 98   public Jedis getResource() { 99     Jedis jedis = super.getResource();100     jedis.setDataSource(this);101     return jedis;102   }103 104   /**105    * @deprecated starting from Jedis 3.0 this method will not be exposed.106    * Resource cleanup should be done using @see {@link redis.clients.jedis.Jedis#close()}107    */108   @Override109   @Deprecated110   public void returnBrokenResource(final Jedis resource) {111     if (resource != null) {112       returnBrokenResourceObject(resource);113     }114   }115 116   /**117    * @deprecated starting from Jedis 3.0 this method will not be exposed.118    * Resource cleanup should be done using @see {@link redis.clients.jedis.Jedis#close()}119    */120   @Override121   @Deprecated122   public void returnResource(final Jedis resource) {123     if (resource != null) {124       try {125         resource.resetState();126         returnResourceObject(resource);127       } catch (Exception e) {128         returnBrokenResource(resource);129         throw new JedisException("Could not return the resource to the pool", e);130       }131     }132   }133 }
复制代码
View Code

看到有password的参数配置，如果没有配置的话默认为null。到这一步我便没有往下深入看了，因为我连接的redis中有auth，原谅我的不求甚解。于是，我接着配置timeout和auth。timeout直接还是源码的默认值。后面的代码测试通过。在这里我了解到spring的bean注入的几个参数含义：比如property表示属性注入，constructor表示构造函数的参数注入。

3. JedisUtil

3.1 getResource

上面设置好了JedisPool，这里就要获取jedis。然后就可以利用jedis进行操作了。

复制代码 
1  /** 2      * 获取资源 3      * @return 4      */ 5     public static Jedis getResource() { 6         Jedis jedis = null; 7         try { 8             jedis = jedisPool.getResource(); 9             logger.debug("getResource:{}",jedis);10         } catch (Exception e) {11             logger.error("getResource:{}",e);12             if (jedis!=null)13             jedis.close();14             throw  e;15         }16         return jedis;17     }
复制代码

3.2 Object对象的缓存

通过使用jedis基本可以完成任何操作了。这里添加一个缓存对象的功能。java对象的缓存利用序列化实现，因此，需要缓存的对象必须实现了serializable接口。关于如何序列化，参考：。

复制代码 
1   /** 2      * 设置缓存 3      * @param key String 4      * @param value Object对象 5      * @param cacheSeconds 超时时间，0为不超时 6      * @return 7      */ 8     public static String setObject(String key,Object value,int cacheSeconds){ 9         String result = null;10         Jedis jedis = null;11         try {12             jedis = getResource();13             result = jedis.set(getBytesKey(key),toBytes(value));14             if (cacheSeconds!=0){15                 jedis.expire(key,cacheSeconds);16             }17             logger.debug("setObject {}={}",key,value);18         } catch (Exception e) {19             logger.warn("setObject {}  失败：{}",key,e);20         } finally {21             jedis.close();22         }23         return result;24     }25 /**26      * 获取缓存27      * @param key28      * @return 对象(反序列化)29      */30     public static Object getObject(String key){31         Object value = null;32         Jedis jedis = null;33         try {34             jedis = getResource();35             byte[] bytes = jedis.get(getBytesKey(key));36             value =  toObject(bytes);37             logger.debug("getObject {}={}",key,value);38         } catch (Exception e) {39             logger.warn("getObject {}错误：{}",key,e.getMessage());40             e.printStackTrace();41         } finally {42             jedis.close();43         }44         return value;45     }46  /**47      * 将key转换为byte[]48      * @param object49      * @return50      */51     private static byte[] getBytesKey(Object object) {52         if(object instanceof String){53             return StringUtils.getBytes((String) object);54         }else {55             return ObjectUtils.serialize(object);56         }57     }58 59     /**60      * Object转换为byte[]类型61      * @param value Object对象62      * @return byte[]数组63      */64     private static byte[] toBytes(Object value) {65         return ObjectUtils.serialize(value);66     }67 68     /**69      * byte[]转换为object70      * @param bytes71      * @return72      */73     private static Object toObject(byte[] bytes) {74         return ObjectUtils.unserialize(bytes);75     }
复制代码

3.3 ObjectList对象缓存

我们平时用到的list基本都是ObjectList，即list的元素为object而不是String。这样就需要特定方法来缓存了。

采用同样的方式，将object序列化为字节数组，然后存储起来。取出的时候再反序列化，因此object必须实现了serializable接口，而且static的成员不能序列化或者说序列化的结果为默认值。原因参考：。

复制代码 
1 /**  2      * 获取list缓存  3      * @param key  4      * @return  5      */  6     public static List
       
         getList(String key){  7         key = addDatabaseName(key);  8         List
        
          value = null;  9         Jedis jedis = null; 10         try { 11             jedis = getResource(); 12             value = jedis.lrange(key, 0, -1); 13             logger.debug("getList {}={}",key,value); 14         } catch (Exception e) { 15             logger.warn("getList {}失败：{}",key,e); 16             e.printStackTrace(); 17         } finally { 18             jedis.close(); 19         } 20         return value; 21     } 22  23     /** 24      * 获取list缓存，元素是object 25      * @param key 26      * @return 27      */ 28     public static List
          getObjectList(String key){ 29         key = addDatabaseName(key); 30         List value = null; 31         Jedis jedis = null; 32         try { 33             jedis = getResource(); 34             List
           
             list = jedis.lrange(getBytesKey(key), 0, -1); 35             value = Lists.newArrayList(); 36             for (byte[] bytes : list) { 37                 value.add(toObject(bytes)); 38             } 39             logger.debug("getObjectList {}={}",key,value); 40         }catch (Exception e){ 41             logger.warn("getObjectList {} 失败：{}",key,e); 42             e.printStackTrace(); 43         }finally { 44             jedis.close(); 45         } 46         return value; 47     } 48  49     /** 50      * 设置list缓存 51      * @param key 52      * @param value 53      * @param cacheSeconds 54      * @return 55      */ 56     public static long setList(String key,List
            
              value,int cacheSeconds){ 57 key = addDatabaseName(key); 58 long result = 0; 59 Jedis jedis = null; 60 try { 61 jedis = getResource(); 62 jedis.del(key); 63 String[] arr = new String[value.size()]; 64 value.toArray(arr); 65 result = jedis.rpush(key,arr); 66 if (cacheSeconds!=0){ 67 jedis.expire(key,cacheSeconds); 68 } 69 logger.debug("setList {}={}",key,value); 70 }catch (Exception e){ 71 logger.warn("setList {} 错误：",key,e); 72 e.printStackTrace(); 73 }finally { 74 jedis.close(); 75 } 76 return result; 77 } 78 79 /** 80 * 设置list缓存，list的元素为object 81 * @param key 82 * @param value 83 * @param cacheSeconds 84 * @return 85 */ 86 public static long setObjectList(String key,List
              value ,int cacheSeconds){ 87 key = addDatabaseName(key); 88 long result = 0; 89 Jedis jedis = null; 90 try { 91 jedis = getResource(); 92 jedis.del(key); 93 ArrayList
              
                list = Lists.newArrayList(); 94 for (Object o : value) { 95 list.add(toBytes(o)); 96 } 97 byte[] []arr = new byte[list.size()][]; 98 list.toArray(arr); 99 result = jedis.rpush(getBytesKey(key),arr);100 if(cacheSeconds!=0){101 jedis.expire(key,cacheSeconds);102 }103 logger.debug("setObjectList {}={}",key,value);104 }catch (Exception e){105 logger.warn("setObjectList {} 错误：{}",key,e);106 e.printStackTrace();107 }108 return result;109 }
复制代码
View Code

 

So do it,and change it,no regret!

http://www.cnblogs.com/woshimrf/p/5211253.html

你可能感兴趣的文章
openstack M版安装 compute(nova)服务篇
查看>>
大学四年你必须做到的事儿---那些学计算机的
查看>>
rlwrap安装
查看>>
【scala初学】scala IDE eclipse
查看>>
VMM2012应用指南之4-向VMM中添加Hyper-V主机与应用服务器
查看>>
我的友情链接
查看>>
我的友情链接
查看>>
perl文件读写
查看>>
R-FCN
查看>>
DenseNet
查看>>
jspsmart 支持jdk1.4 解决utf-8编码时出现乱码的问题 附源码和jar包
查看>>
我的友情链接
查看>>
把LYNC从评估版升级到正式版
查看>>
我的友情链接
查看>>
eclipse 不能建立maven项目
查看>>
Session死亡讲解
查看>>
八周三次课（1月31日）
查看>>
我的友情链接
查看>>
关于linux中 变量相关 学习小白总结
查看>>
文德数据启动国庆中秋大优惠——现在购买立省三千
查看>>
喝酒易醉，品茶养心，人生如梦，品茶悟道，何以解忧？唯有杜康！-- 愿君每日到此一游！
当前时间: 2025-01-04 12:22:44   当前IP: 3.133.136.95   联系邮箱:javaeecc@qq.com     Copyright © 2020 - 2022 baihongyu.com 京ICP备2021015314号-2
强烈建议你试试无所不能的CHAT-GPT，快点击我
强烈建议你试试无所不能的CHAT-GPT，快点击我