redis 介绍

Redis是一种支持key-value等多种数据结构的存储系统。可用于缓存，事件发布或订阅，高速队列等场景。支持网络，提供字符串，哈希，列表，队列，集合结构直接存取，基于内存，可持久化。

redis 集成

一、核心装配

1、RedisTemplate 注入

 @Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory,ObjectMapper objectMapper, KeyStringSerializer keyStringSerializer) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(redisConnectionFactory);//key序列化方式RedisSerializer<String> defalutSerializer = template.getStringSerializer();//值序列化方式RedisSerializer<Object> jsonRedisSerializer = new GenericJackson2JsonRedisSerializer(objectMapper);//设置key 的序列化方式template.setKeySerializer(keyStringSerializer);template.setHashKeySerializer(keyStringSerializer);//设置值 的序列化方式template.setValueSerializer(jsonRedisSerializer);template.setHashValueSerializer(jsonRedisSerializer);//设置默认的序列化方式template.setDefaultSerializer(defalutSerializer);template.afterPropertiesSet();return template;}

2、自自定义key 序列化 , redisKeyPrefix前缀兼容多项目隔离

@Slf4j
public class KeyStringSerializer implements RedisSerializer<String> {private final Charset charset;public KeyStringSerializer() {this.charset = StandardCharsets.UTF_8;}@Autowiredprivate CustomRedisProperties redisProperties;@Overridepublic byte[] serialize(String s) throws SerializationException {String newValue = getKeyPrefix() + s;return newValue.getBytes(charset);}@Overridepublic String deserialize(byte[] bytes) throws SerializationException {String saveKey = new String(bytes, charset);String keyPrefix = getKeyPrefix();if (StrUtil.isNotBlank(keyPrefix)) {int indexOf = saveKey.indexOf(keyPrefix);if (indexOf > 0) {log.info("key缺少前缀");} else {saveKey = saveKey.substring(indexOf);}log.info("saveKey:{}", saveKey);}return saveKey;}private String getKeyPrefix() {return redisProperties.getRedisKeyPrefix();}

二、redis操作封装

注入bean实例，方便引用

    @Beanpublic RedisService redisService(ObjectMapper objectMapper, RedisTemplate<String, Object> redisTemplate) {return new DefaultRedisServiceImpl(objectMapper, redisTemplate);}

RedisService 接口实现

package com.hxl.redis.load;import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;/*** @Author hxl* @description* @Date 2023-06-14 16:19**/
public interface RedisService {/*** *公共基础操作***/Boolean exists(String key);Boolean expire(String key, long timeout);Boolean expire(final String key, final long timeout, final TimeUnit unit);int delete(String... keys);Boolean delete(String key);/*** *基础类型(Integer、String、实体类等) 操作***/Boolean set(String key, Object value);Boolean set(String key, Object value, long expireTime);Boolean set(String key, Object value, long expireTime, TimeUnit timeUnit);String get(String key);<T> T getObject(String key, Class<T> type);<T> List<T> getObjectList(String key, Class<T> type);/*** *双向列表 list操作***/Long setCacheList(String key, Object value);Long setCacheList(String key, List<Object> values);Long setLeftCacheList(String key, Object value);Long setLeftCacheList(String key, List<Object> values);<T> T rightPop(String key, Class<T> type);<T> T leftPop(String key, Class<T> type);<T> List<T> getCacheList(String key, Class<T> type);Long size(String key);/*** *hash map操作**/Boolean hPut(String key, String hashKey, Object value);Boolean hPutAll(String key, Map<String, String> maps);Boolean hExists(String key, String field);Long hDelete(String key, Object... fields);Map<Object, Object> hGetAll(String key);Object hGet(String key, String field);List<Object> hMultiGet(String key, Collection<Object> fields);Long hSize(String key);/*** *set 集合 不重复**/boolean addSet(String key, Object value);boolean removeSet(String key, Object... value);Set<Object> getAllSet(String key);/*** *set 有序集合 不重复**/Boolean addZSet(String key, Object value, double score);Long removeZSet(String key, Object... value);/*** ZSet数据增加分数** @param key   key* @param value value* @param delta 分数* @return duuble*/Double incrZSet(String key, Object value, double delta);/*** 升序 区间查询** @param key key* @param min 最小分数* @param max 最大分数* @return Set<Object>*/Set<Object> zSetRangeByScore(String key, double min, double max);/*** 降序 区间查询** @param key key* @param min 最小分数* @param max 最大分数* @return Set<Object>*/Set<Object> zSetRangeDescByScore(String key, double min, double max);
}

具实现见：DefaultRedisServiceImpl

三、使用方法

1、pom 依赖

<dependency><groupId>com.hxl</groupId><artifactId>tower-boot-redis</artifactId><version>1.0.0-SNAPSHOT</version>
</dependency>

2、yml 配置

edisKeyPrefix 项目前缀,会默认拼接key前缀

spring:redis:host: 127.0.0.1port: 6379database: 0password:timeout: 5000lettuce:pool:max-active: 8max-idle: 8max-wait: -1min-idle: 0redisKeyPrefix: tower

github 项目地址：

https://github.com/sanxiaoshitou/tower-boot