springboot指定redis库编号配置实现

Posted 2021-02-01 zincredible

yml配置

spring:  
  redis:
    database: 0   #shiro
    host: 127.0.0.1
    port: 6379
    timeout: 6000
    password: null
  redis-cache:
    database: 1 #字符串缓存
    host: 127.0.0.1
    port: 6379
    timeout: 6000
    password: null
    maxTotal: 200
    maxIdle: 20
    minIdle: 10

redis配置类

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.util.StringUtils;

import redis.clients.jedis.JedisPoolConfig;

@Configuration
public class RedisCacheConfig {

    @Value("${spring.redis-cache.host}")
    private String host; // ip
    @Value("${spring.redis-cache.port}")
    private int port; // 端口
    @Value("${spring.redis-cache.password}")
    private String password; // 密码
    @Value("${spring.redis-cache.database}")
    private int database;//数据库索引
    @Value("${spring.redis-cache.timeout}")
    private int timeout; //链接超时
    @Value("${spring.redis-cache.maxIdle}")
    private int maxIdle;// 最大空闲连接
    @Value("${spring.redis-cache.minIdle}")
    private int minIdle;// 最小空闲连接
    @Value("${spring.redis-cache.maxTotal}")
    private int maxTotal;// 连接池最大连接数（使用负值表示没有限制）

    //注入字符串缓存实例，同理可注入Object缓存实例等等
    @Bean(name = "cacheTemplate")
    public StringRedisTemplate redisTemplate() {
        StringRedisTemplate temple = new StringRedisTemplate();
        temple.setConnectionFactory(connectionFactory());
        return temple;
    }

    public RedisConnectionFactory connectionFactory() {
        JedisConnectionFactory jedis = new JedisConnectionFactory();
        jedis.setHostName(host);
        jedis.setPort(port);
        jedis.setTimeout(timeout);
        if (!StringUtils.isEmpty(password)) {
            jedis.setPassword(password);
        }
        if (database != 0) {
            jedis.setDatabase(database);
        }
        jedis.setPoolConfig(poolCofig());
        // 初始化连接pool
        jedis.afterPropertiesSet();

        return jedis;
    }

    public JedisPoolConfig poolCofig() {
        JedisPoolConfig poolCofig = new JedisPoolConfig();
        poolCofig.setMaxIdle(maxIdle);
        poolCofig.setMinIdle(minIdle);
        poolCofig.setMaxTotal(maxTotal);
        return poolCofig;
    }
}

缓存服务接口和实现

public interface IStringCacheService {

    boolean set(String key, String value);

    boolean set(String key, String value, long secondTime);
    
    boolean set(String key, String value, int hourTime);

    boolean delete(String... key);

    boolean hasKey(String key);

    boolean update(String key, String value);
    
    boolean update(String key, String value,long time);

    String get(String key);

    long getExpire(String key);
    
    boolean setExpire(String key,long time);
}

import java.util.Arrays;
import java.util.concurrent.TimeUnit;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Service
public class StringCacheServiceImpl implements IStringCacheService {
    @Autowired
    @Qualifier("cacheTemplate")
    private StringRedisTemplate cacheTemplate;

    @Override
    public boolean set(String key, String value, long secondTime) {
        try {
            cacheTemplate.opsForValue().set(key, value, secondTime, TimeUnit.SECONDS);
            return true;
        } catch (Exception e) {
            log.error(e.toString());
        }
        return false;
    }

    @Override
    public boolean set(String key, String value, int hourTime) {
        try {
            cacheTemplate.opsForValue().set(key, value, hourTime, TimeUnit.HOURS);
            return true;
        } catch (Exception e) {
            log.error(e.toString());
        }
        return false;
    }

    @Override
    public boolean hasKey(String key) {
        try {
            return cacheTemplate.hasKey(key);
        } catch (Exception e) {
            log.error(e.toString());
        }
        return false;
    }

    @Override
    public long getExpire(String key) {
        return cacheTemplate.getExpire(key, TimeUnit.SECONDS);
    }

    @Override
    public boolean setExpire(String key, long time) {
        try {
            if (time > 0) {
                return cacheTemplate.expire(key, time, TimeUnit.SECONDS);
            }
        } catch (Exception e) {
            log.error(e.toString());
        }
        return false;
    }

    @Override
    public boolean set(String key, String value) {
        try {
            cacheTemplate.opsForValue().set(key, value);
            return true;
        } catch (Exception e) {
            log.error(e.toString());
        }
        return false;
    }

    @Override
    public boolean delete(String... key) {
        try {
            if (key != null && key.length > 0) {
                if (key.length == 1) {
                    cacheTemplate.delete(key[0]);
                } else {
                    cacheTemplate.delete(Arrays.asList(key));
                }
            }
            return true;
        } catch (Exception e) {
            log.error(e.toString());
        }
        return false;
    }

    @Override
    public boolean update(String key, String value) {
        return set(key, value);
    }

    @Override
    public String get(String key) {
        return key == null ? null : cacheTemplate.opsForValue().get(key);
    }

    @Override
    public boolean update(String key, String value, long time) {
        return set(key, value, time);
    }

}