关于Redis的问题探讨:为何存放集合偏向于转String后存放而非直接存
IRedisService
import java.util.Collection; import java.util.List; ? public interface IRedisService { ? List lRange(final String key, long start, long end); ? Long rightPushAll(final String key, Collection value); ? }
RedisServiceImpl
import com.zyuan.boot.redis.IRedisService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; ? import java.util.Collection; import java.util.List; ? @Service public class RedisServiceImpl implements IRedisService { ? private static final Logger log = LoggerFactory.getLogger(RedisServiceImpl.class); ? @Autowired private RedisTemplate redisTemplate; ? @Override public List lRange(String key, long start, long end) { List result = null; try { result = redisTemplate.opsForList().range(key, start, end); } catch (Exception e) { log.error("redis range失败:" + e.getMessage()); } return result; } ? @Override public Long rightPushAll(String key, Collection value) { Long result = null; try { result = redisTemplate.opsForList().rightPushAll(key, value); } catch (Exception e) { log.error("redis push all失败:" + e.getMessage()); } return result; } ? }
ThisIsDTO:用于存入Redis中
@Data public class ThisIsDTO implements Serializable { ? private String name; ? private Integer age; ? private Long time; ? private Long iiid; ? }
测试类
import com.zyuan.boot.redis.dto.ThisIsDTO; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; ? import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; ? @SpringBootTest @RunWith(SpringRunner.class) public class RedisServiceTest { ? @Autowired private IRedisService redisService; ? @Test public void testRightPushAll() { String key = "right_push_all_01"; ListaddDTOList = getAddDTOList(); Long result = redisService.rightPushAll(key, addDTOList); System.out.println(result); } ? private List getAddDTOList() { List addDTOList = new ArrayList<>(); for (int i = 4; i <= 7; i++) { ThisIsDTO dto = new ThisIsDTO(); String name = "name" + i + i; Integer age = i*30; Long time = i*20L; dto.setName(name); dto.setAge(age); dto.setTime(time); addDTOList.add(dto); } return addDTOList; } ? }
执行testRightPushAll,通过Redis可视化工具查看是否添加成功:
先通过对象的方式来存储查出的数据
@Test public void testLRange() { String key = "right_push_all_01"; ListdtoList = redisService.lRange(key, 0, -1); System.out.println(dtoList.toString()); for (ThisIsDTO thisIsDTO : dtoList) { String name = thisIsDTO.getName(); } }
在for处打个断点,debug运行
数据确实查询成功
但是继续运行,发现报错了
看报错信息,LinkedHashMap不能转换为ThisIsDTO类型,
所以,获取到的集合,其实是 List
通过LinkedHashMap来存放数据:
@Test public void testLRange() { String key = "right_push_all_01"; List> linkedHashMapList = redisService.lRange(key, 0, -1); for (LinkedHashMap linkedHashMap : linkedHashMapList) { for (String concurrentKey : linkedHashMap.keySet()) { Object value = linkedHashMap.get(concurrentKey); System.out.println(concurrentKey + "--->" + value); } System.out.println("============="); } }
再次运行,查看控制台打印信息:
东西都正常查出来了。
同样的,通过Redis可视化工具手动创建集合,查询出来的结果也是如此,可以自行验证一下。
所以这种方式获取到的集合,将其转换为原来对象类型比较困难,因此使用fastJson将集合转为String类型,然后取出来之后直接通过fastJson直接转回去更加便捷。