Jedis 客户端
Jedis 基于 Java 实现，是 shell 程序连接 Redis 数据库最常使用的工具。提供了比较全面的 Redis 命令的支持。
- Jedis 使用阻塞 I/O，且其方法调用都是同步的，程序流需要等到 sockets 处理完 I/O 才能执行。
- Jedis 采取直连模式，在多个线程间共享一个 Jedis 实例线程不安全，多线程操作 Redis 必须要使用多个 Jedis 实例。
- 导入依赖
Spring Boot 2.x 版本 Redis 默认导入了 lettuce，需要排除才能使用 Redis .
<!-- Redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <exclusions> <exclusion> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> </exclusion> </exclusions> </dependency> <!-- Jedis --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency>Copy to clipboardErrorCopied 复制代码
- 基本使用
使用引入的 Jedis 类即可连接 Redis 数据库并进行操作。操作名取自 Redis 指令，如果出现问题则会抛出 JedisDataException。
import redis.clients.jedis.Jedis; public class JedisTest{ @Test public void jedisTest (){ // 连接 Redis Jedis jedis = new Jedis("127.0.0.1", 6379); // 对 Redis 操作（直接使用 Redis 指令） try { jedis.set("name", "MrJoker"); System.out.print(jedis.get("name")); } catch(JedisDataException e) { System.out.print("error"); } finally { // 关闭 Redis 连接 jedis.close(); } } }Copy to clipboardErrorCopied 复制代码
在实际开发中，创建多个 Redis 连接会非常复杂且难以管理，Jedis 提供了 JedisPool 类作为 Redis 连接池来管理 Redis 连接。
import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; public class JedisTest{ @Test public void jedisTest (){ // 配置连接池 JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxIdle(50); // 最大空闲数 poolConfig.setMaxTotal(100); // 最大连接数 poolConfig.setMaxWaitMillis(20000); // 最大等待毫秒数 // 创建连接池 JedisPool pool = new JedisPool(poolConfig, "localhost"); // 从连接池中获取单个连接 Jedis jedis = pool.getResource(); // 如果需要密码 //jedis.auth("password"); } }Copy to clipboardErrorCopied 复制代码
- Spring Boot 集成
Spring Boot 中，我们无需自行创建 Redis 连接，只需要在配置文件中配置好参数。
# REDIS配置 # Redis数据库索引（默认为0） spring.redis.database=0 # Redis服务器地址 spring.redis.host=localhost # Redis服务器连接端口 spring.redis.port=6379 # Redis服务器连接密码（默认为空） spring.redis.password= # 连接池最大连接数（使用负值表示没有限制） spring.redis.pool.max-active=8 # 连接池最大阻塞等待时间（使用负值表示没有限制） spring.redis.pool.max-wait=-1 # 连接池中的最大空闲连接 spring.redis.pool.max-idle=8 # 连接池中的最小空闲连接 spring.redis.pool.min-idle=0 # 连接超时时间（毫秒） spring.redis.timeout=0Copy to clipboardErrorCopied 复制代码
Spring Boot 提供默认的 RedisTemplate 工具类根据配置文件自动连接 Redis，自动加载后可以直接调用其中的方法去操作。
@RunWith(SpringJUnit4ClassRunner.class) @SpringBootTest() public class ApplicationTests { @Autowired private RedisTemplate redisTemplate; @Test public void test() throws Exception { User user = new User(); user.setName("我没有三颗心脏"); user.setAge(21); // 调用工具类方法 redisTemplate.opsForValue().set("user_1", user); User user1 = (User) redisTemplate.opsForValue().get("user_1"); System.out.println(user1.getName()); } }Copy to clipboardErrorCopied 复制代码
RedisTemplate 类常用操作
redisTemplate.delete(key); // 删除 key redisTemplate.delete(keys); // 批量删除 key redisTemplate.expire(key,time,TimeUnit.MINUTES); // 设置 key 失效时间 Long expire = redisTemplate.getExpire(key); // 获取 key 失效时间Copy to clipboardErrorCopied 复制代码
Lettuce 客户端
更加高级的 Redis 客户端，用于线程安全同步，异步和响应使用，支持集群，Sentinel，管道和编码器。
- 基于 Netty 框架的事件驱动的通信层，其方法调用是异步的。不用浪费线程等待网络或磁盘 I/O。
- Lettuce 的 API 是线程安全的，所以可以操作单个 Lettuce 连接来完成各种操作。
- 导入依赖
在 spring boot 2.x 版本，为 Redis 默认导入了 Lettuce 。
<!-- Redis 默认导入 Lettuce --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>Copy to clipboardErrorCopied 复制代码
如果 Spring Boot 版本过低，也可以自行导入 Lettuce. Redis 版本至少需要 2.6 .
<!-- 单独导入 Lettuce --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>io.lettuce</groupId> <artifactId>lettuce-core</artifactId> <version>5.1.8.RELEASE</version> </dependency>Copy to clipboardErrorCopied 复制代码
- 基本使用
public class LettuceTest { @Test public void testSetGet() throws Exception { // 注册连接信息 RedisURI redisUri = RedisURI.builder() .withHost("localhost") .withPort(6379) .withTimeout(Duration.of(10, ChronoUnit.SECONDS)) .build(); // 创建 Redis 客户端 RedisClient redisClient = RedisClient.create(redisUri); // 创建连接 StatefulRedisConnection<String, String> connection = redisClient.connect(); // 创建同步命令 RedisCommands<String, String> redisCommands = connection.sync(); SetArgs setArgs = SetArgs.Builder.nx().ex(5); String result = redisCommands.set("name", "throwable", setArgs); Assertions.assertThat(result).isEqualToIgnoringCase("OK"); result = redisCommands.get("name"); Assertions.assertThat(result).isEqualTo("throwable"); /******************** 其他操作 **********************/ connection.close(); // 关闭连接 redisClient.shutdown(); // 关闭客户端 } }Copy to clipboardErrorCopied 复制代码
Lettuce 主要提供三种API：同步（sync）RedisCommands、异步（async）RedisAsyncCommands、反应式（reactive）RedisReactiveCommands。
- Spring Boot 集成
同样在配置文件中配置好参数。
spring.redis.host=localhost spring.redis.port=6379 spring.redis.password=root # 连接池最大连接数(使用负值表示没有限制) 默认为8 spring.redis.lettuce.pool.max-active=8 # 连接池最大阻塞等待时间(使用负值表示没有限制) 默认为-1 spring.redis.lettuce.pool.max-wait=-1ms # 连接池中的最大空闲连接 默认为8 spring.redis.lettuce.pool.max-idle=8 # 连接池中的最小空闲连接 默认为 0 spring.redis.lettuce.pool.min-idle=0Copy to clipboardErrorCopied 复制代码
我们同样可以使用 Spring Boot 提供默认的 RedisTemplate 工具类根据配置文件自动连接 Redis。但默认情况下的模板只支持 RedisTemplate<String,String> 存入字符串，因此我们往往需要自定义 RedisTemplate 设置序列化器，以方便操作实例对象。
@Configuration public class RedisConfig { @Bean public RedisTemplate redisTemplate(RedisConnectionFactory factory) { RedisTemplate<String, Serializable> redisTemplate = new RedisTemplate<>(); // key 采用 String 的序列化方式 redisTemplate.setKeySerializer(new StringRedisSerializer()); // value 采用 jackson 的序列化方式 redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // hash 采用 String/jackson 的序列化方式 redisTemplate.setHashKeySerializer(stringRedisSerializer); redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer); redisTemplate.setConnectionFactory(connectionFactory); return redisTemplate; } }Copy to clipboardErrorCopied 复制代码
完成后即可用自定义的 RedisTemplate 工具类对 Redis 进行操作。
@RunWith(SpringRunner.class) @SpringBootTest public class RedisTest { @Autowired private RedisTemplate<String, Serializable> redisTemplate; @Test public void test() { String key = "user:1"; redisTemplate.opsForValue().set(key, new User(1,"pjmike",20)); User user = (User) redisTemplate.opsForValue().get(key); } }
作者：武师叔
链接：https://juejin.cn/post/7132418128625008647
来源：稀土掘金
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。
