【Redis】使用Java操作Redis的客户端

文章目录

🍃前言
🌴项目的创建
🎋引入依赖
🌳配置端⼝转发
🌲更改 Redis 配置文件
🎄连接 Redis Server
⭕总结

🍃前言

我们使用 Java 操作 Redis 客户端时我们需要进行以下操作。

注意：Java 操作Redis 客户端有很多种，博主这里介绍一种最通用，最简单的

引入依赖
配置端口转发
更改 Redis 配置文件
连接 Redis

🌴项目的创建

这里我们创建一个Maven 项目，方便后续引入依赖

在这里插入图片描述

🎋引入依赖

Java操作 redis 的客⼾端有很多. 其中最知名的是 jedis

使用jedis 时，只需要把 jedis 的依赖拷⻉到刚刚创建的 pom.xml中即可

依赖如下：

<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.4.4</version>
</dependency>

注意：

不一定非要使用博主这一版，大家大可以去官网寻找自己想要的版本即可，一般来说最新版即可

官网地址如下：

https://mvnrepository.com/artifact/redis.clients/jedis

导入时，该依赖需要包裹在<dependencies> </dependencies> 标签内

在这里插入图片描述

导入后，记得重新下载一下

在这里插入图片描述

如果遇到 Maven 下载失败，可以参考博主之前写的【JavaEE进阶】 Maven jar 包下载失败问题的解决方法

🌳配置端⼝转发

edis 服务器安装在云服务器上, ⽽我们编写的代码则是在本地主机.

要想让本地主机能访问 redis, 需要把 redis 的端⼝（默认：6379）通过云服务器后台⻚⾯的 “防⽕墙” / "安全组"放开端⼝到公⽹上.

但是这个操作⾮常危险(⿊客会顺着redis 端⼝进来)。因此我们可以使⽤端⼝转发的⽅式, 直接把服务器的 redis 端⼝映射到本

博主使用的时 xshell 操作 linux 服务器，如果这部分还不会的小伙伴可以参考博主写的【JavaEE进阶】使用云服务器实现Linux环境搭建

在 xshell 中, 进⾏如下配置:

右键云服务器的会话, 选择属性.
找到隧道 -> 配置转移规则

在这里插入图片描述

此处需要注意的是：

如果你之前已经连接上服务器，然后再进行配置，这时你需要重新断开进行连接

此时访问本地的 8888,就相当于访问对应服务器的 6379

这里我们也可以通过本地 cmd 输入以下命令查看我们所配置端口是否被使用来判断配置是否成功

在这里插入图片描述

🌲更改 Redis 配置文件

我们想要通过该端口正确访问 Redis 时，我们还需要对 Redis 配置文件进行如下配置

首先我们使用vim命令进入，打开相应的配置文件，命令如下

vim /etc/redis/redis.conf

然后点击 i 进入插入模式进行修改，需要修改的点如下：

修改 bind 127.0.0.1 为 bind 0.0.0.0
修改 protected-mode yes 为 protected-mode no

在这里插入图片描述

最后按 Esc 键，并输入 :wq,按下enter键返回即可

🎄连接 Redis Server

使⽤ JedisPool 描述 Redis 服务器的位置，使⽤ url 来表⽰.
使⽤ getResource 和服务器建⽴连接.
连接使⽤完毕需要 close 关闭，也可以直接使⽤ try ⾃动关闭
通过 ping ⽅法可以检测连接是否正确建⽴

实验代码如下：

JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
try (Jedis jedis = jedisPool.getResource()) {
    String ping = jedis.ping();
    System.out.println(ping);
}

注意：

此处的端口号对应的时你刚刚配置端口转发时所配置的本地端口号
确保你的 xshell 连接上你的服务器

如果你得到如下结果，恭喜你，你已经成功连接

在这里插入图片描述

我们来看一下简单的 get/set 命令的实现，代码实现如下：

public class RedisMain {
    public static void main(String[] args) {
        JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
        try (Jedis jedis = jedisPool.getResource()) {
            getAndSet(jedis);
        }
    }
    public static void getAndSet(Jedis jedis) {
        System.out.println("测试get和set");
        // 先刷新 Redis 库
        jedis.flushAll();
        // 添加key = "key"，value = "value"
        jedis.set("key","value");
        // 获取当前 key 所对应value
        String value = jedis.get("key");
        System.out.println("value：" + value);
    }
}