Java 连接 Redis 的两种方式

今天带来一期：Java通过两种方式连接Redis，如果大家对于除本内容外的疑问无法解答，可以私信找我，我来帮大家解决。

前言

Redis 是一种高性能的键值存储数据库，广泛应用于缓存、消息队列、会话存储等场景。Java 作为一门广泛使用的编程语言，提供了多种方式来连接和操作 Redis。本文将介绍两种常用的 Java 连接 Redis 的方式：Jedis 和 Lettuce，并详细说明它们的使用方法。

一、Jedis

Jedis 是一个轻量级的 Java Redis 客户端，提供了简单易用的 API 来操作 Redis。它适合大多数 Redis 操作场景，并且易于上手。

1. 添加依赖

首先，在项目中添加 Jedis 的依赖。以 Maven 项目为例，在 pom.xml 文件中添加以下依赖：

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>4.2.3</version>
</dependency>

2. 连接 Redis

使用 Jedis 连接 Redis 非常简单，只需要创建一个 Jedis 对象，并指定 Redis 服务器的地址和端口即可：

java">import redis.clients.jedis.Jedis;public class JedisExample {public static void main(String[] args) {// 创建 Jedis 对象，连接本地 Redis 服务器，默认端口 6379Jedis jedis = new Jedis("localhost", 6379);// 测试连接System.out.println("连接成功");System.out.println("服务正在运行: " + jedis.ping());// 设置键值对jedis.set("name", "Redis with Jedis");// 获取值String value = jedis.get("name");System.out.println("获取的值: " + value);// 关闭连接jedis.close();}
}

3. 连接池

为了提高性能，可以使用 Jedis 连接池来管理 Redis 连接：

java">import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;public class JedisPoolExample {public static void main(String[] args) {// 配置连接池JedisPoolConfig poolConfig = new JedisPoolConfig();poolConfig.setMaxTotal(10); // 最大连接数poolConfig.setMaxIdle(5);   // 最大空闲连接数// 创建连接池JedisPool jedisPool = new JedisPool(poolConfig, "localhost", 6379);// 从连接池获取连接try (Jedis jedis = jedisPool.getResource()) {// 测试连接System.out.println("连接成功");System.out.println("服务正在运行: " + jedis.ping());// 设置键值对jedis.set("name", "Redis with Jedis Pool");// 获取值String value = jedis.get("name");System.out.println("获取的值: " + value);}// 关闭连接池jedisPool.close();}
}

二、Lettuce

Lettuce 是一个高性能的 Java Redis 客户端，基于 Netty 实现，支持异步和响应式编程模型。它适合高并发场景，并且提供了更丰富的功能。

1. 添加依赖

在项目中添加 Lettuce 的依赖。以 Maven 项目为例，在 pom.xml 文件中添加以下依赖：

<dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId><version>6.2.1.RELEASE</version>
</dependency>

2. 连接 Redis

使用 Lettuce 连接 Redis 也非常简单：

java">import io.lettuce.core.RedisClient;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.sync.RedisCommands;public class LettuceExample {public static void main(String[] args) {// 创建 RedisClientRedisClient redisClient = RedisClient.create("redis://localhost:6379");// 获取连接StatefulRedisConnection<String, String> connection = redisClient.connect();// 获取同步操作接口RedisCommands<String, String> syncCommands = connection.sync();// 测试连接System.out.println("连接成功");System.out.println("服务正在运行: " + syncCommands.ping());// 设置键值对syncCommands.set("name", "Redis with Lettuce");// 获取值String value = syncCommands.get("name");System.out.println("获取的值: " + value);// 关闭连接connection.close();redisClient.shutdown();}
}

3. 异步操作

Lettuce 支持异步操作，适合高并发场景：

java">import io.lettuce.core.RedisClient;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.async.RedisAsyncCommands;
import java.util.concurrent.CompletableFuture;public class LettuceAsyncExample {public static void main(String[] args) {// 创建 RedisClientRedisClient redisClient = RedisClient.create("redis://localhost:6379");// 获取连接StatefulRedisConnection<String, String> connection = redisClient.connect();// 获取异步操作接口RedisAsyncCommands<String, String> asyncCommands = connection.async();// 异步设置键值对CompletableFuture<String> future = asyncCommands.set("name", "Redis with Lettuce Async");// 异步获取值future.thenCompose(result -> asyncCommands.get("name")).thenAccept(value -> System.out.println("获取的值: " + value));// 关闭连接connection.close();redisClient.shutdown();}
}