【入门篇】1.4 redis 客户端 之 Lettuce 详解

文章目录

  • 1. 简介
    • 1. 什么是Lettuce
    • 2. Lettuce与其他Redis客户端的比较
    • 3. Lettuce的特性和优势
  • 2. 安装和配置
  • 3. 连接池配置
    • 1. 什么是连接池
    • 2. Lettuce的连接池使用与配置
    • 3. 连接池配置项
  • 4. 基本操作
    • 1. 如何创建Lettuce连接
    • 2. Lettuce的基本操作如增删改查
    • 3. Lettuce的事务操作
    • 4. Lettuce的管道操作
    • 5. Lettuce的发布订阅操作
    • 6. Lettuce的脚本执行
  • 5. 错误处理和重试
  • 6. Lettuce vs Jedis
  • 7. 参考资料

在这里插入图片描述

1. 简介

1. 什么是Lettuce

Lettuce是一个高级Redis客户端，用于线程安全的同步、异步和反应式访问。它支持高级的Redis特性，如Sentinel、集群、流水线、自动重新连接和redis数据模型等。Lettuce是完全非阻塞的，基于Netty事件驱动的通信层，其方法将返回具有可观察的类型，可在流或异步编程环境中使用。

2. Lettuce与其他Redis客户端的比较

与Jedis这种阻塞的Java Redis客户端相比，Lettuce的主要优势在于其完全非阻塞的IO和线程安全。使用Jedis，在多线程环境中，需要使用连接池以避免线程安全问题，但是对于Lettuce来说，可以避免这种复杂的设置，因为一个Lettuce连接实例（StatefulRedisConnection）就是线程安全的。另一个重要的区别是，Lettuce支持Redis的高级特性，如集群、流水线、发布订阅、和Lua脚本。

3. Lettuce的特性和优势

  • 完全非阻塞IO和线程安全：Lettuce使用Netty进行网络通信，采用了异步和事件驱动的模型。一个Lettuce连接实例（StatefulRedisConnection）是线程安全的，可以在多个线程间共享。
  • 支持Redis的高级特性：Lettuce支持Redis的高级特性，如Sentinel、集群、流水线、发布订阅、Lua脚本等。
  • 自动重连：Lettuce支持自动重连，当Redis服务器重新启动或断开连接时，Lettuce可以自动恢复连接。
  • 可观察的数据类型：Lettuce的所有操作都返回Observable，这可以让在流或异步编程环境中使用。

2. 安装和配置

在Java项目中，可以使用Maven或者Gradle来引入Lettuce的依赖。

  1. 使用Maven引入依赖
<dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId><version>6.1.5.RELEASE</version> <!-- 请将此版本号替换为所需要的版本 -->
</dependency>
  1. 使用Gradle引入依赖
dependencies {implementation 'io.lettuce:lettuce-core:6.1.5.RELEASE'  
}

配置Lettuce非常简单
创建一个新的RedisClient实例，使用redis://password@localhost:6379/0作为Redis服务器的URL。然后我们打开一个新的连接，并通过此连接获取同步命令来执行Redis命令。执行完命令后，我们关闭了连接并关闭了Redis客户端。

