java - 过期的 Redisson 密钥在 Redis Cli 中仍然可见

Question

我也刚刚了解了 Redis 和 Redisson。基本上我正在尝试使用 Redis 来存储用于在我的应用程序中进行授权的 AcessTokens/RefreshTokens。所以我想用过期时间存储令牌。我使用Spring Data Redis来存储令牌，但没有 Api 可以使 Map 中的每个条目过期。我遇到了这篇Spring Data Redis Expire Key帖子，因此查找了 Redisson。我尝试了一个简单的maven java项目来测试过期。这是 pom.xml：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.bridgelabz</groupId>
    <artifactId>redissonApp</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>redissonApp</name>
    <url>http://maven.apache.org</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>3.8.1</version>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.3.0</version>
        </dependency>

    </dependencies>
</project>

下面是 Token 类

package com.bridgelabz.redissonApp;

public class Token {

    private String accessToken;
    private int id;

    public Token() { }


    public Token(String accessToken, int id) {

        this.accessToken = accessToken;
        this.id = id;
    }

    public String getAccessToken() {
        return accessToken;
    }

    public void setAccessToken(String accessToken) {
        this.accessToken = accessToken;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    @Override
    public String toString() {
        return "Token [accessToken=" + accessToken + ", id=" + id + "]";
    }   

}

这是我的演示应用程序：

package com.bridgelabz.redissonApp;

import java.util.concurrent.TimeUnit;

import org.redisson.Redisson;
import org.redisson.api.LocalCachedMapOptions;
import org.redisson.api.RMapCache;
import org.redisson.api.RedissonClient;
import org.redisson.api.LocalCachedMapOptions.EvictionPolicy;
import org.redisson.config.Config;


public class App {
    public static void main(String[] args) {
        Config config = new Config();

        config.useSingleServer().setAddress("127.0.0.1:6379");

        // LocalCachedMapOptions localCachedMapOptions =
        // LocalCachedMapOptions.defaults()
        // .evictionPolicy(EvictionPolicy.LFU);

        RedissonClient redisson = Redisson.create(config);

        try {

            RMapCache<Integer, Token> map = redisson.getMapCache("TestMap");

            Token myToken = new Token("abc", 1);

            map.put(1, myToken, 10, TimeUnit.SECONDS);

            System.out.println("Stored value with key 1 is: " + map.get(1));

        }

        finally {

            redisson.shutdown();

        }

    }
}

运行 App.java 后，我得到输出，我得到的输出为：

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Stored value with key 1 is: Token [accessToken=abc, id=1]

只需评论 put 代码并在 10 秒后运行应用程序，我就会得到部分想要的结果：

LF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Stored value with key 1 is: null

但是当我运行 redis-cli 时，我仍然在输出中得到值：

127.0.0.1:6379> hget TestMap 1
"\x00\x00\x00\x00\x00\x00\x00\x00H\x00\x00\x00\x00\x00\x00\x00{\"@class\":\"com.bridgelabz.redissonApp.Token\",\"accessToken\":\"abc\",\"id\":1}"

为什么密钥也没有从 redis 中删除？仅供参考：一切都在我的本地机器上进行测试，仅包括 redis。

score 6 · Accepted Answer

Redis 不支持开箱即用的单个元素逐出散列。所以 Redisson 建立了自己的解决方案并命名为MapCache.

因此，有了MapCache，您现在有两个级别的过期控制：Redis 提供的密钥级别和 Redisson 提供的字段级别。

在您的测试代码中：

RMapCache<Integer, Token> map = redisson.getMapCache("TestMap");

Token myToken = new Token("abc", 1);

map.put(1, myToken, 10, TimeUnit.SECONDS);

1您已经在 hash的字段上设置了过期时间TestMap。这意味着哈希没有针对它设置到期，而是针对它拥有的字段之一设置了到期。所以当你在 using 中查找它时redis-cli，哈希仍然存在。当 Redisson 过期进程启动时，它最终会消失。

score 0 · Accepted Answer

    try {

        RMapCache<Integer, Token> map = redisson.getMapCache("TestMap");

        Token myToken = new Token("abc", 1);

        map.put(1, myToken, 10, TimeUnit.SECONDS);

        System.out.println("Stored value with key 1 is: " + map.get(1));

    }

