Java 實現(xiàn)Redis存儲復雜json格式數(shù)據(jù)并返回給前端
問題背景
在Java Web項目中,經(jīng)常需要前端請求數(shù)據(jù),后臺從數(shù)據(jù)庫中查詢并計算最后返回json格式數(shù)據(jù)給前端。
而每次請求都需要計算一次可能比較浪費時間,這時我們可以將計算好的結(jié)果保存在redis中,下次請求時先判斷redis中是否已經(jīng)存在,如果是則直接從redis里取出返回,因為是在內(nèi)存中,所以比較快。
而自己在項目中遇到的json格式數(shù)據(jù)比較復雜,下面記錄一下redis存儲對象和json格式數(shù)據(jù)的幾種方式以及遇到的問題。
存儲方式
1. 直接使用String存儲
String類型是Redis中最簡單的類型了,每個key對應一個String,我們可以直接將要存儲的對象轉(zhuǎn)換成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的相關函數(shù)toJSONString將對象轉(zhuǎn)換為字符串進行存儲。獲取的時候直接返回json字符串給前端就可以了。使用這種方式可能只能存儲簡單的json字符串,對于復雜格式的可能會解析錯誤。
2. 使用對象序列化方式存儲
先將對象以字節(jié)序列化存儲,然后再反序列化得到對象,這里可以封裝一個序列化和反序列化的工具類:
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數(shù)組等不太好解決。
3. 使用hash存儲
第三種方式也是解決我問題的一種方式,由于我的json格式數(shù)據(jù)比較復雜,形如:
{
"cd": [{"Condition": {...}, segs:[1,2,3]}, { }, ...]
"rs": {"way": "休寧路", "road":[{},{},..], "segList": [{object}, {}, ...] }
}
我剛開始是直接使用fastjson將其轉(zhuǎn)換為字符串進行存儲,但在返回解析時發(fā)現(xiàn)格式不太對了。分析其原因可能是json格式太復雜,然后使用redis中hash方式將數(shù)據(jù)進行分割存儲,即cd對應一個key存儲,rs為一個key進行存儲,將這兩部分都放入一個hash中。
相應代碼如下:
Jedis jedis = RedisConnection.getJedis();
JSONObject res = new JSONObject(); //最終結(jié)果
//如果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();
//候選結(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);
我是以路名(lm)作為hash的key,首先判斷是否存在該key,不存在的話先進行計算res = computeRes(lm);,得到上述的json格式數(shù)據(jù),然后使用hset方法將其分別作為兩個key進行存儲。注意上述cd為一個JSONArray對象,需要使用調(diào)用toJSONString()方法轉(zhuǎn)換成字符串,而rs為一個JSONObject對象,使用的是JSON.toJSONString。
在獲取時首先分別獲取其字符串形式,然后分別轉(zhuǎn)換成相應的類型JSONArray.parseArray(cd_value)和JSONObject.parseObject(rs_value),最終包裹在一個JSONObject中。
以上這篇Java 實現(xiàn)Redis存儲復雜json格式數(shù)據(jù)并返回給前端就是小編分享給大家的全部內(nèi)容了,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
Spring Boot 與 Kotlin 使用Redis數(shù)據(jù)庫的配置方法
Redis是目前業(yè)界使用最廣泛的內(nèi)存數(shù)據(jù)存儲。下面通過本文給大家介紹Spring Boot 與 Kotlin 使用Redis數(shù)據(jù)庫的配置方法,感興趣的朋友一起看看吧2018-01-01
SpringBoot Admin健康檢查功能的實現(xiàn)
admin主要就是告訴運維人員,服務出現(xiàn)異常,然后進行通知(微信、郵件、短信、釘釘?shù)龋┛梢苑浅?焖偻ㄖ竭\維人員,相當報警功能,接下來通過本文給大家介紹SpringBoot Admin健康檢查的相關知識,一起看看吧2021-06-06
SpringCloud對服務內(nèi)某個client進行單獨配置的操作步驟
我們的微服務項目用的是springCloud,某個微服務接口因為數(shù)據(jù)處理量大,出現(xiàn)了接口超時的情況,我們需要單獨修改這一個feignClient的超時時間,所以本文介紹了SpringCloud對服務內(nèi)某個client進行單獨配置的操作步驟,需要的朋友可以參考下2023-10-10

