1.jedis的使用
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.2.0</version>
<type>jar</type>
<scope>compile</scope>
</dependency>
1.1直连
其实是tcp连接,底层用了socket。
每次都new Jedis(),使用这个对象去执行命令,返回对应的结果,关闭连接。
Jedis jedis = null;
try(
jedis = new Jedis("192.168.2.103",6379);
jedis.set("hello","word");
String value = jedis.get("hello");
}finally{
if(jedis != null){
jedis.close();
}
}
1.2JedisPool 连接池的使用
每次从JedisPool中借一个Jedis对象,Jedis执行命令,返回执行结果,归还Jedis对象给JedisPool。
这样不用每次都new Jedis,不用每次都走三次握手、没用每次都关闭Jedis。
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
JedisPool jedisPool = new JedisPool(poolConfig,"192.168.2.103",6379);
Jedis jedis = null;
try{
jedis = jedisPool.getResource();
jedis.set("hello","word");
}catch(Exception e){
e.printStackTrace();
}
finally{
if(jedis != null){
//如果使用的jedispool来得到的jedis,那cloese操作不是关闭,而是归还给线程池
jedis.close();
}
}
直连和使用连接池的对比
连接方式 | 优点 | 缺点 |
---|---|---|
直连 | 简单方便 适用于少量长期连接的场景 |
存在每次新建/关闭TCP开销 资源无法控制,存在连接泄露的可能 Jedis对象线程不安全 |
连接池 | Jedis预先生成,降低开销 连接池的形式保护和控制资源的使用 |
相对于直连,使用相对麻烦, 尤其在资源管理上需要很多参数来保证, 一旦规划不合理也会出现问题。 |
2.Jedis连接池配置
资源数控制参数
参数名 | 含义 | 默认值 | 使用建议 |
---|---|---|---|
maxTotal | 资源池最大连接数 | 8 | |
maxIdle | 资源池允许最大空闲连接数 | 8 | 建议=maxTotal |
minIdle | 资源池确保最少空闲连接数 | 0 | 预热minIdle |
jmxEnabled | 是否开启jmx监控,可用于监控 | true | 建议开启 |
适合的maxTotal
其实这个参数是比较难确定的,举个例子:
- 命令平均执行时间0.1ms = 0.001s
- 业务需要50000 QPS
- maxTotal理论值 = 0.001 * 50000 = 50个。实际值要偏大一些
对于适合的maxTotal而言,我们需要考虑
- 业务希望Redis并发量
- 客户端执行命令时间
- Redis资源:例如 nodes(例如应用个数) * maxTotal 是不能超过redis的最大连接数
- 资源开销:例如虽然希望控制空闲连接,但是不希望因为连接池的频繁释放创建连接造成不必靠开销
适合的maxIdle和minIdle
- 建议maxIdle = maxTotal,减少创建新连接的开销
- 建议预热minIdle,减少第一次启动后的新连接开销
QPS
QPS即每秒查询率,是对一个特定的查询服务器在规定时间内所处理流量多少的衡量标准。
计算关系:
QPS = 并发量 / 平均响应时间
并发量 = QPS * 平均响应时间
参数名 | 含义 | 默认值 | 使用建议 |
---|---|---|---|
blockWhenExhausted | 当资源池用尽后,调用者是否要等待。只有当为true时,下面的maxWaitMillis才会生效 | true | 建议使用默认值 |
maxWaitMillis | 当资源池连接用尽后,调用者的最大等待时间(单位毫秒) | -1:表示永不超时 | 不建议使用默认值 |
testOnBorrow | 向资源池借用连接时是否做连接有效性检查(ping),无效连接会被移除 | false | 建议false |
testOnReturn | 向资源池归还连接时是否做连接有效性测试(ping),无效连接会被移除 | false | 建议false |
连接池常见报错
redis.clients.jedis.exceptions.JedisConnectionException:Could not get a resource from the pool
...
Caused by: java.utils.NoSuchElementException:Timeout waiting for idle object
获取连接超时,资源池没有对应的资源。
redis.clients.jedis.exceptions.JedisConnectionException:Could not get a resource from the pool
...
Caused by: java.utils.NoSuchElementException:Pool exhausted
资源池中资源耗尽。
解决思路
1.慢查询阻塞:连接池的连接都被hang住了。
2.资源池参数不合理:QPS高、资源池太小。
3.连接泄露(没有close()):此类问题比较难定位。例如client list、netstat等、最重要是代码。
4.DNS异常。
网友评论