spring boot构建基础版web项目(三)-springboot、redis数据缓存整合

神甫

@Component　　@Slf4j

　　public>　　@Autowired
　　RedisTemplate redisTemplate;
　　/**
　　* 键值对设值
　　*
　　* @param key   键
　　* @param value 值
　　* @return
　　*/
　　public  Boolean set(K key, V value) {
　　return redisTemplate.execute((RedisCallback) connection -> {
　　connection.set(JSON.toJSONBytes(key), JSON.toJSONBytes(value));
　　return true;
　　});
　　}
　　/**
　　* 键值对设值和有效时间
　　*
　　* @param key   键
　　* @param value 值
　　* @param time  有效时间(单位：秒)
　　* @return
　　*/
　　public  Boolean setEx(K key, V value, long time) {
　　return redisTemplate.execute((RedisCallback) connection -> {
　　connection.setEx(JSON.toJSONBytes(key), time, JSON.toJSONBytes(value));
　　return true;
　　});
　　}
　　/**
　　* 查询键值对
　　*
　　* @param key           键
　　* @param typeReference 返回类型
　　* @param            键类型
　　* @param            返回类型
　　* @return
　　*/
　　public  R get(K key, TypeReference typeReference) {
　　byte[] redisValue = redisTemplate.execute((RedisCallback) connection -> connection.get(JSON.toJSONBytes(key)));
　　if (redisValue == null) return null;
　　return JSONObject.parseObject(new String(redisValue), typeReference);
　　}
　　/**
　　* 存储Hash结构数据(批量)
　　*
　　* @param outerKey 外键
　　* @param map      内键-内值
　　* @return
　　*/
　　public  Boolean hSetMap(O outerKey, Map map) {
　　if (map == null || map.isEmpty()) return false;
　　Map byteMap = new HashMap();
　　map.forEach((innerKey, innerValue) -> byteMap.put(JSON.toJSONBytes(innerKey), JSON.toJSONBytes(innerValue)));
　　return redisTemplate.execute((RedisCallback) connection -> {
　　connection.hMSet(JSON.toJSONBytes(outerKey), byteMap);
　　return true;
　　});
　　}
　　/**
　　* 存储Hash结构数据
　　*
　　* @param outerKey   外键
　　* @param innerKey   内键
　　* @param innerValue 值
　　* @return
　　*/
　　public  Boolean hSet(O outerKey, I innerKey, V innerValue) {
　　Map map = new HashMap();
　　map.put(innerKey, innerValue);
　　return this.hSetMap(outerKey, map);
　　}
　　/**
　　* 获取Hash结构Map集合，内键和内值键值对封装成Map集合
　　*
　　* @param outerKey       外键
　　* @param innerKeyType   内键类型
　　* @param innerValueType 值类型
　　* @return
　　*/
　　public  Map hGetMap(O outerKey, TypeReference innerKeyType, TypeReference innerValueType) {
　　Map redisMap = redisTemplate.execute
　　((RedisCallback) connection -> connection.hGetAll(JSON.toJSONBytes(outerKey)));
　　if (redisMap == null) return null;
　　Map resultMap = new HashMap();
　　redisMap.forEach((key, value) -> resultMap.put(JSONObject.parseObject
　　(new String(key), innerKeyType), JSONObject.parseObject(new String(value), innerValueType)));
　　return resultMap;
　　}
　　/**
　　* 查询Hash结构的值
　　*
　　* @param outerKey      外键
　　* @param innerKey      内键
　　* @param typeReference 值类型
　　* @return
　　*/
　　public  V hGet(O outerKey, I innerKey, TypeReference typeReference) {
　　byte[] redisResult = redisTemplate.execute((RedisCallback)
　　connection -> connection.hGet(JSON.toJSONBytes(outerKey), JSON.toJSONBytes(innerKey)));
　　if (redisResult == null) return null;
　　return JSONObject.parseObject(new String(redisResult), typeReference);
　　}
　　/**
　　* 删除键值对
　　*
　　* @param keys 键
　　* @return
　　*/
　　public  Long del(List keys) {
　　if (keys == null || keys.isEmpty()) return 0L;
　　byte[][] keyBytes = new byte[keys.size()][];
　　int index = 0;
　　for (K key : keys) {
　　keyBytes[index] = JSON.toJSONBytes(key);
　　index++;
　　}
　　return redisTemplate.execute((RedisCallback) connection -> connection.del(keyBytes));
　　}
　　/**
　　* 删除Hash结构内键和值
　　*
　　* @param outerKey  外键
　　* @param innerKeys 内键
　　* @return
　　*/
　　public  Long hDel(O outerKey, List innerKeys) {
　　if (innerKeys == null || innerKeys.isEmpty()) return 0L;
　　byte[][] innerKeyBytes = new byte[innerKeys.size()][];
　　int index = 0;
　　for (I key : innerKeys) {
　　innerKeyBytes[index] = JSON.toJSONBytes(key);
　　index++;
　　}
　　return redisTemplate.execute((RedisCallback) connection ->
　　connection.hDel(JSON.toJSONBytes(outerKey), innerKeyBytes));
　　}
　　}