Java 實現Redis儲存複雜json格式資料並返回給前端
問題背景
在Java Web專案中，經常需要前端請求資料，後臺從資料庫中查詢並計算最後返回json格式資料給前端。
而每次請求都需要計算一次可能比較浪費時間，這時我們可以將計算好的結果儲存在redis中，下次請求時先判斷redis中是否已經存在，如果是則直接從redis裡取出返回，因為是在記憶體中，所以比較快。
而自己在專案中遇到的json格式資料比較複雜，下面記錄一下redis儲存物件和json格式資料的幾種方式以及遇到的問題。
儲存方式
1. 直接使用String儲存
String型別是Redis中最簡單的型別了，每個key對應一個String，我們可以直接將要儲存的物件轉換成json字串，程式碼如下：
//儲存
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;
}這裡是使用fastjson的相關函式toJSONString將物件轉換為字串進行儲存。獲取的時候直接返回json字串給前端就可以了。使用這種方式可能只能儲存簡單的json字串，對於複雜格式的可能會解析錯誤。
2. 使用物件序列化方式儲存
先將物件以位元組序列化儲存，然後再反序列化得到物件，這裡可以封裝一個序列化和反序列化的工具類：
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);
}
使用這種方式可能遇到巢狀的物件或者json陣列等不太好解決。
3. 使用hash儲存
第三種方式也是解決我問題的一種方式，由於我的json格式資料比較複雜，形如：
{
"cd": [{"Condition": {...},segs:[1,2,3]},{ },...]
"rs": {"way": "休寧路","road":[{},{},..],"segList": [{object},...] }
}
我剛開始是直接使用fastjson將其轉換為字串進行儲存，但在返回解析時發現格式不太對了。分析其原因可能是json格式太複雜，然後使用redis中hash方式將資料進行分割儲存，即cd對應一個key儲存，rs為一個key進行儲存，將這兩部分都放入一個hash中。
相應程式碼如下：
Jedis jedis = RedisConnection.getJedis();
JSONObject res = new JSONObject(); //最終結果
//如果redis中存在,則直接從redis中取,否則計算並存儲至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();
//候選結果集轉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);
我是以路名(lm)作為hash的key，首先判斷是否存在該key，不存在的話先進行計算res = computeRes(lm);，得到上述的json格式資料，然後使用hset方法將其分別作為兩個key進行儲存。注意上述cd為一個JSONArray物件，需要使用呼叫toJSONString()方法轉換成字串，而rs為一個JSONObject物件，使用的是JSON.toJSONString。
在獲取時首先分別獲取其字串形式，然後分別轉換成相應的型別JSONArray.parseArray(cd_value)和JSONObject.parseObject(rs_value)，最終包裹在一個JSONObject中。
以上這篇Java 實現Redis儲存複雜json格式資料並返回給前端就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支援我們。