launch-webFlux-platform/launch-redis/src/main/java/com/weblux/launchredis/utils/ReactiveRedisServer.java

package com.weblux.launchredis.utils;

import jakarta.annotation.Resource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.ReactiveRedisTemplate;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono;

import java.time.Duration;
@Component
@SuppressWarnings(value = { "unchecked", "rawtypes" })
public class ReactiveRedisServer {

    @Resource
    private ReactiveRedisTemplate<String,String> reactiveRedisTemplate;


    public Mono<String> getKey(String key){
      return reactiveRedisTemplate.opsForValue().get(key);
    }

    public Mono<Boolean> setKey(String key,String value,Long seconds){
        return reactiveRedisTemplate.opsForValue().set(key, value, Duration.ofSeconds(seconds));
    }
}