Redis高手修炼之路Jedis——Jedis的基本使用

Posted 2023-03-30 陶然同学

• 💂 个人主页: 陶然同学
• 🤟 版权: 本文由【陶然同学】原创、在CSDN首发、需要转载请联系博主
• 💬 如果文章对你有帮助、欢迎关注、点赞、收藏(一键三连)和订阅专栏哦
• 💅 想寻找共同成长的小伙伴，请点击【Java全栈开发社区】

---

目录

1.Jedis的介绍

2.Jedis基本操作

        2.1Jedis对象常用API

        2.2Jedis的基本操作

3.Jedis连接池的使用

        3.1Jedis连接池的基本概念

        3.2Jedis连接池API

        3.3JedisPool的基本使用

4.案例：编写jedis连接池工具类

        4.1相应API的学习

        4.2连接池工具类的实现

---

1.Jedis的介绍

Jedis = Java + Redis

Redis不仅可以使用命令来操作，现在基本上主流的语言都有API支持，比如Java、C#、C++、php、Node.js、Go等。在官方网站里列一些Java的客户端，有Jedis、Redisson、Jredis、JDBC-Redis等其中官方推荐使用Jedis和Redisson。

使用Jedis操作redis需要导入jar包如下：

2.Jedis基本操作

        2.1Jedis对象常用API

注：每个方法就是redis中的命令名，方法的参数就是命令的参数

方法	功能
new Jedis(host, port)	创建Jedis的连接，参数：主机名，端口号6379
set(key,value)	添加一个字符串的键和值
get(key)	得到指定键的值
del(key)	删除指定键和值
hset(key,field,value)	添加一个hash类型的键-字段-值
hget(key,field)	通过hash键-字段得到它的值
lpush(key,values)	从左边添加一个list类型的键和元素
lpop(key)	从左边弹出一个元素
rpop(key)	从右边弹出一个元素
close()	关闭连接

        2.2Jedis的基本操作

操作步骤：

创建Jedis对象，指定服务器地址和端口号

向服务器写入

set字符串类型的数据，person=张三

lpush添加list类型的数据，cities=珠海，深圳，广州

从服务器中读取上面的数据打印输出

get得到字符串的值

lrange得到list所有的列表元素

关闭Jedis对象，释放资源

通过客户端查看数据库中是否有数据

控制台输出：

数据库中

 

代码：

package com.itheima.jedis;

import redis.clients.jedis.Jedis;

import java.util.List;

/**
 * 使用Jedis向redis中添加string和list，读取它们的值
 */
public class Demo1 

    public static void main(String[] args) 
        //创建Jedis连接对象
        Jedis jedis = new Jedis("localhost", 6379);
        //添加string类型
        jedis.set("person", "张三");
        //添加list类型
        jedis.lpush("cities", "广州","上海","东莞");
        //读取string类型
        String person = jedis.get("person");
        //读取list类型
        List<String> cities = jedis.lrange("cities", 0, -1);
        //输出到控制器上
        System.out.println("person:" + person);
        System.out.println("cities:" + cities);
        //关闭连接对象
        jedis.close();
    

3.Jedis连接池的使用

        3.1Jedis连接池的基本概念

jedis连接资源的创建与销毁是很消耗程序性能，所以jedis为我们提供了jedis的连接池技术，jedis

连接池在创建时初始化一些连接对象存储到连接池中，使用jedis连接资源时不需要自己创建jedis对

象，而是从连接池中获取一个资源进行redis的操作。使用完毕后，不需要销毁该jedis连接资源，

而是将该资源归还给连接池，供其他请求使用。 

        3.2Jedis连接池API

JedisPoolConfig配置类	功能说明
JedisPoolConfig()	创建一个配置对象，使用无参构造方法就可以了
void setMaxTotal()	设置连接池最大的连接数
void setMaxWaitMillis()	设置得到连接对象Jedis最长等待时间

JedisPool连接池类	说明
JedisPool(配置对象,服务器名,端口号)	创建连接池 参数1：上面的配置对象，参数2：服务器名，参数3：6379
Jedis getResource()	从连接池中得到一个Jedis连接对象
void close()	连接池关闭方法，通常不关闭连接池

        3.3JedisPool的基本使用

