Redis綜合案例 - 使用redis來實現快取商品分類 - 建立Jedis工具類連線redis
2020-09-24 11:01:58
文章目錄
使用redis的流程圖：
實現快取商品分類的思維圖：
- 瀏覽器傳送請求，伺服器接收請求交給CategroySerivce類的queryAll()方法處理去查詢資料
- 首次查詢redis，如果沒有資料(json格式)，就呼叫CategoryDao去資料庫(MySQL)查詢，獲取集合List商品分類集合，然後先返回給CategorySrvice，讓其將List資料轉成json後快取進redis，同時將json資料返回給伺服器。
- 第二次起查詢，直接從redis中獲取json資料格式的商品分類，然後將json轉成List，顯示到瀏覽器上。
案例實現
1. 編寫測試類
//第一步：測試開發CategoryService
public class TestCategoryService {
@Test
public void test01() throws Exception {
//1. 建立業務類物件
CategoryService categoryService = new CategoryService();
//2. 查詢所有分類集合
List<Category> list = categoryService.queryAll();
//3. 迴圈遍歷輸出
for(Category category:list){
System.out.println(category);
}
}
}
2. 編寫商品分類的bean(Category)
public class Category {
private int cid; //編號
private String cname; //名稱
//省略setter和getter
}
3. 建立properties檔案(jedis.properties)存放鍵值對
maxTotal=50
maxIdle=15
url=localhost
port=6379
4. 建立Jedis工具類，連線redis，讀取propties檔案鍵值對設定
//使用ResourceBundle讀.propties檔案
public class JedisUtils {
//單例模式 靜態程式碼塊只執行一次，因為建立會很消耗效能
private static JedisPool pool = null;
//1. 建立一個連線池 靜態程式碼在專案中，如果被使用只會載入一次
static{
//1.1 通過ResourceBundle讀取properties檔案 jedis.properties
ResourceBundle bundle = ResourceBundle.getBundle("jedis");
//獲取引數
String maxTotal = bundle.getString("maxTotal");
String maxIdle = bundle.getString("maxIdle");
String url = bundle.getString("url");
String port = bundle.getString("port");
//1.2建立連線池
//建立連線池的設定物件
JedisPoolConfig config = new JedisPoolConfig();
//設定最大連線數
config.setMaxTotal(Integer.parseInt(maxTotal));
//設定空閒連線數
config.setMaxIdle(Integer.parseInt(maxIdle));
//2:建立連線池
pool = new JedisPool(config, url, Integer.parseInt(port));
}
//2。 對外提供一個獲取連線的方法
public static Jedis getJedis(){
return pool.getResource();
}
//3。 提供釋放資源的方法
public static void close(Jedis jedis){
if(jedis != null) {
jedis.close();
}
}
}
5. 編寫service層(CategoryService)
public class CategoryService {
//呼叫dao層查詢資料
CategoryDao dao = new CategoryDao();
//jackson 的 ObjectMapper類3 用來將資料與json格式相互轉換
ObjectMapper objectMapper = new ObjectMapper();
public List<Category> queryAll() throws IOException {
//1. 先存取redis，有資料就返回 JedisUtils 資料格式：Map<Srting,String>
// 獲取redis連線
Jedis redis = JedisUtils.getJedis();
// 查詢redis快取中的資料
String json = redis.get("categoryList");
if(json == null){//2. 如果沒有資料就查詢資料庫(MySQL)，快取到redis
System.out.println("(第一次查詢) redis中沒有資料，去查詢資料庫的資料");
List<Category> categoryList = dao.findAll();
//快取 將查詢到的list集合轉換成json資料格式，快取到redis上
//通過ObjectMapper物件，轉list資料格式轉化成json資料格式
String categoryListJson = objectMapper.writeValueAsString(categoryList);
System.out.println("查詢到的categoryList的json資料是：");
System.out.println(categoryListJson);
redis.set("categoryList",categoryListJson);
return categoryList;
}else{//json ! =null 在redis中查詢到了資料
System.out.println("非第一次查詢，資料快取到redis中，redis有資料，直接從記憶體中返回，速度快");
//將json轉成物件 參1 json資料 參2 TypeReference
List<Category> categoryList = objectMapper.readValue(json,new TypeReference<List<Category>>(){});
return categoryList;
}
}
}
6. 編寫dao層
public class CategoryDao {
public List<Category> findAll() {
//1：建立集合
List<Category> categoryList = new ArrayList<>();
//使用迴圈模擬資料，以後使用mybatis來查資料
for (int i = 0; i < 10; i++) {
categoryList.add(new Category(i,"選單名" + i));
}
return categoryList;
}
}
7. 測試TestCategoryService看邏輯是否正確
(這裡連線的redis是原生的localhost，需要開啟reids伺服器redis-server.exe，否則會報連線錯誤)
第一次查詢測試
(第一次查詢) redis中沒有資料，去查詢資料庫的資料
查詢到的categoryList的json資料是：
[{「cid」:0,「cname」:「選單名0」},{「cid」:1,「cname」:「選單名1」},{「cid」:2,「cname」:「選單名2」},{「cid」:3,「cname」:「選單名3」},{「cid」:4,「cname」:「選單名4」},{「cid」:5,「cname」:「選單名5」},{「cid」:6,「cname」:「選單名6」},{「cid」:7,「cname」:「選單名7」},{「cid」:8,「cname」:「選單名8」},{「cid」:9,「cname」:「選單名9」}]
Category{cid=0, cname=‘選單名0’}
Category{cid=1, cname=‘選單名1’}
Category{cid=2, cname=‘選單名2’}
Category{cid=3, cname=‘選單名3’}
Category{cid=4, cname=‘選單名4’}
Category{cid=5, cname=‘選單名5’}
Category{cid=6, cname=‘選單名6’}
Category{cid=7, cname=‘選單名7’}
Category{cid=8, cname=‘選單名8’}
Category{cid=9, cname=‘選單名9’}
第二次/三次查詢資料(非第一次的任意次數查詢)
非第一次查詢，資料快取到redis中，redis有資料，直接從記憶體中返回，速度快
Category{cid=0, cname=‘選單名0’}
Category{cid=1, cname=‘選單名1’}
Category{cid=2, cname=‘選單名2’}
Category{cid=3, cname=‘選單名3’}
Category{cid=4, cname=‘選單名4’}
Category{cid=5, cname=‘選單名5’}
Category{cid=6, cname=‘選單名6’}
Category{cid=7, cname=‘選單名7’}
Category{cid=8, cname=‘選單名8’}
Category{cid=9, cname=‘選單名9’}
從結果可以知道業務邏輯沒有錯誤，這時候就可以寫頁面了
8. 編寫頁面Servlet顯示(就是測試類copy修改就寫)
@WebServlet("/CategoryListServlet")
public class CategoryListServlet extends HttpServlet {
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
doGet(request,response);
}
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
//1. 建立業務類物件
CategoryService categoryService = new CategoryService();
//2. 查詢分類集合
List<Category> categoryList = categoryService.queryAll();
//3. 請求轉發
request.setAttribute("categoryList",categoryList);
request.getRequestDispatcher("categoryList.jsp").forward(request,response);
}
}
9. 過濾器，防止亂碼
//攔截所有，進行編碼設定
@WebFilter("/*")
public class EncodingFilter implements Filter {
public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain) throws ServletException, IOException {
req.setCharacterEncoding("utf-8");
resp.setContentType("text/html;charset=utf-8");
chain.doFilter(req, resp);//放行
}
}
10. 寫jsp頁面
<%-- isELIgnored="false 開啟el表示式--%>
<%@ page contentType="text/html;charset=UTF-8" language="java" isELIgnored="false" %>
<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<html>
<head>
<title>categoryList商品型別列表</title>
</head>
<body>
<c:if test="${empty categoryList}">
商品型別是空的喲
</c:if>
<c:if test="${!empty categoryList}">
<table border="1" cellpadding="0" cellspacing="0">
<thead>
<tr>
<th>編號</th>
<th>商品型別名稱</th>
</tr>
</thead>
<tbody>
<c:forEach items="${categoryList}" var="category" varStatus="vs">
<tr>
<td>${vs.count}</td>
<td>${category.cname}</td>
</tr>
</c:forEach>
</tbody>
</table>
</c:if>
</body>
</html>
11. 需要的jar包
12. 執行結果
