package com.walker.tcp.lb;

import com.walker.infrastructure.utils.StringUtils;
import com.walker.support.redis.cache.RedisCacheProvider;
import com.walker.tcp.Constants;

/**
 * 连接元数据对象缓存定义。
 * <p>这仅仅是描述了连接基本信息，不是长连接本身！</p>
 * @author 时克英
 * @date 2023-09-25
 */
public class RedisConnectionMetaCache extends RedisCacheProvider<LongConnectionMeta> {

    public RedisConnectionMetaCache(){
        this.setUseRedis(true);
        this.setLoadPage(false);
        // 2024-01-05 设置支持缓存失效，该参数很重要，如果需要失效而没有设置在调用后会出现数据无法失效！
        this.setSupportExpiredCache(true);
    }

    public LongConnectionMeta getConnectionMeta(String id){
        return this.getCacheData(id);
    }

    public void removeConnectionMeta(String id){
        this.removeCacheData(id);
    }

    /**
     * 缓存一个连接元数据对象，默认：24小时候失效。
     * @param connectionMeta
     */
    public void putConnectionMeta(LongConnectionMeta connectionMeta){
//        this.putCacheData(this.getKey(connectionMeta.getConnectionHost(), connectionMeta.getId()), connectionMeta, expiredSeconds);
        this.putCacheData(connectionMeta.getId(), connectionMeta, expiredSeconds);
    }

    @Deprecated
    private String getKey(String connectionHost, String id){
        return new StringBuilder(connectionHost).append(StringUtils.SEPARATOR_COLON).append(id).toString();
    }

    @Override
    public String getProviderName() {
        return Constants.CACHE_NAME_CONNECTION_META;
    }

    @Override
    public Class<?> getProviderType() {
        return LongConnectionMeta.class;
    }

    public long getExpiredSeconds() {
        return expiredSeconds;
    }

    /**
     * 设置缓存失效时间，单位：秒，如果不设置默认：24小时
     * @param expiredSeconds
     */
    public void setExpiredSeconds(long expiredSeconds) {
        this.expiredSeconds = expiredSeconds;
    }

    private long expiredSeconds = 8 * 3600;
}