需求：

使用连接池优化jedis操作

开发步骤

创建连接池配置对象，设置最大连接数10，设置用户最大等待时间2000毫秒

通过配置对象做为参数，创建连接池对象

从连接池里面获取jedis连接对象，执行redis命令。

执行redis命令sadd写入set集合类型的数据：students=白骨精,孙悟空,猪八戒

执行redis命令smembers读取集合中的数据

输出读取的数据

关闭连接对象(通常连接池不关闭)

运行效果

执行代码

package com.itheima.jedis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.util.Set;

/**
 * 创建Jedis连接池
 */
public class Demo2 

    public static void main(String[] args) 
        //1)	创建连接池配置对象，设置最大连接数10，设置用户最大等待时间2000毫秒
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(10);
        config.setMaxWaitMillis(2000);
        //2)	通过配置对象做为参数，创建连接池对象
        JedisPool pool = new JedisPool(config, "localhost", 6379);
        //3)	从连接池里面获取jedis连接对象，执行redis命令。
        Jedis jedis = pool.getResource();
        //4)	执行redis命令sadd写入set集合类型的数据：students=白骨精,孙悟空,猪八戒
        jedis.sadd("students", "白骨精", "孙悟空", "猪八戒");
        //5)	执行redis命令smembers读取集合中的数据
        Set<String> students = jedis.smembers("students");
        //6)	输出读取的数据
        System.out.println(students);
        //7)	关闭连接对象(通常连接池不关闭)
        jedis.close();
        pool.close();
    

4.案例：编写jedis连接池工具类

        4.1相应API的学习

java.util.ResourceBundle类是专门用于：读取类路径下Properties配置文件的类

java.util.ResourceBundle类	功能
static ResourceBundle getBundle("配置基名")	通过自己的静态方法创建ResourceBundle对象 参数：放在src下.properties文件。参数中不用写扩展名，只要有主名就可以了
String getString("键名")	通过键得到值

案例：得到druid.properties中的url属性

package com.itheima.jedis;

import java.util.ResourceBundle;

/**
 * 读取属性文件
 */
public class Demo3 

    public static void main(String[] args) 
        //得到资源绑定对象
        ResourceBundle bundle = ResourceBundle.getBundle("druid");
        System.out.println(bundle.getString("url"));
    

        4.2连接池工具类的实现

需求：

实现连接池工具类，通过工具类得到Jedis连接对象，配置参数写在属性文件中

调用工具类，对Redis数据库进行操作

执行效果：

实现步骤：

在src目录下创建连接池的工具类: jedis.properties 

创建静态成员变量JedisPool对象

在静态代码块中，读取src下的配置文件，得到ResourceBundle对象

得到上面的四个参数，其中host是字符串类型，其它参数要转成整数类型

实例化配置对象，实例化连接池对象

编写静态方法getJedis()返回Jedis对象

创建hash对象：键employee，添加字段名：name，值：NewBoy；字段名: salary，值：3000

使用hgetall读取hash对象输出

关闭jedis对象

jedis.properties配置文件

# 主机名
host=localhost
# 端口号
port=6379
# 最大连接数
maxTotal=20
# 最长等待时间
maxWaitMillis=3000

JedisUtils.java

package com.itheima.utils;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.util.ResourceBundle;

/**
 * 连接池工具类
 */
public class JedisUtils 

    //创建一个连接对象
    private static JedisPool pool;

    static 
        //创建连接池的配置对象
        JedisPoolConfig config = new JedisPoolConfig();
        //设置最大连接数和最长等待时间
        ResourceBundle bundle = ResourceBundle.getBundle("jedis");
        //得到配置文件中的属性值
        String host = bundle.getString("host");
        int port = Integer.parseInt(bundle.getString("port"));
        int maxTotal = Integer.parseInt(bundle.getString("maxTotal"));
        int maxWaitMillis = Integer.parseInt(bundle.getString("maxWaitMillis"));
        //设置配置对象的参数
        config.setMaxTotal(maxTotal);
        config.setMaxWaitMillis(maxWaitMillis);
        //创建连接池对象
        pool = new JedisPool(config, host, port);
    

    /**
     * 得到redis连接对象
     * @return
     */
    public static Jedis getJedis() 
        return pool.getResource();
    