import io.lettuce.core.RedisClient;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.sync.RedisCommands;public class Example {public static void main(String[] args) {// 初始化Redis客户端RedisClient redisClient = RedisClient.create("redis://password@localhost:6379/0");// 打开一个新的连接StatefulRedisConnection<String, String> connection = redisClient.connect();// 获取同步命令RedisCommands<String, String> syncCommands = connection.sync();// 执行命令syncCommands.set("key", "Hello, Redis!");// 关闭连接connection.close();// 关闭Redis客户端redisClient.shutdown();}
}

3. 连接池配置

1. 什么是连接池

连接池是一个预先创建并存储数据库连接的容器，应用程序在需要与数据库交互时，可以从连接池中获取已经建立的连接。使用完毕后，将该连接归还给连接池，而不是关闭它。这种技术可以避免每次需要与数据库交互时都打开新的连接，节省了创建新连接所需的时间。

Lettuce是一个基于Netty的高级Redis客户端，用于线程安全同步、异步和响应式通信。在Lettuce中，每次发送命令都会获取新的连接，执行完命令后就会关闭。这就是说，Lettuce本身并没有传统意义上的"连接池"。

2. Lettuce的连接池使用与配置

虽然在Lettuce本身并未实现连接池，但是在使用Spring Data Redis的情况下，可以通过配置LettuceConnectionFactory来实现连接池的效果。

以下是一个配置示例：

import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;// 创建连接池配置
LettuceClientConfiguration clientConfig = LettucePoolingClientConfiguration.builder().poolConfig(new GenericObjectPoolConfig()).build();// 创建服务器配置
RedisStandaloneConfiguration serverConfig = new RedisStandaloneConfiguration("localhost", 6379);// 使用这两种配置创建Lettuce连接工厂
LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(serverConfig, clientConfig);

在这个配置中，我们使用LettucePoolingClientConfiguration.builder()来创建一个LettuceClientConfiguration的Builder，并使用poolConfig()方法来设置连接池配置。然后，我们使用这个配置和服务器配置来创建一个新的LettuceConnectionFactory。

注意，GenericObjectPoolConfig可以让设置一些连接池的参数，例如maxTotal(最大连接数)，maxIdle(最多的空闲连接数)，minIdle(最少的空闲连接数)等等。

在Lettuce中，使用RedisClient或者RedisClusterClient创建的基本连接实际上是一个连接池。可以通过ClientOptions和ClientResources来定制连接池的行为。

默认连接池的行为如下：

  1. 默认情况下，连接池大小为8个连接。
  2. 连接尝试失败后，默认重试时间间隔为30秒。

在创建RedisClient或者RedisClusterClient之前，可以通过ClientResources.Builder来定制连接池的一些参数，如下所示：

import io.lettuce.core.RedisClient;
import io.lettuce.core.resource.ClientResources;
import io.lettuce.core.resource.DefaultClientResources;public class Example {public static void main(String[] args) {// 创建一个ClientResources来定制连接池参数ClientResources clientResources = DefaultClientResources.builder().ioThreadPoolSize(16) // IO线程池大小.computationThreadPoolSize(16) // 计算线程池大小.build();// 使用定制的ClientResources来创建RedisClientRedisClient redisClient = RedisClient.create(clientResources, "redis://localhost:6379");// 其他代码...}
}

对于更复杂的需求，如最大连接数、最小空闲连接数等，Lettuce本身并没有提供对应的配置项。Lettuce的设计理念是每个Redis命令都运行在一个独立的连接上，因此并没有传统意义上的“连接池”。可以根据自己的需求，通过控制并发命令的数量来间接控制连接数量。

然而，如果正在使用Spring Data Redis，那么在Spring Data Redis中，可以通过LettucePoolingClientConfiguration来配置连接池（包括最大连接数、最小空闲连接数等），如下所示：

import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;LettuceClientConfiguration clientConfig = LettucePoolingClientConfiguration.builder().poolConfig(new GenericObjectPoolConfig()).build();RedisStandaloneConfiguration serverConfig = new RedisStandaloneConfiguration("server", 6379);LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(serverConfig, clientConfig);

在上面的代码中，我们使用LettucePoolingClientConfiguration.builder()来创建一个LettuceClientConfiguration的Builder，并使用poolConfig()方法来设置连接池配置。然后，我们使用这个配置和服务器配置来创建一个新的LettuceConnectionFactory。

3. 连接池配置项

配置Lettuce的连接池可以通过LettuceConnectionFactory类来实现。下面是配置连接池的一些常用参数：

  1. 最大连接数（MaxConnections）：指定连接池的最大连接数，即同时能够从连接池中获取的最大连接数。可以使用setConnectionPoolConfiguration()方法来设置。
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMaxTotal(maxConnections);
lettuceConnectionFactory.setPoolConfig(poolConfig);
  1. 最小空闲连接数（MinIdleConnections）：指定连接池中的最小空闲连接数，即连接池中保持的最少可用连接数。可以使用setPoolConfig()方法来设置。
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMinIdle(minIdleConnections);
lettuceConnectionFactory.setPoolConfig(poolConfig);
  1. 连接空闲超时时间（IdleTimeout）：指定连接在空闲状态下的超时时间，超过该时间会被连接池回收。可以使用setTimeout()方法来设置。
lettuceConnectionFactory.setTimeout(idleTimeout);
  1. 连接重试次数（RetryAttempts）：指定在连接池无法获取到可用连接时的重试次数。可以使用setRetryAttempts()方法来设置。
lettuceConnectionFactory.setRetryAttempts(retryAttempts);
  1. 连接重试间隔时间（RetryInterval）：指定连接重试的间隔时间，即每次重试之间的等待时间。可以使用setRetryInterval()方法来设置。
lettuceConnectionFactory.setRetryInterval(retryInterval);

以上是一些常用的连接池参数的配置方法。根据实际需求，您可以根据需要设置这些参数来优化连接池的性能。

4. 基本操作

1. 如何创建Lettuce连接

你可以使用RedisClient或RedisClusterClient的connect()方法来建立一个连接。例如：

RedisClient redisClient = RedisClient.create("redis://localhost:6379");
StatefulRedisConnection<String, String> connection = redisClient.connect();

2. Lettuce的基本操作如增删改查

可以使用RedisCommands的对应方法进行操作。例如：

RedisCommands<String, String> syncCommands = connection.sync();
// 添加键值对
syncCommands.set("key", "value");
// 获取键值对
String value = syncCommands.get("key");
// 删除键值对
syncCommands.del("key");
// 修改键值对
syncCommands.set("key", "newValue");

3. Lettuce的事务操作

Lettuce支持事务操作，可以使用multi()和exec()方法进行事务的开始和提交：

RedisCommands<String, String> syncCommands = connection.sync();
// 开启事务
syncCommands.multi();
syncCommands.set("key1", "value1");
syncCommands.set("key2", "value2");
// 提交事务
syncCommands.exec();

4. Lettuce的管道操作

Lettuce支持管道操作，可以使用RedisCommands的autoFlushCommands()方法来关闭自动刷新，然后用flushCommands()方法来手动刷新：

RedisCommands<String, String> syncCommands = connection.sync();
syncCommands.setAutoFlushCommands(false);
syncCommands.set("key1", "value1");
syncCommands.set("key2", "value2");
syncCommands.flushCommands();

5. Lettuce的发布订阅操作

Lettuce支持Redis的发布订阅模式，例如：

RedisCommands<String, String> syncCommands = connection.sync();
// 订阅频道
RedisPubSubCommands<String, String> pubSubCommands = connection.sync();
pubSubCommands.subscribe("channel");
// 发布消息
syncCommands.publish("channel", "message");

6. Lettuce的脚本执行

Lettuce支持Lua脚本，可以使用RedisScriptingCommands的eval()或evalsha()方法来执行脚本：

RedisScriptingCommands<String, String> scriptingCommands = connection.sync();
// 执行Lua脚本
String result = scriptingCommands.eval("return redis.call('get', KEYS[1])", ScriptOutputType.VALUE, new String[]{"key"});

注意：以上代码示例假设你已经有了一个有效的StatefulRedisConnection<String, String>对象。

5. 错误处理和重试

Lettuce的错误处理机制和重试策略，如何处理连接错误和命令执行失败等情况。

import io.lettuce.core.RedisClient;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.RedisCommandExecutionException;
import io.lettuce.core.RedisConnectionException;
import io.lettuce.core.RedisCommandInterruptedException;
import io.lettuce.core.RedisCommandTimeoutException;public class RedisExample {public static void main(String[] args) {RedisClient redisClient = RedisClient.create("redis://localhost:6379/");try {StatefulRedisConnection<String, String> connection = redisClient.connect();try {String result = connection.sync().get("key");System.out.println(result);} catch (RedisCommandExecutionException e) {System.err.println("Command execution failed: " + e.getMessage());} catch (RedisCommandInterruptedException e) {System.err.println("Command interrupted: " + e.getMessage());} catch (RedisCommandTimeoutException e) {System.err.println("Command timed out: " + e.getMessage());} finally {connection.close();}} catch (RedisConnectionException e) {System.err.println("Failed to connect to Redis: " + e.getMessage());} finally {redisClient.shutdown();}}
}

1. Lettuce的常见异常

  1. RedisConnectionException：当无法连接到Redis服务器时，或在尝试发送命令时连接已关闭或断开，将抛出此异常。

  2. RedisCommandTimeoutException：当命令的执行超过设定的超时时间时，将抛出此异常。

  3. RedisCommandInterruptedException：当等待命令完成的过程中线程被中断，将抛出此异常。

  4. RedisCommandExecutionException：当Redis命令执行失败时（如键不存在，类型不匹配等），将抛出此异常。

2. 如何处理这些异常

  1. RedisConnectionException：检查你的Redis服务器是否正在运行，网络连接是否畅通。如果是因为连接已关闭或断开，可以尝试重新连接。

  2. RedisCommandTimeoutException：可以尝试增加命令的超时时间，或者查看Redis服务器是否有性能问题，如CPU使用过高，磁盘IO过高等。

  3. RedisCommandInterruptedException：可以查看线程为何被中断，并尝试解决中断的原因。

  4. RedisCommandExecutionException：检查你的Redis命令是否正确，如键是否存在，类型是否匹配等。如果命令没有问题，则可能是Redis服务器的问题，需要检查服务器的状况。

6. Lettuce vs Jedis

维度/库LettuceJedis
单线程/多线程Lettuce是基于Netty的连接实例（StatefulRedisConnection），可以在多个线程间并发访问，应该被用作长期存在的线程安全对象。Jedis实例不是线程安全的，因此在多线程环境下，你需要每个线程创建一个新的连接实例，或者使用连接池。
阻塞/非阻塞Lettuce支持异步、反应式、同步和非阻塞操作。Jedis操作是同步阻塞的，不支持异步和非阻塞操作。
集群支持Lettuce提供了Redis Cluster的原生支持。Jedis也支持Redis Cluster，但需要手动处理重定向。
PUB/SUB模型Lettuce支持发布-订阅模型。Jedis也支持发布-订阅模型。
二进制协议Lettuce直接使用Netty来处理命令和结果，可以处理任何Redis协议和命令。Jedis使用自己的协议处理器，对协议的支持可能不太完整。
项目活跃度Lettuce是目前最活跃的Redis Java客户端项目，一直在持续更新和添加新特性。Jedis的活跃度较低，更新和新功能的添加较慢。
连接池Lettuce的连接实例是线程安全的，大多数情况下，你不需要使用连接池。不过，Lettuce也提供了一个可选的内置连接池。在多线程环境下，你需要使用Jedis的连接池来管理和复用连接。
依赖Lettuce依赖于Netty。Jedis没有外部依赖。
事务Lettuce支持Redis的事务。Jedis也支持Redis的事务。
SentinelLettuce提供了对Redis Sentinel的原生支持。Jedis也支持Redis Sentinel。

7. 参考资料

Lettuce

  1. 官方文档：Lettuce
  2. GitHub：Lettuce GitHub
  3. 深入了解Lettuce：Understanding Lettuce
  4. Lettuce源码分析：Lettuce source code analysis

Jedis

  1. 官方文档：Jedis
  2. GitHub：Jedis GitHub
  3. 深入了解Jedis：Understanding Jedis
  4. Jedis源码分析：Jedis source code analysis

Redis

  1. 官方文档：Redis
  2. GitHub：Redis GitHub
  3. Redis命令：Redis commands
  4. Redis入门教程：Redis tutorial

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/192273.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

JavaScript管理HTMLDOM元素（增删改查）

JavaScript管理HTMLDOM元素（增删改查）

本文主要讲解JavaScript如何通过管理HTML上的DOM元素&#xff0c;其中包括如何查询、创建、修改以及删除具体功能和源码讲解。 增加 首先我们准备一个HTML框架和简单CSS样式&#xff0c;我对其中元素作用和关系进行一个简单说明。 <!DOCTYPE html> <html><he…
阅读更多...
【Qt开发流程】之HelloWorld程序

【Qt开发流程】之HelloWorld程序

【Qt开发流程】之HelloWorld程序 目的编写程序新建项目文件说明及界面设计 程序运行及发布程序运行程序发布手动构建使用windeployqt进行构建 设置应用程序图标修改快捷键类型列表命令行编译程序命令行编译.ui文件自定义类项目模式及项目文件介绍项目模式项目文件 目的 从Hell…
阅读更多...
【LeetCode刷题日志】225.用队列实现栈

【LeetCode刷题日志】225.用队列实现栈

&#x1f388;个人主页&#xff1a;库库的里昂 &#x1f390;C/C领域新星创作者 &#x1f389;欢迎 &#x1f44d;点赞✍评论⭐收藏✨收录专栏&#xff1a;LeetCode 刷题日志&#x1f91d;希望作者的文章能对你有所帮助&#xff0c;有不足的地方请在评论区留言指正&#xff0c;…
阅读更多...
青少年CTF-WEB-Flag在哪里？

青少年CTF-WEB-Flag在哪里？

题目环境&#xff1a;F12查看源代码得到flag&#xff1a;qsnctf{1167716c-54f0-47da-baed-49e3b08dfaeb} 此题主要考察F12查看源代码的使用
阅读更多...
趣学python编程 (二、计算机硬件和用途介绍)

趣学python编程 (二、计算机硬件和用途介绍)

1944年&#xff0c;美籍匈牙利数学家 冯诺依曼 提出计算机基本结构和工作方式的设想&#xff0c;为计算机的诞生和发展提供了理论基础。时至今日&#xff0c;尽管计算机软硬件技术飞速发展&#xff0c;但计算机本身的体系结构并没有明显的突破&#xff0c;当今的计算机仍属于冯…
阅读更多...
Spring Framework 6.1 正式 GA

Spring Framework 6.1 正式 GA

Spring Framework 6.1在运行时方面针对 JDK 21 和 Jakarta EE 10 上提供了一级支持&#xff0c;同时保留了 JDK 17 和 Jakarta EE 9 基线。Spring 还通过精细的元数据推理跟踪 GraalVM for JDK 21 的演变&#xff0c;同时暂时保持与 GraalVM 22.3 的兼容性。 主要变化 支持 JD…
阅读更多...
PHP排序sort()、asort() 和 ksort() 的区别及用法

PHP排序sort()、asort() 和 ksort() 的区别及用法

&#x1f3c6;作者简介&#xff0c;黑夜开发者&#xff0c;CSDN领军人物&#xff0c;全栈领域优质创作者✌&#xff0c;CSDN博客专家&#xff0c;阿里云社区专家博主&#xff0c;2023年6月CSDN上海赛道top4。 &#x1f3c6;数年电商行业从业经验&#xff0c;历任核心研发工程师…
阅读更多...
十. Linux关机重启命令与Vim编辑的使用

十. Linux关机重启命令与Vim编辑的使用

关机重启命令 shutdown命令 其他关机命令 其他重启命令 系统运行级别 系统默认运行级别与查询 退出登录命令logout 文本编辑器Vim Vim简介 没有菜单,只有命令Vim工作模式 Vim常用命令 插入命令 定位命令 删除命令 复制和剪切命令 替换和取消命令 搜索和搜索替换命令 保存和退出…
阅读更多...
科研学习|科研软件——面板数据、截面数据、时间序列数据的区别是什么?

科研学习|科研软件——面板数据、截面数据、时间序列数据的区别是什么?

一、数据采集方式不同 面板数据是通过在多个时间点上对同一组体进行观测而获得的数据。面板数据可以是横向面板数据&#xff0c;即对同一时间点上不同个体的观测&#xff0c;也可以是纵向面板数据&#xff0c;即对同一个体在不同时间点上的观测。采集面板数据需要跟踪相同的个体…
阅读更多...
Vue3-自定义hook函数

Vue3-自定义hook函数

Vue3-自定义hook函数 功能&#xff1a;可以将组合式API封装成一个函数&#xff0c;用于解决代码复用的问题。注意&#xff1a;需要在src文件夹下创建一个文件夹hooks&#xff0c;在里面放js文件&#xff0c;命名随意&#xff0c;主要是将setup函数中的代码放入js文件中。 // s…
阅读更多...
计算机指令的流水线执行与流水线冒险

计算机指令的流水线执行与流水线冒险

目录 计算机指令流水线 流水线冒险 结构冒险 数据冒险 前推/旁路&#xff08;forwarding/bypassing&#xff09; 前推阻塞 控制冒险 BTB&#xff08;Branch Target Buffer&#xff09; 计算机指令流水线 流水线方式的洗衣房可以以并行的方式提高性能 计算机执行指…
阅读更多...
【实用技巧】更改ArduinoIDE默认库文件位置，解放C盘，将Arduino15中的库文件移动到其他磁盘

【实用技巧】更改ArduinoIDE默认库文件位置，解放C盘，将Arduino15中的库文件移动到其他磁盘

本文主要介绍更改Arduino IDE &#xff08;含2.0以上版本&#xff09;默认库文件位置的方法。 原创文章&#xff0c;转载请注明出处&#xff1a; 【实用技巧】解放系统盘&#xff0c;更改ArduinoIDE默认库文件位置&#xff0c;将Arduino15中的库文件移动到其他磁盘-CSDN博客文…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023