免费视频淫片aa毛片_日韩高清在线亚洲专区vr_日韩大片免费观看视频播放_亚洲欧美国产精品完整版

打開APP
userphoto
未登錄

開通VIP，暢享免費電子書等14項超值服

開通VIP

首頁

好書

留言交流

下載APP

聯(lián)系客服
jedis封裝Dao層
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns="http://www.springframework.org/schema/beans"  
  3.     xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"  
  4.     xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"  
  5.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  6.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd  
  7.     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd  
  8.     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd  
  9.     http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">  
  10. <!-- 連接池配置 -->  
  11.     <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  
  12.         <!-- 最大連接數(shù) -->  
  13.         <property name="maxTotal" value="30" />  
  14.         <!-- 最大空閑連接數(shù) -->  
  15.         <property name="maxIdle" value="10" />  
  16.         <!-- 每次釋放連接的最大數(shù)目 -->  
  17.         <property name="numTestsPerEvictionRun" value="1024" />  
  18.         <!-- 釋放連接的掃描間隔（毫秒） -->  
  19.         <property name="timeBetweenEvictionRunsMillis" value="30000" />  
  20.         <!-- 連接最小空閑時間 -->  
  21.         <property name="minEvictableIdleTimeMillis" value="1800000" />  
  22.         <!-- 連接空閑多久后釋放, 當空閑時間>該值 且 空閑連接>最大空閑連接數(shù) 時直接釋放 -->  
  23.         <property name="softMinEvictableIdleTimeMillis" value="10000" />  
  24.         <!-- 獲取連接時的最大等待毫秒數(shù),小于零:阻塞不確定的時間,默認-1 -->  
  25.         <property name="maxWaitMillis" value="1500" />  
  26.         <!-- 在獲取連接的時候檢查有效性, 默認false -->  
  27.         <property name="testOnBorrow" value="true" />  
  28.         <!-- 在空閑時檢查有效性, 默認false -->  
  29.         <property name="testWhileIdle" value="true" />  
  30.         <!-- 連接耗盡時是否阻塞, false報異常,ture阻塞直到超時, 默認true -->  
  31.         <property name="blockWhenExhausted" value="false" />  
  32.     </bean>     
  33.     <!-- jedis客戶端單機版 -->  
  34.     <bean id="redisClient" class="redis.clients.jedis.JedisPool">  
  35.         <constructor-arg name="host" value="192.168.116.13"></constructor-arg>  
  36.         <constructor-arg name="port" value="6379"></constructor-arg>  
  37.         <constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>  
  38.     </bean>    
  39.     <bean id="jedisClient" class="com.taotao.rest.daoImpl.JedisClientCluster"></bean>  
  40.     <!--  <bean id="redisClient" class="redis.clients.jedis.JedisCluster">  
  41.         <constructor-arg name="nodes">  
  42.             <set>  
  43.                 <bean class="redis.clients.jedis.HostAndPort">  
  44.                     <constructor-arg name="host" value="192.168.116.13"></constructor-arg>  
  45.                     <constructor-arg name="port" value="7001"></constructor-arg>  
  46.                 </bean>  
  47.                 <bean class="redis.clients.jedis.HostAndPort">  
  48.                     <constructor-arg name="host" value="192.168.116.13"></constructor-arg>  
  49.                     <constructor-arg name="port" value="7002"></constructor-arg>  
  50.                 </bean>  
  51.                 <bean class="redis.clients.jedis.HostAndPort">  
  52.                     <constructor-arg name="host" value="192.168.116.13"></constructor-arg>  
  53.                     <constructor-arg name="port" value="7003"></constructor-arg>  
  54.                 </bean>  
  55.                 <bean class="redis.clients.jedis.HostAndPort">  
  56.                     <constructor-arg name="host" value="192.168.116.13"></constructor-arg>  
  57.                     <constructor-arg name="port" value="7004"></constructor-arg>  
  58.                 </bean>  
  59.                 <bean class="redis.clients.jedis.HostAndPort">  
  60.                     <constructor-arg name="host" value="192.168.116.13"></constructor-arg>  
  61.                     <constructor-arg name="port" value="7005"></constructor-arg>  
  62.                 </bean>  
  63.                 <bean class="redis.clients.jedis.HostAndPort">  
  64.                     <constructor-arg name="host" value="192.168.116.13"></constructor-arg>  
  65.                     <constructor-arg name="port" value="7006"></constructor-arg>  
  66.                 </bean>  
  67.             </set>  
  68.         </constructor-arg>  
  69.         <constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>  
  70.     </bean>    
  71.     <bean id="JedisClientCluster" class="com.taotao.rest.daoImpl.JedisClientCluster"></bean>  
  72.     -->  
  73.       
  74. </beans>  