使用工具类：

package com.itheima.jedis;

import com.itheima.utils.JedisUtils;
import redis.clients.jedis.Jedis;

import java.util.Map;

/**
 * 使用工具类
 */
public class Demo4 

    public static void main(String[] args) 
        //从工具类中得到Jedis对象
        Jedis jedis = JedisUtils.getJedis();
        //创建hash对象：键employee，添加字段名：name，值：NewBoy；字段名: salary，值：3000
        jedis.hset("employee", "name","NewBoy");
        jedis.hset("employee", "salary","3000");
        //使用hgetall读取hash对象输出
        Map<String, String> employee = jedis.hgetAll("employee");
        System.out.println(employee);
        //关闭jedis对象
        jedis.close();
    

Redis高手修炼之路③持久化

持久化

• ​​1. RDB​​

• ​​1.1 自动备份​​
• ​​1.2 手动备份​​
• ​​1.3 与RDB相关的配置​​

• ​​2. AOF​​

• ​​2.1 开启AOF​​
• ​​2.2 共存？谁优先？​​
• ​​2.3 与AOF相关的配置​​

• ​​3 总结（如何选择？）​​

1. RDB

Redis DataBase

• 在指定的时间间隔内，将内存中的数据集的快照写入磁盘；
• 默认保存在/usr/local/bin中，文件名dump.rdb;

1.1 自动备份

redis是内存数据库，当我们每次用完redis，关闭linux时，按道理来说，内存释放，redis中的数据也会随之消失。为什么我们再次启动redis的时候，昨天的数据还在，并没有消失呢？

• 是因为，每次关机时，redis会自动将数据备份到一个文件中：/usr/local/bin/dump.rdb

接下来我们就来全方位的认识 自动备份机制

1. 默认的自动备份策略不利于我们测试，所以修改redis.conf文件中的自动备份策略

vim redis.conf
/SNAP     # 搜索

save 900 1      #900秒内，至少变更1次，才会自动备份
save 300 10     #300秒内，至少变更10次，才会自动备份
save 60 10000       # 60秒内，至少变更10000次，才会自动备份

​​注意:​​​ 如果你只是使用Redis的缓存功能，而不需要持久化，那么你就可以注释掉所有的save行停用该功能。然后可以直接一个空字符串来实现停用：​​save ""​​

2. 使用shutdown模拟关机，关机之前和关机之后，对比dump.rdb文件的时间
   ​​​注意：​​当我们使用shutdown命令，redis会自动将数据库备份。所以，dump.rdb文件创建时间会更新。
3. 开机启动redis，然后在300秒内保存10条数据，再查看dump.rdb文件的更新时间(开两个终端窗口，方便查看)
4. 300秒内保存10条数据这一动作触发了备份指令，所以目前的dump.rdb文件中保存了10条数据，将dump.rdb拷贝一份dump10.rdb，此时两个文件中都保存10条数据
5. 既然有数据已经备份了，那我们就肆无忌惮的通过​​flushall​​命令将数据全部删除，再次shutdown关机
6. 再次启动redis，发现数据真的消失了，并没有按照我们所想的将dump.rdb文件中的内容恢复到redis中。为什么？

因为，当我们保存10条以上的数据时，数据备份起来了；然后删除数据库，备份文件中的数据，也没问题；
但是，问题出在shutdown上，这个命令一旦执行，就会立刻备份，将删除之后的空数据库生成备份文件，
将之前装10条数据的备份文件覆盖掉了，所以自动恢复失败。怎么解决这个问题呢？要将备份文件再备份。
我们前面已经备份了一个dump10.rdb的文件。

7. 将dump.rdb文件删除，然后将dump10.rdb重命名为dump.rdb
8. 启动redis服务，登录redis，发现10条数据全部恢复！