    finally {

        redisson.shutdown();

    }

将项目放入地图时您的应用程序已退出，然后当该项目过期时没有机会为您的应用程序清理项目。

score 0 · Accepted Answer

我不知道原因，但是当我在 Spring Web App 中使用相同的代码但在简单的 Java 应用程序中不起作用时，密钥已过期。这是 TokenDaoImpl.java 的代码：

import java.io.IOException;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;

import org.apache.log4j.Logger;
import org.redisson.Redisson;
import org.redisson.api.RMapCache;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.stereotype.Repository;

import com.bridgelabz.restApiDemo.entity.Token;

@Repository
public class TokenDaoImpl implements TokenDao {

    Logger logger = Logger.getLogger(TokenDaoImpl.class);

    RedissonClient redissonClient;

    RMapCache<String, Token> tokenMap;

    @PostConstruct
    public void initRedisson() {

        Config config = null;
        try {
            config = Config.fromJSON("{\n" + "   \"singleServerConfig\":{\n"
                    + "      \"idleConnectionTimeout\":10000,\n" + "      \"pingTimeout\":1000,\n"
                    + "      \"connectTimeout\":10000,\n" + "      \"timeout\":3000,\n" + "      \"retryAttempts\":3,\n"
                    + "      \"retryInterval\":1500,\n" + "      \"reconnectionTimeout\":3000,\n"
                    + "      \"failedAttempts\":3,\n" + "      \"password\":null,\n"
                    + "      \"subscriptionsPerConnection\":5,\n" + "      \"clientName\":null,\n"
                    + "      \"address\": \"redis://127.0.0.1:6379\",\n"
                    + "      \"subscriptionConnectionMinimumIdleSize\":1,\n"
                    + "      \"subscriptionConnectionPoolSize\":50,\n" + "      \"connectionMinimumIdleSize\":10,\n"
                    + "      \"connectionPoolSize\":64,\n" + "      \"database\":0,\n"
                    + "      \"dnsMonitoring\":false,\n" + "      \"dnsMonitoringInterval\":5000\n" + "   },\n"
                    + "   \"threads\":0,\n" + "   \"nettyThreads\":0,\n" + "   \"codec\":null,\n"
                    + "   \"useLinuxNativeEpoll\":false\n" + "}");
        } catch (IOException e1) {
            logger.info("******Inside Config Catch");
            e1.printStackTrace();
        }

        logger.info("**************Config Object" + config);

        redissonClient = Redisson.create(config);

        tokenMap = redissonClient.getMapCache("tokenMap");
    }

    @PreDestroy
    public void redissonShutdown() {
        redissonClient.shutdown();
    }

    public TokenDaoImpl() {

    }

    @Override
    public Token generateToken(String tokenType, int uid) {

        // first generate the token
        String tokenValue = UUID.randomUUID().toString().replaceAll("-", "");
        logger.info("******Generated access token is " + tokenValue);

        Token token = new Token(tokenType, tokenValue, uid);

        // save the token in redis cache with expiration depending upon tokenType
        switch (tokenType) {
        case "accessToken":
            tokenMap.put(tokenValue, token, 15, TimeUnit.MINUTES);
            break;

        case "refreshToken":
            tokenMap.put(tokenValue, token, 30, TimeUnit.MINUTES);
            break;

        case "forgotToken":
            tokenMap.put(tokenValue, token, 30, TimeUnit.MINUTES);
            break;

        default:
            logger.info("**********Please specify correct token type!");
            break;
        }

        return token;
    }

    @Override
    public boolean verifyToken(String tokenValue) {

        Token token = tokenMap.get(tokenValue);

        logger.info("******Token from redis for verification" + token);

        if (token != null) {
            return true;
        }

        return false;
    }

}

以前，在运行 Java 应用程序时，我在 redis 中有两个 Map，一个是我创建的，一个是TokenMap新的 map，它有MapName_session_timeout，即使在指定的过期时间之后，键也会保留。现在所有键都已正确删除。

java - 过期的 Redisson 密钥在 Redis Cli 中仍然可见

3 回答 3

Related

Reference