單機版java

  1. package com.taotao.rest.daoImpl;  
  2.   
  3. import org.springframework.beans.factory.annotation.Autowired;  
  4.   
  5. import com.taotao.rest.dao.JedisClient;  
  6.   
  7. import redis.clients.jedis.Jedis;  
  8. import redis.clients.jedis.JedisPool;  
  9.   
  10. public class JedisClientSingle implements JedisClient{  
  11.       
  12.     @Autowired  
  13.     private JedisPool jedisPool;   
  14.       
  15.     @Override  
  16.     public String get(String key) {  
  17.         Jedis jedis = jedisPool.getResource();  
  18.         String string = jedis.get(key);  
  19.         jedis.close();  
  20.         return string;  
  21.     }  
  22.   
  23.     @Override  
  24.     public String set(String key, String value) {  
  25.         Jedis jedis = jedisPool.getResource();  
  26.         String string = jedis.set(key, value);  
  27.         jedis.close();  
  28.         return string;  
  29.     }  
  30.   
  31.     @Override  
  32.     public String hget(String hkey, String key) {  
  33.         Jedis jedis = jedisPool.getResource();  
  34.         String string = jedis.hget(hkey, key);  
  35.         jedis.close();  
  36.         return string;  
  37.     }  
  38.   
  39.     @Override  
  40.     public long hset(String hkey, String key, String value) {  
  41.         Jedis jedis = jedisPool.getResource();  
  42.         Long result = jedis.hset(hkey, key, value);  
  43.         jedis.close();  
  44.         return result;  
  45.     }  
  46.   
  47.     @Override  
  48.     public long incr(String key) {  
  49.         Jedis jedis = jedisPool.getResource();  
  50.         Long result = jedis.incr(key);  
  51.         jedis.close();  
  52.         return result;  
  53.     }  
  54.   
  55.     @Override  
  56.     public long expire(String key, int second) {  
  57.         Jedis jedis = jedisPool.getResource();  
  58.         Long result = jedis.expire(key, second);  
  59.         jedis.close();  
  60.         return result;  
  61.     }  
  62.   
  63.     @Override  
  64.     public long ttl(String key) {  
  65.         Jedis jedis = jedisPool.getResource();  
  66.         Long result = jedis.ttl(key);  
  67.         jedis.close();  
  68.         return result;  
  69.     }  
  70.   
  71. }  


集群版的

  1. package com.taotao.rest.daoImpl;  
  2.   
  3. import org.springframework.beans.factory.annotation.Autowired;  
  4.   
  5. import redis.clients.jedis.JedisCluster;  
  6.   
  7. import com.taotao.rest.dao.JedisClient;  
  8.   
  9. public class JedisClientCluster implements JedisClient {  
  10.   
  11.     @Autowired  
  12.     private JedisCluster jedisCluster;  
  13.       
  14.     @Override  
  15.     public String get(String key) {  
  16.         return jedisCluster.get(key);  
  17.     }  
  18.   
  19.     @Override  
  20.     public String set(String key, String value) {  
  21.         return jedisCluster.set(key, value);  
  22.     }  
  23. //哈希的get  
  24.     @Override  
  25.     public String hget(String hkey, String key) {  
  26.         return jedisCluster.hget(hkey, key);  
  27.     }  
  28.     //哈希的set  
  29.     @Override  
  30.     public long hset(String hkey, String key, String value) {  
  31.         return jedisCluster.hset(hkey, key, value);  
  32.     }  
  33.     //設(shè)置緩存對象值+1  
  34.     @Override  
  35.     public long incr(String key) {  
  36.         return jedisCluster.incr(key);  
  37.     }  
  38. //設(shè)置緩存對象超時時間  
  39.     @Override  
  40.     public long expire(String key, int second) {  
  41.         return jedisCluster.expire(key, second);  
  42.     }  
  43. //判斷緩存對象是否存在  
  44.     //TTL以毫秒為單位。  
  45.   
  46.     //-1, 如果key沒有到期超時。  
  47.   
  48.     //-2, 如果鍵不存在。  
  49.     @Override  
  50.     public long ttl(String key) {  
  51.         return jedisCluster.ttl(key);  
  52.     }  
  53.   
  54. }  



