文档首页

全部产品

弹性缓存数据库（Redis）

租户端数据库弹性缓存数据库（Redis）开发指南

Jedis使用demo示例

最近更新时间: 2024-10-17 17:10:00

准备工作

下载客户端Jedis ，推荐使用最新版本。

短连接

短连接连接数据库的代码示例，如下所示。

import redis.clients.jedis.Jedis;
public class HelloRedis {
  public static void main(String[] args) {
        try {
            String host = "192.xx.xx.195";
            int port = 6379;
            String password = "123ad6aq";
            //连接 Redis
            Jedis jedis = new Jedis(host, port);
            //鉴权
            jedis.auth(password);
            /**接下来可以开始操作 Redis 实例，可以参考                 https://github.com/xetorthio/jedis */
            //设置 Key
            jedis.set("redis", "tencent");
            System.out.println("set key redis suc, value is: tencent");
            //获取 Key
            String value = jedis.get("redis");
            System.out.println("get key redis is: " + value);
            //关闭退出
            jedis.quit();
            jedis.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

连接池

连接池代码示例如下所示，其中各个参数的含义，请参见下表所示。

参数	含义	建议
setMaxTotal	资源池中的最大连接数。设置该业务并发量；客户端能希望的访问延迟；服务端能支撑的连接数。	设置该参数，需要考虑业务并发量、访问延迟、最大连接数等因素 - 如果服务端使用的标准版实例，CRedis会默认提供1万连接。客户端部署了10台机器，那么单台配置就不超过10000/10=1000。 - 如果业务希望耗时能全部在2ms内返回，单个连接的QPS就是1s/2ms=500qps。如果业务侧需要并发10万QPS，那么就需要100000/500=200总连接数。根据客户侧部署的规格数量，比如部署2台机器，那么配置就必须大于100。
setMaxIdle	连接池最大空闲连接数，既业务需要的最大连接数。一般推荐与Maxtotal相同。	一般推荐与 setMaxTotal 相同。
setMinIdle	资源池允许的最小空闲连接数。	该参数设置过大导致连接池浪费，建议为 setMaxTotal 的5%-10%。
timeout	超时时间。	该参数需要根据业务模型及网络链路性能设置。 - 一般网络延迟较低，服务耗时非常敏感的业务，可以设置50-100ms。 - 如果业务容忍度高，或者业务访问kv数据较大，可以设置500ms、1000ms。
setTestOnBorrow	设置在从连接池中获取连接时是否进行连接测试。	- 如果设置为 `true`，则在获取连接时会调用 `connection.isValid()`方法进行连接测试，以确保获取到的连接是可用的。但同时会消耗QPS性能。 - 如果设置为 `false`，则不会进行连接测试，可以提高连接获取的速度，但是可能会获取到不可用的连接。
setTestOnReturn	设置将连接归还连接池时，是否进行校验。	- 如果设置为 `true`，则在归还连接时会调用 `connection.isValid()` 方法进行连接测试，以确保归还的连接是可用的。 - 如果设置为 `false`，则不会进行连接测试，可以提高归还连接的速度，但是可能会归还不可用的连接。通常情况下建议设置为 `true`。

JedisPoolConfig config = new JedisPoolConfig();
// 最大空闲连接数，需自行评估，不超过Redis实例的最大连接数
config.setMaxIdle(200);
// 最大连接数，需自行评估，不超过Redis实例的最大连接数
config.setMaxTotal(200);
//资源池允许的最小空闲连接数
config.setMinIdle(20);
//当资源池连接用尽后，调用者的最大等待时间（单位为毫秒）
config.setMaxWaitMillis(3000);
//从连接池中获取对象时，会先进行ping检查，检查不通过，会从连接池中移走并销毁。
config.setTestOnBorrow(false);
//归还连接时，会进行检查，检查不通过，则销毁。
config.setTestOnReturn(false);
// 分别将host和password的值替换为实例的连接地址、密码
String host = "192.xx.xx.195";
String password = "123ad6aq";
//读写超时（单位为毫秒）
int timeout = 2000;
int port = 6379;
JedisPool pool = new JedisPool(config,host,port,timeout,password);
Jedis jedis = null;
boolean broken = false;
try
{
    jedis = pool.getResource();
    /// ... do stuff here ... for example
    jedis.set("redis", "tencent");
    String foobar = jedis.get("redis");
    jedis.zadd("tec", 0, "a");
    jedis.zadd("tec", 0, "b");
    Set < String > sose = jedis.zrange("tec", 0, -1);
}
catch(Exception e)
{
    broken = true;
}
finally
{
    if(broken)
    {
        pool.returnBrokenResource(jedis);
    }
    else if(jedis != null)
    {
        pool.returnResource(jedis);
    }
}