redis簡(jiǎn)介
redis是一個(gè)key-value存儲(chǔ)系統(tǒng)流昏。和Memcached類似，它支持存儲(chǔ)的value類型相對(duì)更多铺遂，包括string(字符串)茎刚、list(鏈表)膛锭、set(集合)、zset(sorted set --有序集合)和hash（哈希類型）
一莫杈、redis入門級(jí)配置
1.1單機(jī)版配置文件
import org.springframework.boot.context.properties.ConfigurationProperties;
import java.time.Duration;
/**
* @author wangcanfeng
* @description redis配置信息
* @Date Created in 11:07-2019/4/1
*/
@ConfigurationProperties(prefix = "spring.redis")
public class RedisStandaloneProperties {
/**
* redis的數(shù)據(jù)庫索引
*/
private int database = 0;
/**
* host地址筝闹，可以輸入host的ip地址
*/
private String host;
/**
* redis服務(wù)的端口號(hào)
*/
private int port;
/**
* 連接超時(shí)時(shí)間
*/
private Duration timeout;
/**
* lettuce的配置信息
*/
private final Lettuce lettuce = new Lettuce();
/**
* lettuce的配置信息.
*/
public static class Lettuce {
/**
* 停止服務(wù)的超時(shí)時(shí)間.
*/
private Duration shutdownTimeout = Duration.ofMillis(100);
/**
* lettuce連接池配置信息.
*/
private Pool pool;
public Duration getShutdownTimeout() {
return this.shutdownTimeout;
}
public void setShutdownTimeout(Duration shutdownTimeout) {
this.shutdownTimeout = shutdownTimeout;
}
public Pool getPool() {
return this.pool;
}
public void setPool(Pool pool) {
this.pool = pool;
}
}
/**
* 連接池的配置信息.
*/
public static class Pool {
/**
* 最大的空閑連接數(shù)
*/
private int maxIdle;
/**
* 最少需要保持的空閑連接數(shù)
*/
private int minIdle;
/**
* 最大活躍連接數(shù)
*/
private int maxActive;
/**
* 最大等待時(shí)間关顷，也就是阻塞時(shí)間
*/
private Duration maxWait;
public int getMaxIdle() {
return this.maxIdle;
}
public void setMaxIdle(int maxIdle) {
this.maxIdle = maxIdle;
}
public int getMinIdle() {
return this.minIdle;
}
public void setMinIdle(int minIdle) {
this.minIdle = minIdle;
}
public int getMaxActive() {
return this.maxActive;
}
public void setMaxActive(int maxActive) {
this.maxActive = maxActive;
}
public Duration getMaxWait() {
return this.maxWait;
}
public void setMaxWait(Duration maxWait) {
this.maxWait = maxWait;
}
}
public int getDatabase() {
return database;
}
public void setDatabase(int database) {
this.database = database;
}
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
public Duration getTimeout() {
return timeout;
}
public void setTimeout(Duration timeout) {
this.timeout = timeout;
}
public Lettuce getLettuce() {
return lettuce;
}
}
1.2 單機(jī)版配置類
不知道為什么，官方將很多默認(rèn)配置類都做成了非公有的類平痰，在外部根本無法直接使用伍纫，那么我們只能自己動(dòng)手做一個(gè)類來滿足需求了。
import io.lettuce.core.ClientOptions;
import io.lettuce.core.resource.ClientResources;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;
import java.time.Duration;
import java.util.Optional;
/**
* @author wangcanfeng
* @description 單機(jī)版具有連接池的配置信息
* @Date Created in 14:50-2019/4/1
*/
public class StandaloneLettucePoolingClientConfiguration implements LettucePoolingClientConfiguration {
/**
* 客戶端配置對(duì)象
*/
private final LettuceClientConfiguration clientConfiguration;
/**
* 連接池配置對(duì)象
*/
private final GenericObjectPoolConfig poolConfig;
/**
* 單機(jī)版配置對(duì)象
*/
private final RedisStandaloneConfiguration standaloneConfiguration;
/**
* 功能描述: 單機(jī)版配置類的構(gòu)造函數(shù)
* @param poolConfig 連接池信息
* @param host 主機(jī)地址
* @param port 主機(jī)端口
* @param timeout 連接超時(shí)時(shí)間
* @return:
* @since: v1.0
* @Author:
* @Date:
*/
public StandaloneLettucePoolingClientConfiguration(GenericObjectPoolConfig poolConfig,
String host, Integer port,Duration timeout) {
this.poolConfig = poolConfig;
this.clientConfiguration = LettuceClientConfiguration.builder().commandTimeout(timeout).build();
this.standaloneConfiguration = new RedisStandaloneConfiguration(host, port);
}
public RedisStandaloneConfiguration getStandaloneConfiguration() {
return standaloneConfiguration;
}
@Override
public GenericObjectPoolConfig getPoolConfig() {
return poolConfig;
}
@Override
public boolean isUseSsl() {
return clientConfiguration.isUseSsl();
}
@Override
public boolean isVerifyPeer() {
return clientConfiguration.isVerifyPeer();
}
@Override
public boolean isStartTls() {
return clientConfiguration.isStartTls();
}
@Override
public Optional<ClientResources> getClientResources() {
return Optional.empty();
}
@Override
public Optional<ClientOptions> getClientOptions() {
return Optional.empty();
}
@Override
public Duration getCommandTimeout() {
return clientConfiguration.getCommandTimeout();
}
@Override
public Duration getShutdownTimeout() {
return clientConfiguration.getShutdownTimeout();
}
}
上面的代碼中我們可以看到配置類是實(shí)現(xiàn)了LettucePoolingClientConfiguration的，這里先不展開嘹履，后面通過閱讀另一部分源碼就可以輕松的理解了。
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.interceptor.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.util.ObjectUtils;
/**
* @author wangcanfeng
* @description redis配置類
* @Date Created in 19:38-2019/3/28
*/
@EnableCaching
@Configuration
@EnableConfigurationProperties(RedisStandaloneProperties.class)
public class RedisConfig extends CachingConfigurerSupport {
@Autowired
private RedisStandaloneProperties properties;
/**
* 功能描述: 具備連接池的lettuce連接工廠
*/
@Bean
public LettuceConnectionFactory lettuceConnectionFactory() {
//連接池配置
RedisStandaloneProperties.Pool pool = properties.getLettuce().getPool();
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMaxIdle(pool.getMaxIdle());
poolConfig.setMinIdle(pool.getMinIdle());
poolConfig.setMaxWaitMillis(pool.getMaxWait().toMillis());
poolConfig.setMaxTotal(pool.getMaxActive());
// 單機(jī)配置初始化
StandaloneLettucePoolingClientConfiguration standalone =
new StandaloneLettucePoolingClientConfiguration(
poolConfig, properties.getHost(), properties.getPort(), properties.getTimeout());
LettuceConnectionFactory factory = new LettuceConnectionFactory(standalone.getStandaloneConfiguration(), standalone);
//一定要執(zhí)行這個(gè)方法焕刮，才能使得factory生效
factory.afterPropertiesSet();
return factory;
}
/**
* 功能描述: redis模型
*/
@Bean
public <K, V> RedisTemplate<K, V> redisTemplate() {
RedisTemplate<K, V> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(lettuceConnectionFactory());
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
/**
* 功能描述: string類型的template
* 鍵和值都是String,主要功能就是方便String類型的存儲(chǔ)
*
* @param
* @return:org.springframework.data.redis.core.StringRedisTemplate
* @since: v1.0
* @Author:wangcanfeng
* @Date: 2019/4/1 16:45
*/
@Bean
public StringRedisTemplate stringRedisTemplate() {
return new StringRedisTemplate(lettuceConnectionFactory());
}
/**
* 功能描述: 緩存管理器
*/
@Bean
@Override
public CacheManager cacheManager() {
//springboot2.X以上版本引入的緩存管理器和以前版本的緩存管理器初始化方式不一樣配并，
// 新版本的緩存管理器通過連接工程進(jìn)行初始化
return RedisCacheManager.create(lettuceConnectionFactory());
}
/**
* 功能描述: 緩存鍵的生成器
*/
@Bean
@Override
public KeyGenerator keyGenerator() {
return (target, method, params) -> {
StringBuilder sb = new StringBuilder();
// 目標(biāo)類的類名
sb.append(target.getClass().getName());
// 目標(biāo)方法名
sb.append('#').append(method.getName());
if (ObjectUtils.isEmpty(params)) {
sb.append("()");
} else {
sb.append("(");
for (Object param : params) {
if (param != null) {
sb.append(param).append(",");
} else {
// 參數(shù)為空的時(shí)候拼接上null
sb.append("null").append(",");
}
}
//移除最后一個(gè)逗號(hào)
sb.deleteCharAt(sb.length() - 1);
sb.append(")");
}
return sb.toString();
};
}
/**
* 功能描述: 緩存解析器溉旋，可以通過定時(shí)的方式，對(duì)緩存中的內(nèi)容進(jìn)行處理
*/
@Override
public CacheResolver cacheResolver() {
return new SimpleCacheResolver(cacheManager());
}
/**
* 功能描述: 緩存異常處理器
*/
@Override
public CacheErrorHandler errorHandler() {
return new SimpleCacheErrorHandler();
}
}
在上面的方法中邑闲，我們連接工廠bean創(chuàng)建的最后調(diào)用了如下方法
factory.afterPropertiesSet();
這個(gè)方法中的源碼如下苫耸，方法內(nèi)部調(diào)用的createConnectionProvider方法儡陨，會(huì)去判斷配置對(duì)象是否實(shí)現(xiàn)于LettucePoolingClientConfiguration骗村，然后生成對(duì)應(yīng)的provider。
public void afterPropertiesSet() {
this.client = createClient();
//在這個(gè)方法里面渔扎，會(huì)根據(jù)配置對(duì)象是否實(shí)現(xiàn)于LettucePoolingClientConfiguration來生成對(duì)應(yīng)的provider
this.connectionProvider = createConnectionProvider(client, LettuceConnection.CODEC);
this.reactiveConnectionProvider = createConnectionProvider(client, LettuceReactiveRedisConnection.CODEC);
if (isClusterAware()) {
this.clusterCommandExecutor = new ClusterCommandExecutor(
new LettuceClusterTopologyProvider((RedisClusterClient) client),
new LettuceClusterConnection.LettuceClusterNodeResourceProvider(this.connectionProvider),
EXCEPTION_TRANSLATION);
}
}
private LettuceConnectionProvider createConnectionProvider(AbstractRedisClient client, RedisCodec<?, ?> codec) {
LettuceConnectionProvider connectionProvider = doConnectionProvider(client, codec);
//這里判斷客戶端配置是否實(shí)現(xiàn)于LettucePoolingClientConfiguration，如果是残吩，則創(chuàng)建帶有連接池的provider泣侮。
if (this.clientConfiguration instanceof LettucePoolingClientConfiguration) {
return new LettucePoolingConnectionProvider(connectionProvider,
(LettucePoolingClientConfiguration) this.clientConfiguration);
}
return connectionProvider;
}
1.3 值的存取
//利用restTemplate進(jìn)行存值
redisTemplate.opsForValue().set("test","test");
//取值
Object test= redisTemplate.opsForValue().get("test");
原創(chuàng)文章轉(zhuǎn)載請(qǐng)標(biāo)明出處
更多文章請(qǐng)查看
http://www.canfeng.xyz