使用用例

配置文件

名字：resource.properties

內(nèi)容

INDEX_CONTENT_REDIS_KEY=INDEX_CONTENT_REDIS_KEY

  1. package com.taotao.rest.service.impl;  
  2.   
  3. import java.util.List;  
  4.   
  5. import org.apache.commons.lang3.StringUtils;  
  6. import org.springframework.beans.factory.annotation.Autowired;  
  7. import org.springframework.beans.factory.annotation.Value;  
  8. import org.springframework.stereotype.Service;  
  9.   
  10. import com.taotao.common.utils.JsonUtils;  
  11. import com.taotao.mapper.TbContentMapper;  
  12. import com.taotao.pojo.TbContent;  
  13. import com.taotao.pojo.TbContentExample;  
  14. import com.taotao.pojo.TbContentExample.Criteria;  
  15. import com.taotao.rest.dao.JedisClient;  
  16. import com.taotao.rest.service.ContentService;  
  17.   
  18. @Service  
  19. public class ContentServiceImpl implements ContentService{  
  20.   
  21.     @Autowired  
  22.     private TbContentMapper contentMapper;  
  23.     @Autowired  
  24.     private JedisClient jedisClient;  
  25.     @Value("${INDEX_CONTENT_REDIS_KEY}")  
  26.     private String INDEX_CONTENT_REDIS_KEY;  
  27.     @Override  
  28.     public List<TbContent> getContentList(long contentCid) {  
  29.         //從緩存中取出  
  30.         try {  
  31.             String result = jedisClient.hget(INDEX_CONTENT_REDIS_KEY, contentCid+"");  
  32.             if(!StringUtils.isBlank(result)){  
  33.                 List<TbContent> resultlist = JsonUtils.jsonToList(result, TbContent.class);  
  34.                 return resultlist;  
  35.             }  
  36.         } catch (Exception e) {  
  37.             e.printStackTrace();  
  38.         }  
  39.           
  40.         TbContentExample example = new TbContentExample();  
  41.         Criteria criteria = example.createCriteria();  
  42.         criteria.andCategoryIdEqualTo(contentCid);  
  43.           
  44.         List<TbContent> list = contentMapper.selectByExample(example);  
  45.           
  46.         //像緩存中添加內(nèi)容  
  47.         try {  
  48.             //把list轉(zhuǎn)換成字符串  
  49.             String cacheString =JsonUtils.objectToJson(list);  
  50.             jedisClient.hset(INDEX_CONTENT_REDIS_KEY, contentCid+"", cacheString);  
  51.         } catch (Exception e) {  
  52.             e.printStackTrace();  
  53.         }  
  54.           
  55.         return list;  
  56.     }  
  57.   
  58. }  

本站僅提供存儲服務(wù)，所有內(nèi)容均由用戶發(fā)布，如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請點擊舉報。
打開APP，閱讀全文并永久保存 查看更多類似文章
猜你喜歡
類似文章
Jedis編程設(shè)計:連接池
征服 Redis + Jedis
spring框架下配置lucene
Spring+Redis(keyspace notification)實現(xiàn)定時任務(wù)（訂單過期自動關(guān)閉）
Redis Sentinel主從高可用方案（附Jedis Sentinel教程）
Redis的介紹及使用實例.
更多類似文章 >>
生活服務(wù)
分享 收藏 導(dǎo)長圖 關(guān)注 下載文章
綁定賬號成功
后續(xù)可登錄賬號暢享VIP特權(quán)！
如果VIP功能使用有故障，
可點擊這里聯(lián)系客服！

聯(lián)系客服