1.2 手动备份

之前自动备份，必须更改好多数据，例如上边，我们改变了十多条数据，才会自动备份；现在，我只保存一条数据，就想立刻备份，应该怎么做？每次操作完成，执行命令 save 就会立刻备份

1.3 与RDB相关的配置

​​stop-writes-on-bgsave-error​​：进水口和出水口，出水口发生故障与否

• yes：当后台备份时候反生错误，前台停止写入
• no：不管死活，就是往里怼

​​rdbcompression​​：对于存储到磁盘中的快照，是否启动LZF压缩算法，一般都会启动，因为这点性能，多买一台电脑，完全搞定N个来回了。

• yes：启动
• no：不启动（不想消耗CPU资源，可关闭）

​​rdbchecksum​​：在存储快照后，是否启动CRC64算法进行数据校验；

• 开启后，大约增加10%左右的CPU消耗；
• 如果希望获得最大的性能提升，可以选择关闭；

​​dbfilename​​​：快照备份文件名字
​​​dir​​：快照备份文件保存的目录，默认为当前目录

优势and劣势

• 优势：适合大规模数据恢复，对数据完整性和一致行要求不高；
• 劣势：一定间隔备份一次，意外down掉，就失去最后一次快照的所有修改

2. AOF

Append Only File

• 以日志的形式记录每个写操作；
• 将redis执行过的写指令全部记录下来（读操作不记录）；只许追加文件，不可以改写文件；
• redis在启动之初会读取该文件从头到尾执行一遍，这样来重新构建数据；

2.1 开启AOF

1. 为了避免失误，最好将redis.conf总配置文件备份一下，然后再修改内容如下：

appendonly yes
appendfilename "appendonly.aof"

​​注意：​​编辑这个文件，最后要 :wq! 强制执行

2. 重新启动redis，以新配置文件启动

redis-server /opt/redis-5.0.4/redis.conf

3. 连接redis，加数据，删库，退出
4. 查看当前文件夹发现多一个aof文件，看看文件中的内容，保存的都是 写 操作
6. 文件中最后一句要删除，否则数据恢复不了



7. 只需要重新连接，数据恢复成功！

2.2 共存？谁优先？

我们查看redis.conf文件，AOF和RDB两种备份策略可以同时开启，那系统会怎样选择？

1. 编辑appendonly.aof，在文件中随便乱写一串代码，保存退出
2. 启动redis ，结果失败，所以是AOF优先载入来恢复原始数据！因为AOF比RDB数据保存的完整性更高！
3. 修复AOF文件，通过下面命令杀光不符合redis语法规范的代码

reids-check-aof --fix appendonly.aof

2.3 与AOF相关的配置

​​appendonly​​​：开启aof模式 appendfilename：aof的文件名字，最好别改！
​​​appendfsync​​：追写策略

• always：每次数据变更，就会立即记录到磁盘，性能较差，但数据完整性好
• everysec：默认设置，异步操作，每秒记录，如果一秒内宕机，会有数据丢失
• no：不追写

​​no-appendfsync-on-rewrite​​：重写时是否运用Appendfsync追写策略；用默认no即可，保证数据安全性。

• AOF采用文件追加的方式，文件会越来越大，为了解决这个问题，增加了重写机制，redis会自动记录上一次AOF文件的大小，当AOF文件大小达到预先设定的大小时，redis就会启动 AOF文件进行内容压缩，只保留可以恢复数据的最小指令集合

​​auto-aof-rewrite-percentage​​​：如果AOF文件大小已经超过原来的100%，也就是一倍，才重写压缩
​​​auto-aof-rewrite-min-size​​：如果AOF文件已经超过了64mb，才重写压缩

3 总结（如何选择？）

• RDB：只用作后备用途，建议15分钟备份一次就好
• AOF：

• 在最恶劣的情况下，也只丢失不超过2秒的数据，数据完整性比较高，但代价太大，会带来持续的IO
• 对硬盘的大小要求也高，默认64mb太小了，企业级最少都是5G以上；
• 后面要学习的master/slave才是新浪微博的选择！！