场景
SpringBoot中操作Redis的特殊操作-批量查询(通过key的集合批量查杜绝模糊搜索)、查询并解析对象list：
SpringBoot中操作Redis的特殊操作-批量查询(通过key的集合批量查杜绝模糊搜索)、查询并解析对象list_霸道流氓气质的博客-CSDN博客
在上面讲操作redis中特殊操作时，对于通过key的集合批量查询所使用的工具方法，不能实现
通用对象适配，下面进行修改。
应用场景是所有业务数据会存储在mysql数据库中，使用redis作为msyql数据库的缓存。
但是redis中有的数据不一定全覆盖mysql中的数据。
那么在redis中进行缓存时会使用mysql中某个字段作为唯一标识缓存到redis中，将唯一标识作为
redis的key，那么如何通过所有可能的key的集合在redis中批量查询所有存在的key，并将value数据
进行解析为对应的对象。
比如以下两个redis中存储的数据
适用对象1
适用对象2
注：
博客：
霸道流氓气质的博客_CSDN博客-C#,架构之路,SpringBoot领域博主
实现
1、抽离公共操作redis的方法类
package com.badao.demo.utils;
import com.alibaba.fastjson.JSON;
import com.badao.demo.constant.RedisConstants;
import com.badao.demo.entity.*;
import com.ruoyi.common.core.domain.reportmanagement.BusCarEcu;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/**
* 公共服务工具类
*/
@Component
public class CommonServiceUtils {
@Autowired
private RedisCache redisCache;
/**
* 通过所有可能的key从redis中获取存在的key
* @param allKeys
* @return
*/
public List<Map<String, Object>> getExistKeys(Set<String> allKeys) {
try {
List<Map<String, Object>> keys = redisCache.getCacheList(allKeys);
return keys;
}catch (Exception exception){
System.out.println("getExistKeys:异常:"+exception);
return new ArrayList<>();
}
}
/**
* 数据转换为实体
* @param
* @return
*/
public Stream<Object> convertToDTOs(List<Map<String, Object>> objects) {
try {
objects.removeAll(Collections.singletonList(null));
objects.forEach(car -> {
car.remove("@type");
if(car.containsKey("params")){
car.remove("params");
}
}
);
Stream<Object> objectStream = JSON.parseArray(JSON.toJSONString(objects), Object.class)
.stream();
return objectStream;
}catch (Exception exception){
System.out.println("convertToDTOs异常:"+exception.getMessage());
return Stream.of();
}
}
}一个方法是传递所有可能的key的集合，然后从redis中批量查询。
一个是将查询到的数据移除空数据，这里移除@Type和移除params完全是根据自己业务来写，
在redis中存储时会有这两个字段，所以在映射为实体时需要将其移除掉。
如果自己业务中没有这两个字段，可以不用写这块。
然后返回Object的Stream。
2、在需要调用的地方
@Autowired
private CommonServiceUtils commonServiceUtils;先引入依赖
再获取所有所有可能的key的集合
Set<String> allKeys = signalLightIdList.stream()
.map(signal -> RedisConstants.SIGNALIGHT_XHD + signal)
.collect(Collectors.toSet());
List<Map<String, Object>> cards = commonServiceUtils.getExistKeys(allKeys);
if(cards.size()>0) {
Stream<Object> dtosStream = commonServiceUtils.convertToDTOs(cards);
List<SignalrightDevsDTO> collect = dtosStream.map(dto -> {
BusSignallightControl busSignallightControl = JSONObject.toJavaObject((JSON) dto, BusSignallightControl.class);如果是映射其他对象也可以通用
Set<String> allKeys = carInfoList.stream()
.map(carInfoPO -> RedisConstants.CARD_CARD + carInfoPO.getLocationNumber())
.collect(Collectors.toSet());
List<Map<String, Object>> cards = commonServiceUtils.getExistKeys(allKeys);
if(cards.size()>0){
Stream<Object> cardDTOStream = commonServiceUtils.convertToDTOs(cards);
try {
List<CarPositionDTO> carPositionDTOList = cardDTOStream.map(cardDTO -> {
CardDTO cardDTOVO = JSONObject.toJavaObject((JSON) cardDTO, CardDTO.class);一个完整业务示例代码
public List<SignalrightDevsDTO> getSignalrightDevsDtoList(List<Long> signalLightIdList) {
Set<String> allKeys = signalLightIdList.stream()
.map(signal -> RedisConstants.SIGNALIGHT_XHD + signal)
.collect(Collectors.toSet());
List<Map<String, Object>> cards = commonServiceUtils.getExistKeys(allKeys);
if(cards.size()>0) {
Stream<Object> dtosStream = commonServiceUtils.convertToDTOs(cards);
List<SignalrightDevsDTO> collect = dtosStream.map(dto -> {
BusSignallightControl busSignallightControl = JSONObject.toJavaObject((JSON) dto, BusSignallightControl.class);
return SignalrightDevsDTO.builder()
.mineCode(mineCode)
.mineName(mineName)
.equipmentCode(busSignallightControl.getId().toString())
.equipmentName(busSignallightControl.getSignalLightName())
.signalState(busSignallightControl.getLightState())
.build();
}).collect(Collectors.toList());
return collect;
}else{
return null;
}
}示例效果
