芭比Q了，redis干了啥

背景

在开发测试过程中，或排查生产问题时，难免会碰到想查看redis服务中某些key的值是怎么变动的，以便确认数据变更与业务流转是否保持一致。此时，就涉及到命令回看——回看redis中执行的变更命令（数据变更）。

那如何实现命令回看呢？作为一个redis使用人员，最先想到的是monitor命令，通过执行monitor来查看redis服务执行的命令情况。

monitor

还可根据monitor结果筛选包含指定键/键类型的命令信息，命令示例如下：

键事件及redis发布订阅

在对应的redis应用执行config set notify-keyspace-events AKE。如需关注键新增事件或键未命中事件，请在配置值中额外补加对应类字符。

订阅事件通知消息并处理纪录

• 新建事件：获取key，执行查询命令获取当前key的value值，并根据接收到订阅消息的时间近似key新增的时间，然后保存记录。
• 更新事件：获取key，执行查询命令获取当前key的value值，并根据接收到订阅消息的时间近似key变更的时间，然后保存记录。
• 删除事件：获取key，并根据接收到订阅消息的时间近似key删除的时间，然后保存记录。

aof文件

这时，不免发现一个问题，我的键变更命令是什么时候执行的？你这个记录里边没有呀？是的，很遗憾，redis 7.0之前的aof文件中并未存储命令执行时间，所以能拿到和提供的也就这么多了。

那么7.0及之后版本的redis aof文件中是有执行时间了吗？这个可以有。

java 解析aof文件示例如下：

public class RedisKeyChangeTest{
 
    @Test
    public void scanAof(){
        String localFilePath = "/data/redis.aof"; //aof file path
        long currentLine = 1;
        try (FileReader fileReader = new FileReader(new File(localFilePath));
            BufferedReader bufferedReader = new BufferedReader(fileReader);){
            List<RedisKeyUpdateRecord> redisRecordList = new ArrayList<>();
            List<RedisKeyUpdateRecord> tempRedisRecords = new ArrayList<>();
            String str;
            while((str = bufferedReader.readLine()) != null){
                currentLine++;
                if(str.startsWith("*")){
                    RedisKeyUpdateRecord redisRecord = new RedisKeyUpdateRecord();
                    StringBuffer values = new StringBuffer();
                    String s = str.replaceFirst("\\*", "");
                    Integer paramNum = Integer.valueOf(s);
                    for (int i = 0; i < 2* paramNum; i++){
                        String s1 = bufferedReader.readLine();
                        currentLine++;
                        if(i % 2 == 0){
                            continue;
                        }
                        if(i == 1){
                            redisRecord.setCommand(s1);
                        }else if(i == 3){
                            redisRecord.setKey(s1);
                        }else{
                            if(i == 5){
                                values.append(s1);
                            }else{
                                values.append(" ");
                                values.append(s1);
                            }
                        }
                    }
                    redisRecord.setValue(values.toString());
                    redisRecordList.add(redisRecord);
                    tempRedisRecords.add(redisRecord);
                }
                if(str.startsWith("#TS:")){
                    String timestamp = str.replace("#TS:", "");
                    Long updateTime = Long.valueOf(timestamp);
                    Timestamp time = new Timestamp(updateTime * 1000);
                    tempRedisRecords.forEach(redisRecord -> redisRecord.setUpdateTime(time));
                    tempRedisRecords.clear();
                    log.info("save redis key record, currentLine:{}", currentLine);
                }
            }
        }catch (Exception e){
            log.error("save redis key record error, execute currentLine:{}", currentLine, e.getMessage());
        }
    }
 
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    class RedisKeyUpdateRecord {
        /**
         * 命令
         */
        private String command;
        /**
         * key
         */
        private String key;
        /**
         * value
         */
        private String value;
        /**
         * 更新时间
         */
        private Timestamp updateTime;
    }
}

方案总结对比

拓展

monitor简介：

monitor原理：