jedis利用及注意事项

打印 上一主题 下一主题

主题 902|帖子 902|积分 2706

参考:

Jedis

Jedis 是一个 Java 客户端,用于与 Redis 数据库进行交互。它提供了一系列简单易用的 API,使得在 Java 应用步伐中利用 Redis 变得非常方便。以下是 Jedis 的利用方法及一些注意事项。
Jedis的上风

Lettuce客户端及Jedis客户端比较如下:

  • Lettuce:

    • Lettuce客户端没有连接保活探测,错误连接存在连接池中会造成请求超时报错。
    • Lettuce客户端未实现testOnBorrow等连接池检测方法,无法在利用连接之进步行连接校验。

  • Jedis:

    • Jedis客户端实现了testOnBorrow、testWhileIdle、testOnReturn等连接池校验配置。
    • 开启testOnBorrow在每次借用连接前都会进行连接校验,可靠性最高,但是会影响性能(每次Redis请求前会进行探测)。
    • testWhileIdle可以在连接空闲时进行连接检测,合理配置阈值可以及时剔除连接池中的非常连接,防止利用非常连接造成业务报错。
    • 在空闲连接检测之前,连接出现问题,可能会造成利用该连接的业务报错,此处可以通过参数控制检测间隔(timeBetweenEvictionRunsMillis)。

因此,Jedis客户端在面对连接非常,网络抖动等场景下的非常处理和检测能力显着强于Lettuce,可靠性更强。
Jedis 利用

1. 引入依赖

假如你利用 Maven,可以在 pom.xml 中添加以下依赖:
  1. <dependency>
  2.     <groupId>redis.clients</groupId>
  3.     <artifactId>jedis</artifactId>
  4.     <version>5.2.0</version>
  5. </dependency>
复制代码
2. 创建 Jedis 实例

创建一个 Jedis 实例,连接到 Redis 服务器:
  1. import redis.clients.jedis.Jedis;
  2. public class JedisExample {
  3.     public static void main(String[] args) {
  4.         // 创建一个 Jedis 实例,连接到 localhost:6379
  5.         Jedis jedis = new Jedis("localhost", 6379);
  6.         
  7.         // 进行身份验证(如果需要)
  8.         // jedis.auth("your_password");
  9.         // 测试连接
  10.         System.out.println("连接成功: " + jedis.ping());
  11.         
  12.         // 关闭连接
  13.         jedis.close();
  14.     }
  15. }
复制代码
3. 常用操作


  • 字符串操作
  1. // 设置值
  2. jedis.set("key", "value");
  3. // 获取值
  4. String value = jedis.get("key");
  5. System.out.println("获取的值: " + value);
复制代码

  • 哈希操作
  1. // 设置哈希
  2. jedis.hset("user:1000", "name", "Alice");
  3. jedis.hset("user:1000", "age", "30");
  4. // 获取哈希
  5. String name = jedis.hget("user:1000", "name");
  6. System.out.println("用户姓名: " + name);
复制代码

  • 列表操作
  1. // 添加元素到列表
  2. jedis.lpush("mylist", "item1");
  3. jedis.lpush("mylist", "item2");
  4. // 获取列表元素
  5. List<String> list = jedis.lrange("mylist", 0, -1);
  6. System.out.println("列表内容: " + list);
复制代码

  • 集合操作
  1. // 添加元素到集合
  2. jedis.sadd("myset", "member1");
  3. jedis.sadd("myset", "member2");
  4. // 获取集合成员
  5. Set<String> members = jedis.smembers("myset");
  6. System.out.println("集合成员: " + members);
