redis 批量导入数据
@Test public void importEs29() throws Exception { List<Dict> list=new ArrayList<>(); list.add(new Dict().setCustomerId("1").setTagIdList("hello world")); list.add(new Dict().setCustomerId("2").setTagIdList("java python")); //批量set数据 redisTemplate.executePipelined(new RedisCallback<String>() { @Override public String doInRedis(RedisConnection connection) { for (int i=0;i<list.size();i++) { Dict dict = list.get(i); connection.set(dict.getCustomerId().getBytes(),dict.getTagIdList().getBytes()); } return null; } }); Assert.assertTrue(true); }
