首页教程行业资讯正文

Jedis与JedisCluster的使用方法详解

uncle 行业资讯 2025年08月6日

0 收藏 0 点赞 393 浏览 3939 个字

摘要 :

文章目录一、环境准备（一）添加依赖（二）启动Redis服务二、使用Jedis操作单机版Redis （一）创建连接（二）数据操作三、使用JedisCluster操作集群版Redis ……

文
章
目
录

一、环境准备

（一）添加依赖
（二）启动Redis服务

二、使用Jedis操作单机版Redis

（一）创建连接
（二）数据操作

三、使用JedisCluster操作集群版Redis

（一）创建集群连接
（二）数据操作

四、注意事项

（一）异常处理
（二）资源管理
（三）配置优化

Redis作为一款开源的键值对数据库，凭借其对多种数据结构（如字符串、哈希、列表、集合以及有序集合）的支持，以及高性能的特点，被广泛应用于缓存、消息队列等诸多场景。而在Java项目里操作Redis时，Jedis和JedisCluster这两个客户端库是开发者们的常用工具，它们分别用于单机版和集群版Redis的操作。接下来，本文将详细为大家介绍这两者的使用方法。

一、环境准备

（一）添加依赖

不管是使用Jedis还是JedisCluster，首先都要在项目中添加相应的依赖。如果使用Maven构建项目，就在pom.xml文件中添加如下依赖：

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

若使用Gradle，在build.gradle文件里添加：

dependencies {
    implementation \'redis.clients:jedis:4.0.1\'
}

添加这个依赖后，项目就能引入Jedis库，从而使用其中的功能来操作Redis。

（二）启动Redis服务

完成依赖添加后，要确保你的开发环境中已经安装并启动了Redis服务。要是使用的是集群模式，那就需要按照官方文档的指引，配置多个Redis实例并搭建好集群环境。只有Redis服务正常运行，后续的操作才能顺利进行。

二、使用Jedis操作单机版Redis

（一）创建连接

想要操作单机版Redis，首先得创建与Redis服务器的连接。通过创建Jedis对象来实现连接，示例代码如下：

import redis.clients.jedis.Jedis;

public class JedisExample {
    public static void main(String[] args) {
        // 创建Jedis实例，连接到本地运行在6379端口的Redis服务
        Jedis jedis = new Jedis(\"localhost\", 6379);
        System.out.println(\"连接成功\");
        // 通过ping命令查看Redis服务是否正常运行，正常运行会返回\"PONG\"
        System.out.println(\"服务正在运行: \" + jedis.ping());
    }
}

在这段代码里，Jedis(\"localhost\", 6379)表示连接到本地地址localhost、端口号为6379的Redis服务器。jedis.ping()用于测试与Redis服务器的连接状态，若连接正常，会返回PONG。

（二）数据操作

成功连接到Redis后，就可以进行数据操作了。下面的代码展示了如何使用Jedis进行基本的数据操作，比如设置键值对和获取键值：

import redis.clients.jedis.Jedis;

public class JedisDataOperation {
    public static void main(String[] args) {
        Jedis jedis = new Jedis(\"localhost\", 6379);
        System.out.println(\"连接成功\");

        // 使用set方法设置键为\"key1\"，值为\"Hello World\"的键值对
        jedis.set(\"key1\", \"Hello World\");
        // 使用get方法获取键\"key1\"对应的值
        String value = jedis.get(\"key1\");
        System.out.println(\"key1: \" + value);

        // 操作完成后，关闭Jedis连接，释放资源
        jedis.close();
    }
}

在上述代码中，jedis.set(\"key1\", \"Hello World\")用于将键key1和值Hello World存储到Redis中，jedis.get(\"key1\")则是从Redis中获取键key1对应的值，并将其打印输出。最后，调用jedis.close()关闭与Redis的连接，避免资源浪费。

三、使用JedisCluster操作集群版Redis

（一）创建集群连接

操作集群版Redis时，需要创建JedisCluster对象来连接Redis集群。下面是具体的示例代码：

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

import java.util.HashSet;
import java.util.Set;

public class JedisClusterExample {
    public static void main(String[] args) {
        // 创建一个Set集合，用于存储集群中的节点
        Set<HostAndPort> nodes = new HashSet<>();
        // 添加集群中的节点，这里示例添加了三个节点
        nodes.add(new HostAndPort(\"127.0.0.1\", 7000));
        nodes.add(new HostAndPort(\"127.0.0.1\", 7001));
        nodes.add(new HostAndPort(\"127.0.0.1\", 7002));

        // 使用包含集群节点的Set集合创建JedisCluster实例
        JedisCluster jedisCluster = new JedisCluster(nodes);
        System.out.println(\"连接成功\");

        // 通过ping命令测试与Redis集群的连接状态
        System.out.println(\"服务正在运行: \" + jedisCluster.ping());
    }
}

在这段代码中，先创建一个HashSet集合nodes，并向其中添加Redis集群的节点信息（包括IP地址和端口号）。然后，使用这个nodes集合创建JedisCluster实例，从而实现与Redis集群的连接。同样，通过jedisCluster.ping()来测试连接是否成功。

（二）数据操作

JedisCluster的数据操作与单机版Jedis类似，下面的代码展示了如何在集群环境中进行设置和获取键值的操作：

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

import java.util.HashSet;
import java.util.Set;

public class JedisClusterDataOperation {
    public static void main(String[] args) {
        Set<HostAndPort> nodes = new HashSet<>();
        nodes.add(new HostAndPort(\"127.0.0.1\", 7000));
        nodes.add(new HostAndPort(\"127.0.0.1\", 7001));
        nodes.add(new HostAndPort(\"127.0.0.1\", 7002));

        JedisCluster jedisCluster = new JedisCluster(nodes);
        System.out.println(\"连接成功\");

        // 在集群中设置键为\"key2\"，值为\"Hello Cluster\"的键值对
        jedisCluster.set(\"key2\", \"Hello Cluster\");
        // 从集群中获取键\"key2\"对应的值
        String value = jedisCluster.get(\"key2\");
        System.out.println(\"key2: \" + value);

        // 操作完成后，关闭JedisCluster连接，释放资源
        jedisCluster.close();
    }
}

在上述代码里，jedisCluster.set(\"key2\", \"Hello Cluster\")将键值对存储到Redis集群中，jedisCluster.get(\"key2\")用于从集群中获取相应的值并打印。最后，别忘了调用jedisCluster.close()关闭连接。