使用redis作为缓存工具,很容易出现从redis连接池中得不到连接的问题。而使用redis连接池获取连接的时候,往往是在高并发情形下,出现如题所示的问题。本人一般从如下几个方面排查,经验之谈~
1)首先判断redis连接参数是否配置正确?很有可能,之前一直能取,但现在突然出现异常,很有可能是redis的服务器down掉了,或者redis的连接条件被更改;
2)网络权限更改:做过项目就很容易知道,每种环境的权限是不同的,很有可能你项目所在的网段连接redis的权限被更改,导致之前一直可以获取redis连接,但现在却无法获取。
3)查代码:一般而言,从redis里面获取连接取数据,完毕之后应该立即归还到池中。应该注意的是,一般都会用典型的try{} catch{} finally{}结构包围,在finally{}中释放连接(这样可以确保无论是否发生异常,redis的连接都能及时被归还到连接池中);
4)归还redis连接必须要注意的一点,如:
//从连接池获取连接 Jedis jedis = pool.getResource(); try{ }catch(Exception e) { e.printStackTrace(); }finally{ //归还连接到redis池中 poo.returnResource(); }
这段代码看起来很满足3)的规范,在finally里归还了连接。但!有一个隐藏的容错性考虑,当Jedis jedis = pool.getResource();这段代码发生异常时,finally的代码是不会被执行的。我可以模拟一下,
String str = null; System.out.println(str.length());//模拟异常 try{ System.out.println("模拟从redis取数据"); }catch(Exception e) { e.printStackTrace(); }finally{ System.out.println("连接释放。。。"); }
运行报异常,finally里面的代码不会被执行。所以,应该改成这样:
//从连接池获取连接 Jedis jedis = null; try{ jedis = pool.getResource(); }catch(Exception e) { e.printStackTrace(); }finally{ //归还连接到redis池中 poo.returnResource(); }
当然,这是由于try catch finally的机制决定,但很容易被忽视~
5)关闭redis的持久化,提高redis的存取性能:当使用redis缓存的数据越来越多的时候,可以考虑关闭redis的持久化功能。具体做法是:修改redis配置文件,注释掉原来的持久化规则,将redis.conf代码
save 900 1
save 300 10
save 60 10000
注释,修改为 save " ",然后重启redis服务器即可~
再不济的话,提高redis池连接个数和最大空闲数等参数……
相关推荐
java.lang.NoSuchMethodError: redis.clients.jedis.ScanResult.getStringCursor()Ljava/lang/String; at org.crazycake.shiro.WorkAloneRedisManager.keys(WorkAloneRedisManager.java:149) at org.crazycake....
Redis的官方推荐Java客户端...import redis.clients.jedis.Jedis; Jedis jedis = new Jedis("localhost"); jedis.set("foo", "bar"); String value = jedis.get("foo"); jedis.close(); System.out.println(value);
Exception in thread “main” redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketTimeoutException: Read timed out at redis.clients.util.RedisInputStream.ensureFill...
Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。从2010年3月15日起,Redis的开发工作由VMware主持。
redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: Connection refused: connect at redis.clients.jedis.Connection.connect(Connection.java:164) at redis.clients.jedis....
jedis-2.4.1.jar、redis.clients-3.0.1.jar、jedis-3.0.0.jar 全量包,可用!
import redis.clients.jedis.exceptions.JedisConnectionException; public class FirestJedisTest { private static Jedis jedis = new Jedis("127.0.0.1"); public void testConn() { try { jedis....
<groupId>redis.clients <artifactId>jedis <version>2.0.0 ``` 2. **基本操作示例**: - 连接Redis:`Jedis jedis = new Jedis("localhost", 6379);` - 设置键值对:`jedis.set("key", "value");` - 获取...
使用Java操作Redis需要jedis-2.1.0.jar,如果需要使用Redis连接池的话,还需commons-pool-1.5.4.jar使用Java操作Redis需要jedis-2.1.0.jar,如果需要使用Redis连接池的话,还需commons-pool-1.5.4.jar
redis.conf Redis配置文件 下载 redis.conf 配置详解 Redis配置文件redis.conf 详解1.基本配置内存单位的表示# 1k => 1000 bytes# ...Redis 的详细介绍Redis 的下载地址
包含Java说明文件、配置代码、redis相应版本的Jar 1、代码片段要求的框架为:SpringMVC,但原理都是一样的,采用其他方式也可以。 2、RedisMng为简单封装的接口,不封装,直接采用redisTemplate也可以。
<groupId>redis.clients <artifactId>jedis 最新版本号 ``` 在 Java 项目中使用 Jedis,你需要做以下几步: 1. 创建 Jedis 实例:通过指定 Redis 服务器的 IP 地址和端口,可以创建一个 Jedis 实例。 2. 连接 ...
import redis.clients.jedis.Jedis; Jedis jedis = new Jedis("your_instance_ip", your_port); jedis.auth("your_password"); ``` 除了上述基础操作,阿里云Redis还提供了丰富的功能,如备份与恢复、监控与...
解决报错_org.springframework.data.redis.serializer.SerializationException_ Could not write_read JSON
redis6.2.6 redis.conf配置文件
import redis.clients.jedis.Jedis; public class RedisClient { public static void main(String[] args) { Jedis jedis = new Jedis("localhost", 6379); jedis.set("key", "value"); String value = jedis....
<groupId>redis.clients <artifactId>jedis 版本号 ``` 然后,通过简单的Java代码即可连接并操作Redis: ```java Jedis jedis = new Jedis("localhost"); jedis.set("key", "value"); String value = jedis.get...
import redis.clients.jedis.Jedis; public class Publisher { private Jedis jedis; public Publisher(String redisHost, int redisPort) { jedis = new Jedis(redisHost, redisPort); } public void ...
<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"> <property name="hostName" ref="redisHost"/> ${redis.port}"/> ...
import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class JedisPoolExample { private static final String REDIS_HOST = "localhost"; private static final int ...