修改redis连接问题

Pu Zhibing

2024-12-17 3f367b7d7ee0f2297dc1e6ae7b181c74680b942b

修改redis连接问题

 ZuulAHTravel/src/main/java/com/sinata/zuul/config/RedisConfig.java

@@ -4,6 +4,7 @@
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;


 ZuulAHTravel/src/main/java/com/sinata/zuul/util/RedisUtil.java

@@ -19,6 +19,8 @@

    @Autowired
    private JedisPool jedisPool;
    
    private Jedis resource;


    /**
@@ -28,9 +30,10 @@
     */
    public void setStrValue(String key, String value){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            String set = resource.set(key, value);
            closeJedis(resource);
        }
    }

@@ -43,9 +46,10 @@
     */
    public void setStrValue(String key, String value, int time){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            String setex = resource.setex(key, time, value);
            closeJedis(resource);
        }
    }

@@ -57,9 +61,10 @@
     */
    public String getValue(String key){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            String data = resource.get(key);
            closeJedis(resource);
            return data;
        }
        return null;
@@ -73,14 +78,15 @@
     */
    public List<Object> getValues(List<String> kes){
        if(null != kes){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            Pipeline pipelined = resource.pipelined();
            for(String key : kes){
                pipelined.get(key);
            }
            List<Object> list = pipelined.syncAndReturnAll();

            closeJedis(resource);
            pipelined.clear();
            try {
                pipelined.close();
@@ -104,9 +110,10 @@
     * @param value
     */
    public void addListRight(String key, String value){
        Jedis resource = jedisPool.getResource();
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        resource.rpush(key, value);
        closeJedis(resource);
    }
    
    /**
@@ -115,9 +122,10 @@
     * @param value
     */
    public void addListLeft(String key, String value){
        Jedis resource = jedisPool.getResource();
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        resource.lpush(key, value);
        closeJedis(resource);
    }
    
    
@@ -127,7 +135,9 @@
     * @return
     */
    public String getListFirstValue(String key){
        Jedis resource = jedisPool.getResource();
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        String lpop = resource.lpop(key);
        return lpop;
    }
@@ -140,20 +150,13 @@
     */
    public void remove(String key){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            Long del = resource.del(key);
            closeJedis(resource);
        }
    }


    /**
     * 删除资源
     * @param jedis
     */
    public void closeJedis(Jedis jedis){
        if(null != jedis){
            jedis.close();
        }
    }

}

 ZuulAHTravel/src/main/resources/redis.properties

@@ -1,21 +1,10 @@
#redisÅäÖÿªÊ¼
# RedisÊý¾Ý¿âË÷Òý£¨Ä¬ÈÏΪ0£©
spring.redis.database=0
# Redis·þÎñÆ÷µØÖ·
spring.redis.host=127.0.0.1
# Redis·þÎñÆ÷Á¬½Ó¶Ë¿Ú
spring.redis.port=6379
# Redis·þÎñÆ÷Á¬½ÓÃÜÂ루ĬÈÏΪ¿Õ£©
spring.redis.password=123456
# Á¬½Ó³Ø×î´óÁ¬½ÓÊý£¨Ê¹ÓøºÖµ±íʾûÓÐÏÞÖÆ£©
spring.redis.jedis.pool.max-active=1024
# Á¬½Ó³Ø×î´ó×èÈûµÈ´ýʱ¼ä£¨Ê¹ÓøºÖµ±íʾûÓÐÏÞÖÆ£©
spring.redis.jedis.pool.max-wait=10000
# Á¬½Ó³ØÖеÄ×î´ó¿ÕÏÐÁ¬½Ó
spring.redis.jedis.pool.max-idle=200
# Á¬½Ó³ØÖеÄ×îС¿ÕÏÐÁ¬½Ó
spring.redis.jedis.pool.min-idle=50
# Á¬½Ó³¬Ê±Ê±¼ä£¨ºÁÃ룩
spring.redis.timeout=10000
#redisÅäÖýáÊø
spring.redis.block-when-exhausted=true