通过JedisPool整合redis

超、凢脫俗 2022-05-28 10:24 183阅读 0赞

1.下载redis，地址：https://download.csdn.net/download/rexueqingchun/10324719

2.设置redis密码，修改redis.windows.conf配置文件，去掉requirepass foobared前面的注释

（注：foobared为默认密码，可以自定义密码，例如：123456）

3.在redis目录中新建startup.bat，添加redis-server.exe redis.windows.conf命令，通过startup.bat启动服务

4.项目中添加 jedis-2.1.0.jar，地址：https://download.csdn.net/download/rexueqingchun/10324985

5.项目中新建redis.properties文件：

#访问地址
    redis.host=127.0.0.1
    #访问端口
    redis.port=6379
    #注意，如果没有password，此处不设置值，但这一项要保留
    redis.password=123456
    #最大空闲数，数据库连接的最大空闲时间。超过空闲时间，数据库连接将被标记为不可用，然后被释放。设为0表示无限制。
    redis.maxIdle=300
    #连接池的最大数据库连接数。设为0表示无限制  
    redis.maxActive=600
    #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
    redis.maxWait=1000
    #在borrow一个jedis实例时，是否提前进行alidate操作；如果为true，则得到的jedis实例均是可用的；  
    redis.testOnBorrow=true
    #客户端连接超时时间
    redis.timeout=30000
    #可用数据库数
    redis.database = 0

6.项目中新建redis-context.xml文件：

在web.xml中引入redis-context.xml文件：

<context-param>
    	<param-name>contextConfigLocation</param-name>
    	<param-value>
    		/WEB-INF/applicationContext.xml;
    		/WEB-INF/redis-context.xml;
    	</param-value>
    </context-param>

7.在service中注入jedisPool：

import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    
    import net.sf.json.JSONObject;
    import net.sf.json.JsonConfig;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import cn.com.highset.goexpo.util.JsonDateValueProcessor;
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    
    @Service
    public class RedisService {
    	
    	@Autowired
            private JedisPool jedisPool;//注入jedisPool
    	
    	//保存单个值
    	public void set(String key,String value){
                Jedis jedis = jedisPool.getResource();
                jedis.set(key, value);
    	}
    	
    	//获取单个值
    	public String get(String key){
    	    String value = "";
    	    Jedis jedis = jedisPool.getResource();
                value = jedis.get(key);
                return value;
    	}
    	
    	//根据key删除值
    	public void del(String key){
    	    Jedis jedis = jedisPool.getResource();
                jedis.del(key);
    	}
    
    	//保存list集合
    	public void setList(String key,List<Map> list){
    	    if(list != null){
    	        Jedis jedis = jedisPool.getResource();
    		for(Map m : list){
    		    JsonConfig jsonConfig = new JsonConfig();  
    		    //处理时间格式,注意时间类型java.sql.Timestamp/java.util.Date/java.sql.Date
    		    jsonConfig.registerJsonValueProcessor(java.sql.Timestamp.class, new JsonDateValueProcessor("yyyy-MM-dd HH:mm:ss"));  
    		    JSONObject jsonObject = JSONObject.fromObject(m,jsonConfig);  
                        String jsonString = jsonObject.toString(); 
                        jedis.rpush(key, jsonString);
    	        }
    	    }
    	}
    	
    	//获取list集合
    	public List<Map> getList(String key){
    	    List<Map> listMap = new ArrayList<Map>();
    	    Jedis jedis = jedisPool.getResource();
    	    List<String> list = jedis.lrange(key, 0, -1);  
                for(String m : list){  
            	JSONObject jsonObject = JSONObject.fromObject(m);
                    Map<Object, Object> map = (Map)jsonObject;
                    listMap.add(map);
                }  
                return listMap;
    	}
    	
    	//获取list分页数据
    	public List<Map> getPageList(String key,int start,int end){
    	    List<Map> listMap = new ArrayList<Map>();
    	    Jedis jedis = jedisPool.getResource();
    	    List<String> list = jedis.lrange(key, start, end);  
                for(String m : list){  
            	JSONObject jsonObject = JSONObject.fromObject(m);
                    Map<Object, Object> map = (Map)jsonObject;
                    listMap.add(map);
                }  
                return listMap;
    	}
    }

8.处理json日期格式工具类：

import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.Locale;
    
    import net.sf.json.JsonConfig;
    import net.sf.json.processors.JsonValueProcessor;
    
    public class JsonDateValueProcessor implements JsonValueProcessor { 
    	
        private String format ="yyyy-MM-dd hh:mm:ss";  
          
        public JsonDateValueProcessor() {  
            super();  
        }  
          
        public JsonDateValueProcessor(String format) {  
            super();  
            this.format = format;  
        }  
      
        @Override  
        public Object processArrayValue(Object paramObject,JsonConfig paramJsonConfig) {  
            return process(paramObject);  
        }  
      
        @Override  
        public Object processObjectValue(String paramString, Object paramObject,JsonConfig paramJsonConfig) {  
            return process(paramObject);  
        }  
          
        private Object process(Object value){  
            if(value instanceof Date){    
                SimpleDateFormat sdf = new SimpleDateFormat(format,Locale.CHINA);    
                return sdf.format(value);  
            }    
            return value == null ? "" : value.toString();    
        }  
    }

附常用redis命令：

启动redis服务：redis-server.exe redis.windows.conf   
远程连接redis服务：redis-cli -h 127.0.0.1 -p 6379  
设置key：set key value  
获取key值：get key  
查看是否设置密码：config get requirepass  
登录密码：auth password