卡飞资源网

专业编程技术资源共享平台

如何在生产环境优雅的使用Jedis

如何使redis在生产环境中获得最佳可靠性和性能,可以通过一下几个方面进行优化。

  • 连接池
  • 客户端缓存
  • 超时
  • 健康检查
  • 异常处理
  • DNS缓存和Redis

连接池

示例代码通常会在开始时打开一个连接,演示某个功能,然后在结束时关闭该连接。然而,生产代码通常会间歇性地多次使用连接。反复打开和关闭连接会带来性能开销。使用连接池 可以避免打开和关闭连接的开销,而无需编写代码来缓存和重用打开的连接。请参阅 使用连接池进行连接 ,了解如何将此技术与 Jedis 结合使用。

客户端缓存

客户端缓存 是指将只读命令的结果存储在本地缓存中。如果稍后再次执行相同的命令,则可以从缓存中获取结果,而无需访问服务器。这可以缩短客户端上的命令执行时间,同时减少网络流量和服务器负载。 有关更多信息和示例代码,请参阅使用客户端缓存进行连接。

超时

如果在代码打开连接或发出命令时发生网络或服务器错误,代码可能会无限期挂起。您可以通过设置套接字读写和打开连接的超时时间来防止这种情况发生。要设置连接超时,请使用带有参数的JedisPooled或构造函数,或者使用带有和参数的构造函数。(套接字超时是执行命令时允许读取或写入数据的最长时间。连接超时是允许建立新连接的最长时间。)
JedisPooltimeoutJedisClientConfigsocketTimeoutconnectionTimeout

HostAndPort hostAndPort = new HostAndPort("localhost", 6379);

JedisPooled jedisWithTimeout = new JedisPooled(hostAndPort,
    DefaultJedisClientConfig.builder()
        .socketTimeoutMillis(5000)  // set timeout to 5 seconds
        .connectionTimeoutMillis(5000) // set connection timeout to 5 seconds
        .build(),
    poolConfig
);

健康检查

如果你的代码不需要持续访问 Redis 服务器,那么定期进行“健康检查”可能会很有用(比如每隔几秒一次)。你可以使用一个简单的 PING命令来执行此操作:

try (Jedis jedis = jedisPool.getResource()) {
  if (! "PONG".equals(jedis.ping())) {
    // Report problem.
  }
}

健康检查有助于尽快发现问题,而无需等待用户报告。

异常处理

Redis 使用命令的返回值来处理许多错误,但也存在抛出异常的情况。在生产代码中,您应该在发生异常时进行处理。Jedis 异常层次结构以 为根JedisException,并实现了 RuntimeException。因此,层次结构中的所有异常均为未检查异常。

JedisException
├── JedisDataException
│   ├── JedisRedirectionException
│   │   ├── JedisMovedDataException
│   │   └── JedisAskDataException
│   ├── AbortedTransactionException
│   ├── JedisAccessControlException
│   └── JedisNoScriptException
├── JedisClusterException
│   ├── JedisClusterOperationException
│   ├── JedisConnectionException
│   └── JedisValidationException
└── InvalidURIException

异常说明

一般来说,Jedis 在执行命令时可能会抛出以下异常:

  • JedisConnectionException- 当与 Redis 的连接意外丢失或关闭时。配置故障转移,使用 Resilience4J 和内置的 Jedis 故障转移机制自动处理此异常。
  • JedisAccessControlException- 当用户没有执行命令的权限或用户 ID 和/或密码不正确时。
  • JedisDataException- 当 Redis 服务器发送或接收数据时出现问题。通常,错误消息会包含有关失败命令的更多信息。
  • JedisException- 此异常是一个捕获所有异常,可能因任何其他意外错误而引发。

可以抛出的条件JedisException

  • PING使用命令进行健康检查时返回错误
  • 关机期间发生故障
  • 发出命令时发布/订阅失败(断开连接)
  • 任何未知的服务器消息
  • Sentinel:可以连接sentinel但是master没有被监控或者所有Sentinel都down了。
  • MULTI 或 DISCARD 命令失败
  • 分片命令键哈希校验失败或无可访问分片
  • 重试截止时间已超出/尝试次数(重试命令执行器)
  • POOL - 池已耗尽,添加空闲对象时出错,将损坏的资源返回到池中

所有 Jedis 异常都是运行时异常,并且在大多数情况下无法恢复,因此通常会冒泡到捕获错误消息的 API。

DNS缓存和Redis

当您连接到具有多个终端节点的 Redis 服务器(例如Redis Enterprise Active-Active )时,必须 禁用 JVM 的 DNS 缓存。如果服务器节点或代理发生故障,则受故障影响的任何数据库的 IP 地址都将更改。发生这种情况时,如果启用了 DNS 缓存,您的应用将继续尝试使用过时的 IP 地址。

使用以下代码禁用DNS缓存:

java.security.Security.setProperty("networkaddress.cache.ttl","0");
java.security.Security.setProperty("networkaddress.cache.negative.ttl", "0");

声明:文章内容来源官方文档。

控制面板
您好,欢迎到访网站!
  查看权限
网站分类
最新留言