redis應用的場景

通過快取來減少對關係型資料庫的查詢次數，減輕資料庫壓力。在執行DAO類的select***(), query***()方法時，先從Redis中查詢有沒有快取資料，如果有則直接從Redis拿到結果，如果沒有再向資料庫發起查詢請求取資料。

springboot已經集成了redis快取，只需要在pom.xml中載入redis，然後通過註解即可完成配置。

首先在配置類中加上 @EnableCaching 註解

然後在DAO類加上@CacheConfig 註解

類中的對資料庫操作的函式按功能加上 @CachePut @CacheEvict @Cacheable

@CachePut 是將資料加入到redis快取中

@Cacheable 在獲取資料的時候會先查詢快取，如果快取中存在，則不執行查詢資料庫的方法，如果不存在則查詢資料庫，並加入到快取中。

@CacheEvict 一般註解到刪除資料的操作上，會將一條或多條資料從快取中刪除。

這三個方法都有value 和 key屬性。

value指的是快取的名稱，不能為空。也可以在類@CacheConfig註解上指定value，則後面的方法的註解value可省略且value值與類註解的value相同。

key是快取的鍵，預設為空，既表示使用方法的引數型別及引數值作為key。可通過key = "#p0",p0為方法的第一個引數，p1為第二個，也可直接 #引數的名字。

還有一個註解為@Caching  用於組合將多個註解註解到一個方法上。

具體程式碼：

package com.example.demo.dao;

import java.io.IOException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.LinkedList;
import java.util.List;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import org.springframework.cache.annotation.CacheConfig;
import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

import com.example.demo.entity.Diary;
import com.example.demo.entity.User;
import com.example.demo.map.DiaryMapper;
import com.example.demo.map.UserMapper;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service
@CacheConfig(cacheNames="userCache") // 本類內方法指定使用快取時，預設的名稱就是userCache
public class UserDAOImpl implements UserDAO{
	
	String resource = null;
	InputStream is = null;
	SqlSessionFactory sqlSessionFactory = null;
	SqlSession sqlSession = null;
	
	public UserDAOImpl() throws IOException {
		resource = "sqlMapConfig.xml";
		is = Resources.getResourceAsStream(resource);
		sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
		sqlSession = sqlSessionFactory.openSession();
	}
	//檢查註冊時使用者名稱是否可用
	public boolean checkUsername(String username) {
		boolean flag = true;
		UserMapper userMapper=sqlSession.getMapper(UserMapper.class);
		String name = userMapper.selectPwdByUsername(username);
		sqlSession.commit();
		if (name==username) {
			flag = true;
		}
		return flag;
	}
	//登入時密碼驗證
	@Cacheable()
	public boolean checkPass(String username,String pwd){
		boolean flag = false;
		UserMapper userMapper=sqlSession.getMapper(UserMapper.class);
		String pass = userMapper.selectPwdByUsername(username);
		System.out.println("查詢資料庫");
		sqlSession.commit();
		if(pass != null){
			if (pass.equals(pwd)) {
				flag = true;
			}
			
		}else{
			
		}
		return flag;
	}
	//註冊
	@CachePut()
	public void register(String username,String userpwd,String email,String question,String answer,String photo){
		User user = new User();
		user.setUsername(username);
		user.setPwd(userpwd);
		user.setEmail(email);
		user.setQuestion(question);
		user.setAnswer(answer);
		user.setImage(photo);
		UserMapper userMapper=sqlSession.getMapper(UserMapper.class);
		try {
			int flag = userMapper.insertUser(user);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		sqlSession.commit();

	}
	//分享
	@CachePut(key = "#P1")
	public void share(String username,String title,String content){
		String time=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Calendar.getInstance().getTime());
		System.out.println(time);
		Diary diary = new Diary();
		diary.setTitle(title);
		diary.setContent(content);
		diary.setWriteTime(time);
		//User user = new User();
		diary.setUsername(username);
		DiaryMapper diaryMapper=sqlSession.getMapper(DiaryMapper.class);
		try {
			int flag = diaryMapper.insertDiary(diary);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		sqlSession.commit();
	}

	//@Cacheable() // @Cacheable 會先查詢快取，如果快取中存在，則不執行方法
	public User selectUser(String username){
		User user = null;
		System.out.println(username);
		UserMapper userMapper=sqlSession.getMapper(UserMapper.class);
		user = userMapper.selectUser(username);
		sqlSession.commit();
		return user;
	}
	@Cacheable(key = "getMethodName()") // @Cacheable 會先查詢快取，如果快取中存在，則不執行方法
    public List<Diary> seeShare() {
		List<Diary> list = new LinkedList<Diary>();
		DiaryMapper diaryMapper = sqlSession.getMapper(DiaryMapper.class);
		list = diaryMapper.selectShare();
		sqlSession.commit();
		return list;
    }
}
 

當執行時會將資料加入到快取，在redis視覺化工具中檢視資料如下

顯示的資料就是redis存入到記憶體中的二進位制格式的資料，然後用十六進位制顯示了出來。

get一下也會顯示這些資料

注意：在快取物件是要讓物件類實現Serializable介面，將物件序列化後再儲存到記憶體中，取出來的時候redis會自動反序列化再顯示出來。