這段時間一直有人問如何在redis中緩存Java中的List 集合數(shù)據(jù),其實很簡單,常用的方式有兩種:
讓客戶滿意是我們工作的目標,不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴,公司提供的服務項目有:域名注冊、網(wǎng)頁空間、營銷軟件、網(wǎng)站建設、海南網(wǎng)站維護、網(wǎng)站推廣。
1. 利用序列化,把對象序列化成二進制格式,Redis 提供了 相關(guān)API方法存儲二進制,取數(shù)據(jù)時再反序列化回來,轉(zhuǎn)換成對象。
2. 利用 Json與java對象之間可以相互轉(zhuǎn)換的方式進行存值和取值。
正面針對這兩種方法,特意寫了一個工具類,來實現(xiàn)數(shù)據(jù)的存取功能。
1. 首頁在Spring框架中配置 JedisPool 連接池對象,此對象可以創(chuàng)建 Redis的連接 Jedis對象。當然,必須導入Redis的相關(guān)Jar包。
Jedis 的Jar包如下:
commons-pool2-2.3.jar
jedis-2.9.0.jar
要用到 Json,所以還需要導入Json的Jar包:
commons-beanutils-1.8.0.jar
commons-collections-3.1.jar
commons-lang-2.5.jar
commons-logging-1.1.3.jar
ezmorph-1.0.6.jar
json-lib-2.3-jdk15.jar
在配置文件中配置JedisPool 連接池對象
<!-- Redis 連接池配置 --> <bean id="jedisPool" class="redis.clients.jedis.JedisPool" destroy-method="close"> <constructor-arg name="host" value="127.0.0.1" /> <constructor-arg name="port" value="6379" /> </bean>
2. 創(chuàng)建一個Redis的工具類RedisUtil,這個類中實現(xiàn)了上面所說的兩種方法的存取操作
package com.sgxy.util; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import net.sf.json.JSONArray; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; @Component public class RedisUtil { @Autowired JedisPool pool; // Jedis連接池 // 判斷Redis中是否存在鍵 public boolean existsKey(String key) { Jedis jedis = pool.getResource(); boolean bool; try { bool = jedis.exists(key); } finally { jedis.close(); } return bool; } // 取緩存中的二進制數(shù)據(jù),反序列化成List集合對象 @SuppressWarnings("unchecked") public <T> List<T> getObject(String key, Class<T> clazz) { Jedis jedis = pool.getResource(); // 二進制 IO 輸入流 ByteArrayInputStream is = null; ObjectInputStream ois = null; try { // 從緩存中取二進制數(shù)據(jù) byte[] b = jedis.get(key.getBytes()); is = new ByteArrayInputStream(b); ois = new ObjectInputStream(is); // 把二進制轉(zhuǎn)換成T指定類型的集合 return (List<T>) ois.readObject(); } catch (Exception e) { e.printStackTrace(); } finally { try { is.close(); ois.close(); } catch (Exception e2) { e2.printStackTrace(); } jedis.close(); } return null; } // 把對象序列化二進制格式并保證到Redis緩存中 public void saveObject(Object object, String key) { Jedis jedis = pool.getResource(); // 二進制 IO 輸出流 ByteArrayOutputStream os = null; ObjectOutputStream oos = null; try { os = new ByteArrayOutputStream(); oos = new ObjectOutputStream(os); oos.writeObject(object); // 二進制數(shù)據(jù) byte[] b = os.toByteArray(); // 存入二進制數(shù)據(jù)到Redis緩存中 jedis.set(key.getBytes(), b); } catch (Exception e) { e.printStackTrace(); } finally { try { os.close(); oos.close(); } catch (Exception e2) { e2.printStackTrace(); } jedis.close(); } } // 把List集合對象轉(zhuǎn)換成json格式保存到指定的鍵中 public void saveJsonArray(Object object, String key) { Jedis jedis = pool.getResource(); try { // 格式化成Json字符串 JSONArray array = JSONArray.fromObject(object); jedis.set(key, array.toString()); // 存入緩存 } finally { jedis.close(); } } // 通過鍵取出Json字符串并轉(zhuǎn)換成 Class<T>這個T所指定的類型 @SuppressWarnings({ "static-access", "unchecked" }) public <T> List<T> getJsonArray(String key, Class<T> clazz) { Jedis jedis = pool.getResource(); try { String str = jedis.get(key); JSONArray array = JSONArray.fromObject(str); // 把字符串轉(zhuǎn)換回集合對象 clazz是指定的類型 return (List<T>) array.toCollection(array, clazz); } finally { jedis.close(); } } }
在Java程序其他地方操作這個工具類做數(shù)據(jù)的處理:
@Controller //注解這個類為控制器 @RequestMapping("grade") //注冊訪問此控制器的URL public class GradeController { @Autowired // 從IOC容器注入業(yè)務層對象 GradeService gradeService; @Autowired JedisPool pool; @Autowired RedisUtil redisUtil; @RequestMapping("list") //注冊URL public ModelAndView list() { List<Grade> grades = null; if (redisUtil.existsKey("g")) { System.out.println("從Redis 緩存中取數(shù)據(jù).."); //調(diào)用反序列化方法取緩存的數(shù)據(jù) grades = redisUtil.getObject("g",Grade.class); //調(diào)用Json格式轉(zhuǎn)換的方法取緩存數(shù)據(jù) //grades = redisUtil.getJsonArray("gradeList", Grade.class); } else { System.out.println("從數(shù)據(jù)庫中取數(shù)據(jù),并存入緩存.."); //調(diào)用底層方法從數(shù)據(jù)庫中取數(shù)據(jù) grades = gradeService.find(); //調(diào)用序列化方法把數(shù)據(jù)緩存到Redis中 redisUtil.saveObject(grades, "g"); //調(diào)用Json格式化方法把數(shù)據(jù)緩存到Redis中 //redisUtil.saveJsonArray(grades, "gradeList"); } return new ModelAndView("gradeList", "grades", grades); } }
寫到此,希望對大家有所幫助。
以上所述是小編給大家介紹的在Java程序中運用Redis緩存對象的方法詳解整合,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對創(chuàng)新互聯(lián)網(wǎng)站的支持!
文章標題:詳解在Java程序中運用Redis緩存對象的方法
URL鏈接:http://aaarwkj.com/article40/pdeeeo.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供、定制開發(fā)、App設計、移動網(wǎng)站建設、軟件開發(fā)、企業(yè)網(wǎng)站制作
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)