Redis 客户端 Jedis 的使用教程-JavaScript中文网-JavaScript教程资源分享门户

Redis 是一款开源的 key-value 存储系统，被广泛地应用于缓存、消息队列、排行榜等领域，在前端应用中也有着重要的作用。而 Jedis 是 Redis 的一个 Java 客户端，提供了丰富的 API 来操作 Redis 数据库。本篇文章将详细介绍 Jedis 的使用，包括连接 Redis 服务器、操作数据、使用管道、发布订阅等技巧，以及 Jedis 在前端应用中的实际应用。

安装 Jedis

使用 Jedis 首先需要下载 Jedis 的 jar 包并添加到项目中。可以从 Maven 或 GitHub 上获取 Jedis 的最新版本，或者在 gradle 文件中添加以下依赖：

dependencies {
    implementation 'redis.clients:jedis:3.7.0'
}

连接 Redis 服务器

在使用 Jedis 来操作 Redis 之前，首先需要建立和 Redis 服务器的连接。可以使用以下代码来创建 Jedis 实例并连接 Redis 服务器：

// www.javascriptcn.com code example
import redis.clients.jedis.Jedis;

public class RedisExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        System.out.println("Connected to Redis server successfully.");
        System.out.println("Server is running: " + jedis.ping());
        jedis.close();
    }
}

上述代码使用 Jedis 构造器传入 Redis 服务器的 IP 地址和端口号，然后调用 ping() 方法来检查连接是否成功建立。如果返回 PONG 则表示连接成功。最后需要在不使用 Jedis 实例时调用 close() 方法来关闭连接。

操作数据

连接成功后，就可以使用 Jedis 提供的 API 来操作 Redis 数据库了。下面将介绍常见的数据操作方法：

字符串

在 Redis 中，字符串是最基本的数据类型。可以使用如下代码来设置、获取和删除一个字符串类型的数据：

// www.javascriptcn.com code example
import redis.clients.jedis.Jedis;

public class RedisExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        String key = "name";
        String value = "Tom";
        jedis.set(key, value);
        System.out.println("Get " + key + " from Redis: " + jedis.get(key));
        jedis.del(key);
        System.out.println("Deleted " + key + " from Redis.");
        jedis.close();
    }
}

上述代码使用 set() 方法来设置一个键值对，然后使用 get() 方法来获取该键对应的值，最后使用 del() 方法来删除该键。可以重复设置同一个键，后一次设置会覆盖前一次设置的值。

列表

列表是一种有序的数据集合类型，可以使用如下代码来添加、获取和删除一个列表类型的数据：

// www.javascriptcn.com code example
import redis.clients.jedis.Jedis;
import java.util.List;

public class RedisExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        String key = "list";
        jedis.del(key);
        jedis.lpush(key, "A");
        jedis.lpush(key, "B");
        jedis.lpush(key, "C");
        List<String> list = jedis.lrange(key, 0, -1);
        System.out.println("List " + key + " in Redis: " + list);
        String element = jedis.lpop(key);
        System.out.println("Pop element from " + key + ": " + element);
        jedis.del(key);
        System.out.println("Deleted " + key + " from Redis.");
        jedis.close();
    }
}

上述代码使用 lpush() 方法来在列表左端加入一个元素，使用 lrange() 方法来获取列表的所有元素（0 代表列表的起始下标，-1 代表列表的结束下标），使用 lpop() 方法来弹出列表左端的元素，最后使用 del() 方法来删除该列表。

散列

散列是一种键值对集合类型，其中每个键的值也是一种键值对集合类型。可以使用如下代码来添加、获取和删除一个散列类型的数据：

// www.javascriptcn.com code example
import redis.clients.jedis.Jedis;
import java.util.Map;

public class RedisExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        String key = "user";
        jedis.del(key);
        jedis.hset(key, "name", "Tom");
        jedis.hset(key, "age", "18");
        Map<String, String> map = jedis.hgetAll(key);
        System.out.println("Hash " + key + " in Redis: " + map);
        String name = jedis.hget(key, "name");
        System.out.println("Name of " + key + ": " + name);
        jedis.del(key);
        System.out.println("Deleted " + key + " from Redis.");
        jedis.close();
    }
}

上述代码使用 hset() 方法来设置一个散列中某个键的值，使用 hgetAll() 方法来获取整个散列中所有的键值对，使用 hget() 方法来获取散列中某个键的值，最后使用 del() 方法来删除该散列。

使用管道

Jedis 还提供了管道（pipeline）功能，可以用来批量执行 Redis 命令。与单个执行 Redis 命令不同，管道在客户端并不执行命令，而是将所有命令一次性打包发送给 Redis 服务器执行，从而提高了性能。

例如，如果要向 Redis 中批量添加 10000 个列表元素，可以这样使用管道：

// www.javascriptcn.com code example
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;

public class RedisExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        String key = "biglist";
        jedis.del(key);
        Pipeline pipeline = jedis.pipelined();
        for (int i = 0; i < 10000; i++) {
            pipeline.lpush(key, "value" + i);
        }
        pipeline.sync();
        jedis.close();
    }
}

上述代码使用 pipelined() 方法创建一个管道，然后通过 lpush() 方法向 Redis 中不断添加列表元素。最后调用 sync() 方法将管道中所有 Redis 命令一次性执行。

使用管道可以大大提高 Redis 操作效率，尤其是在需要批量操作数据时。需要注意的是，使用管道在某些情况下可能会出现数据丢失或不一致的问题，所以需要酌情使用。

发布订阅

Jedis 还支持 Redis 的发布订阅（pub/sub）功能，可以用来实现消息推送等场景。发布者可以向某个频道（channel）发布消息，订阅者可以订阅相应的频道并接收到发布者的消息。

例如，一个简单的聊天室应用可以这样实现：

// www.javascriptcn.com code example
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost");
        String channel = "chat";
        Thread publisher = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                try {
                    Thread.sleep(1000);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                jedis.publish(channel, "Hello " + i);
            }
        });
        Thread subscriber = new Thread(() -> {
            JedisPubSub pubSub = new JedisPubSub() {
                @Override
                public void onMessage(String channel, String message) {
                    System.out.println("Receive message from " + channel + ": " + message);
                }
            };
            jedis.subscribe(pubSub, channel);
        });
        publisher.start();
        subscriber.start();
        try {
            publisher.join();
            subscriber.join();
        } catch (Exception e) {
            e.printStackTrace();
        }
        jedis.close();
    }
}

上述代码首先使用 publish() 方法向频道发布消息，然后使用 subscribe() 方法订阅相应的频道。在终端上启动两个不同的 Jedis 实例分别运行发布者和订阅者，就可以在订阅者的窗口中看到发布者发送的消息了。

Jedis 实际应用

除了上述基本的数据操作和高级功能，Jedis 在前端应用中还有着广泛的应用场景，例如：

缓存数据：使用 Jedis 对查询结果、配置数据等进行缓存，可以提高应用的性能和并发支持；
消息队列：使用 Jedis 的队列类型，可以实现简单且高效的消息队列；
排行榜：使用 Jedis 的有序集合类型，可以对用户进行排名并实时更新。

总之，Jedis 是 Redis 非常重要的一部分，掌握 Jedis 可以使前端应用对 Redis 的应用更加深入和灵活。

来源：JavaScript中文网，转载请注明来源 https://www.javascriptcn.com/post/67bc02b0a231b2b7edd4eac6

Redis 客户端 Jedis 的使用教程