Java如何用Redis存儲(chǔ)復(fù)雜json格式數(shù)據(jù)并返回給前端

 //存儲(chǔ)
 public static void setJsonString(String key, Object obj) {
 Jedis jedis = RedisConnection.getJedis();
 jedis.set(key, JSON.toJSONString(obj));
 jedis.close();
 }
 //獲取
 public static String getJsonString(String key) {
 Jedis jedis = RedisConnection.getJedis();
 String value = jedis.get(key);
 jedis.close();
 return value;
 }

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;

public class SerializeUtil {
  /*
   * 序列化
   * */
  public static byte[] serizlize(Object object){
    ObjectOutputStream oos = null;
    ByteArrayOutputStream baos = null;
    try {
      baos = new ByteArrayOutputStream();
      oos = new ObjectOutputStream(baos);
      oos.writeObject(object);
      byte[] bytes = baos.toByteArray();
      return bytes;
    } catch (Exception e) {
      e.printStackTrace();
    }finally {
      try {
        if(baos != null){
          baos.close();
        }
        if (oos != null) {
          oos.close();
        }
      } catch (Exception e2) {
        e2.printStackTrace();
      }
    }
    return null;
  }
  /*
   * 反序列化
   * */
  public static Object deserialize(byte[] bytes){
    ByteArrayInputStream bais = null;
    ObjectInputStream ois = null; 
    try{
      bais = new ByteArrayInputStream(bytes);
      ois = new ObjectInputStream(bais);
      return ois.readObject();
    }catch(Exception e){
      e.printStackTrace();
    }finally {
      try {

      } catch (Exception e2) {
        e2.printStackTrace();
      }
    }
    return null;
  }
}

 public static void setObject(String key,Object object){
    Jedis jedis = RedisConnection.getJedis();
    jedis.set(key.getBytes(), SerializeUtil.serizlize(object));
    jedis.close();
  }
  public static Object getObject(String key){
    Jedis jedis = RedisConnection.getJedis();
    byte[] bytes = jedis.get(key.getBytes());
    jedis.close();
    return SerializeUtil.deserialize(bytes);
  }

{
 "cd": [{"Condition": {...}, segs:[1,2,3]}, { }, ...]
 "rs": {"way": "休寧路", "road":[{},{},..], "segList": [{object}, {}, ...] }
}

Jedis jedis = RedisConnection.getJedis();
JSONObject res = new JSONObject(); //最終結(jié)果
//如果redis中存在,則直接從redis中取,否則計(jì)算并存儲(chǔ)至redis
if(jedis.exists(lm)) {
 String rs_value = jedis.hget(lm, "rs");
 String cd_value = jedis.hget(lm, "cd");
 res.put("cd", JSONArray.parseArray(cd_value));
 res.put("rs", JSONObject.parseObject(rs_value));
 System.out.println("redis get success");
} else {
 res = computeRes(lm);
 //更新redis
 jedis.hset(lm, "cd", res.getJSONArray("cd").toJSONString());
 jedis.hset(lm, "rs", JSON.toJSONString(res.getJSONObject("rs")));
 System.out.println("redis set success");
}
jedis.close();
 
//候選結(jié)果集轉(zhuǎn)json字符串
String jsonStr = JSON.toJSONString(res, SerializerFeature.DisableCircularReferenceDetect);
//返回給前端
System.out.println("json string: " + jsonStr);
response.setContentType("text/html;charset=utf-8"); //解決前端中文亂碼
PrintWriter out = response.getWriter();
out.print(jsonStr);