프로젝트는 시기적절한 쿼리 및 검색을 용이하게 하기 위해 장치에서 수집한 최신 경도 및 위도 정보를 Redis 캐시에 저장해야 합니다. 검색 조건에 따라 문의하는 장비가 다르다는 점을 고려하여 작성합니다. 데이터는 Redis Cache에 Map 형태로 저장되며 여기에 기록됩니다.
참고: 직렬화 인터페이스를 구현해야 합니다
public class Redis implements Serializable{ private String name; private Integer age; public String getName() { return name; } public void setName(String name) { this.name = name; } public Integer getAge() { return age; } public void setAge(Integer age) { this.age = age; } }
import java.io.Serializable; public class RedisCustom extends Redis { private String stuCode; public String getStuCode() { return stuCode; } public void setStuCode(String stuCode) { this.stuCode = stuCode; } }
redisTemplate.opsForHash()
샘플 코드
@Controller @RequestMapping("/redis") public class RedisController { @Autowired private RedisTemplate redisTemplate; /** * @param * @return */ @RequestMapping(value = "/setRedisData", method = RequestMethod.GET) @ResponseBody public Map<String, Object> setRedisData() { RedisCustom redis1 = new RedisCustom(); redis1.setName("小明"); redis1.setAge(12); redis1.setStuCode("36"); RedisCustom redis2 = new RedisCustom(); redis2.setName("小红"); redis2.setAge(11); redis2.setStuCode("24"); //构造存入redis中的map Map<String, RedisCustom> redisDataMap = new HashMap<String, RedisCustom>(); redisDataMap.put(redis1.getName(), redis1); redisDataMap.put(redis2.getName(), redis2); //存入redis redisTemplate.opsForHash().putAll("redisTest",redisDataMap); //获取缓存内容 Map<String,RedisCustom> resultMap = redisTemplate.opsForHash().entries("redisTest"); //List<RedisCustom> reslutMapList = redisTemplate.opsForHash().values("redisTest"); //Set<RedisCustom> resultMapSet = redisTemplate.opsForHash().keys("redisTest"); //RedisCustom value = (RedisCustom)redisTemplate.opsForHash().get("redisTest","小明"); return ResponseData.success(resultMap); } }
Result
참조
https://www .yisu.com/article/246815.htm
객체를 바이트[]로 변환
직렬화 및 역직렬화 도구 클래스
import java.io.*; /** * 序列化及反序列化工具类 */ public class SerializeObjectTool { //序列化 public static byte[] serialize(Object obj) { ObjectOutputStream obi = null; ByteArrayOutputStream bai = null; try { bai = new ByteArrayOutputStream(); obi = new ObjectOutputStream(bai); obi.writeObject(obj); byte[] byt = bai.toByteArray(); return byt; } catch (IOException e) { e.printStackTrace(); } return null; } // 反序列化 public static Object unserizlize(byte[] byt) { ObjectInputStream oii = null; ByteArrayInputStream bis = null; bis = new ByteArrayInputStream(byt); try { oii = new ObjectInputStream(bis); Object obj = oii.readObject(); return obj; } catch (Exception e) { e.printStackTrace(); } return null; } }
샘플 코드
@Controller @RequestMapping("/redis") public class RedisController { /** * @param * @return */ @RequestMapping(value = "/setRedisData", method = RequestMethod.GET) @ResponseBody public Map<String, Object> setRedisData() { RedisCustom redis1 = new RedisCustom(); redis1.setName("小明"); redis1.setAge(12); redis1.setStuCode("36"); RedisCustom redis2 = new RedisCustom(); redis2.setName("小红"); redis2.setAge(11); redis2.setStuCode("24"); //构造存入redis中的map Map<String, RedisCustom> redisDataMap = new HashMap<String, RedisCustom>(); redisDataMap.put(redis1.getName(), redis1); redisDataMap.put(redis2.getName(), redis2); //连接redis Jedis redis = new Jedis("xx.xx.xxx.xx", 6379); redis.auth("xxxxxxxxxxx"); //存 byte[] personByte = SerializeObjectTool.serialize(redisDataMap); redis.set("redisData".getBytes(), personByte); //取 byte[] byt = redis.get("redisData".getBytes()); Object obj = SerializeObjectTool.unserizlize(byt); Map<String, RedisCustom> redisData = (Map<String, RedisCustom>) obj; return ResponseData.success(redisData); } }
위 내용은 Map 객체 유형 데이터를 저장하기 위해 Java redis를 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!