复制代码
注意事项


  • 连接管理

    • 每次操作前创建和关闭 Jedis 实例会导致性能问题,发起利用连接池。
    • 可以利用 JedisPool 来管理连接。
    • Jedis可以利用tr-with-resources管理资源
    1. import redis.clients.jedis.JedisPool;
    2. import redis.clients.jedis.Jedis;
    3. public class JedisPoolExample {
    4.     public static void main(String[] args) {
    5.       JedisPoolConfig config = new JedisPoolConfig();
    6.        config.setMaxTotal(100);       // 最大连接数
    7.        config.setMaxIdle(50);         // 最大空闲连接数
    8.        config.setMinIdle(10);         // 最小空闲连接数
    9.        config.setTestOnBorrow(true);  // 在获取连接时检查连接有效性
    10.        config.setTestWhileIdle(true);  // 在空闲时检查连接有效性
    11.        config.setMinEvictableIdleTimeMillis(60000); // 空闲连接最小存活时间,60S
    12.        config.setTimeBetweenEvictionRunsMillis(30000); // 清理线程运行时间间隔,30S
    13.        JedisPool pool = new JedisPool(config, "localhost", 6379);
    14.         try (Jedis jedis = pool.getResource()) {
    15.             System.out.println("连接成功: " + jedis.ping());
    16.         } catch (Exception e) {
    17.             e.printStackTrace();
    18.         } finally {
    19.             pool.close();
    20.         }
    21.     }
    22. }
    复制代码
  • 非常处理

    • 在利用 Jedis 时,应当处理可能的非常,例如连接失败、超时等。

  • 线程安全

    • Jedis 实例不是线程安全的,因此不应在多个线程之间共享同一个实例。利用连接池可以避免这个问题。

  • Redis 配置

    • 确保 Redis 服务正常运行,并根据需求调整 Redis 配置(如最大连接数、超时时间等)。

  • 数据逾期

    • Redis 提供了键的逾期功能,可以通过 expire 下令设置键的有效时间,以防止数据长时间占用内存。

  • 监控与优化

    • 监控 Redis 性能指标(如内存利用、下令实行时间等),并根据实际情况进行优化。

连接池推荐配置

参数配置介绍配置发起maxTotal最大连接,单位:个根据Web容器的Http线程数来进行配置,估算单个Http请求中可能会并行进行的Redis调用次数,例如:Tomcat中的Connector内的maxConnections配置为150,每个Http请求可能会并行实行2个Redis请求,在此之上进行部分预留,则发起配置至少为:150 x 2 + 100= 400 限制条件:单个Redis实例的最大连接数。maxTotal和客户端节点数(CCE容器或业务VM数量)数值的乘积要小于单个Redis实例的最大连接数。例如:Redis主备实例配置maxClients为10000,单个客户端maxTotal配置为500,则最大客户端节点数量为20个。maxIdle最大空闲连接,单位:个配置与maxTotal一致。minIdle最小空闲连接,单位:个一般来说发起配置为maxTotal的X分之一,例如此处常规配置发起为:100。对于性能敏感的场景,为了防止经常连接数量抖动造成影响,可以配置与maxIdle一致,例如:400。maxWaitMillis最大获取连接等候时间,单位:毫秒获取连接时最大的连接池等候时间,根据单次业务最长容忍的失败时间减去实行下令的超时时间得到发起值。例如:Http最长容忍的失败时间为15s,Redis请求的timeout设置为10s,则此处可以配置为5s。timeout下令实行超时时间,单位:毫秒单次实行Redis下令最大可容忍的超时时间,根据业务步伐的逻辑进行选择,出于对网络容错等考虑发起配置为不小于210ms。特殊的探测逻辑或者环境非常检测等,可以适当调整达到秒级。minEvictableIdleTimeMillis空闲连接逐出时间,大于该值的空闲连接不停未被利用则会被释放,单位:毫秒假如盼望系统不会经常对连接进行断链重修,此处可以配置一个较大值(xx分钟),或者此处配置为-1并且搭配空闲连接检测进行定期检测。timeBetweenEvictionRunsMillis空闲连接探测时间间隔,单位:毫秒根据系统的空闲连接数量进行估算,例如系统的空闲连接探测时间配置为30s,则代表每隔30s会对连接进行探测,假如30s内发生非常的连接,经过探测后会进行连接排除。根据连接数的多少进行配置,假如连接数太大,配置时间太短,会造成请求资源浪费。对于几百级别的连接,常规来说发起配置为30s,可以根据系统需要进行动态调整。testOnBorrow向资源池借用连接时是否做连接有效性检测(ping),检测到的无效连接将会被移除。对于业务连接极端敏感的,并且性能可以接受的情况下,可以配置为True,一般来说发起配置为False,启用连接空闲检测。testWhileIdle是否在空闲资源监测时通过ping下令监测连接有效性,无效连接将被烧毁。TruetestOnReturn向资源池归还连接时是否做连接有效性检测(ping),检测到无效连接将会被移除。FalsemaxAttempts在JedisCluster模式下,您可以配置maxAttempts参数来界说失败时的重试次数。发起配置3-5之间,默认配置为5。根据业务接口最大超时时间和单次请求的timeout综合配置,最大配置不发起超过10,否则会造成单次请求处理时间过长,接口请求阻塞。
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

正序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

傲渊山岳

金牌会员
这个人很懒什么都没写!

标签云

快速回复 返回顶部 返回列表