SpringBoot30 整合Mybatis-Plus、整合Redis、利用Ehcache和Redis分別實現二級快取
摘要：
1 環境說明
JDK: 1.8
MAVEN: 3.
SpringBoot: 2.0.4
2 SpringBoot整合Mybatis-Plus
2.1 建立SpringBoot
利用IDEA建立SpringBoot專案，引入web mysql mybatis-p...
1 環境說明
JDK: 1.8
MAVEN: 3.
SpringBoot: 2.0.4
2 SpringBoot整合Mybatis-Plus
2.1 建立SpringBoot
利用IDEA建立SpringBoot專案，引入web mysql mybatis-plus lombok devtools依賴
技巧01：SpringBoot沒有mybatis的啟動依賴，需要到maven倉庫查詢
<dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.0.1</version> </dependency>
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.example</groupId> <artifactId>spring_mybatisplus_redis</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>spring_mybatisplus_redis</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.5.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <!--<dependency>--> <!--<groupId>org.springframework.boot</groupId>--> <!--<artifactId>spring-boot-starter-data-redis</artifactId>--> <!--</dependency>--> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.0.1</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project> pom.xml
2.2 配置資料庫連線
在 application.yml中配置資料庫的連線資訊
2.3 建立實體類
根據資料表建立對應的實體類
/* Navicat SQL/">MySQL Data Transfer Source Server: mysql5.4 Source Server Version : 50540 Source Host: localhost:3306 Source Database: testdemo Target Server Type: MYSQL Target Server Version : 50540 File Encoding: 65001 Date: 2018-09-16 22:55:16 */ SET FOREIGN_KEY_CHECKS=0; -- ---------------------------- -- Table structure for `student` -- ---------------------------- DROP TABLE IF EXISTS `student`; CREATE TABLE `student` ( `id` int(50) NOT NULL AUTO_INCREMENT, `name` varchar(20) NOT NULL, `age` int(10) NOT NULL, `address` varchar(50) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=20 DEFAULT CHARSET=utf8mb4; -- ---------------------------- -- Records of student -- ---------------------------- INSERT INTO `student` VALUES ('1', 'wys', '24', '重慶'); INSERT INTO `student` VALUES ('2', '王楊帥', '24', '重慶'); INSERT INTO `student` VALUES ('3', '王楊帥', '25', '渝足'); INSERT INTO `student` VALUES ('4', '王楊帥', '25', '重慶'); INSERT INTO `student` VALUES ('5', '楊玉林', '0', '大足'); INSERT INTO `student` VALUES ('6', '楊玉林', '22', '渝足'); INSERT INTO `student` VALUES ('7', '楊玉林', '20', '重慶'); INSERT INTO `student` VALUES ('8', '楊玉林', '24', '大足'); INSERT INTO `student` VALUES ('9', 'wys', '33', '渝足'); INSERT INTO `student` VALUES ('10', '楊玉林', '24', '重慶'); INSERT INTO `student` VALUES ('11', '楊玉林', '32', '渝足'); INSERT INTO `student` VALUES ('12', '楊玉林', '24', '大足'); INSERT INTO `student` VALUES ('13', '楊玉林', '6', '重慶'); INSERT INTO `student` VALUES ('14', '三少', '24', '渝足'); INSERT INTO `student` VALUES ('15', '楊玉林', '4', '大足'); INSERT INTO `student` VALUES ('16', '楊玉林', '24', '渝足'); INSERT INTO `student` VALUES ('17', 'wys', '12', '重慶'); INSERT INTO `student` VALUES ('18', '楊玉林', '0', '渝足'); INSERT INTO `student` VALUES ('19', '楊玉林', '24', null); student.sql
2.4 建立持久層介面
技巧01：由於使用的是mybatis-plus，所以持久層介面只要繼承了BaseMapper就可以擁有簡單的CRUD功能，這一點跟SpringData JPA 很相似
2.5 啟動類配置
在啟動類上新增@MapperScan註解來掃描持久層介面，只有添加了這個註解才可以依賴注入持久層介面
2.6 測試
》依賴注入持久層介面
》呼叫mybatis-plus預設提供的方法進行CRUD操作
3 SpringBoot整合Mybatis-Plus進階
說明：在第2節中是利用mybatis-plus提供的方法進行CRUD操作，其實mybatis-plus是對mybatis的封裝，它同樣可以向mybatis那樣利用xml對映檔案來實現資料庫操作
3.1 建立mybatis配置檔案
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <settings> <!-- 列印SQL語句到控制檯 --> <setting name="logImpl" value="STDOUT_LOGGING" /> </settings> </configuration> mybatis-config.xml
3.2 建立對映檔案
技巧01：在resources目錄下建立一個xml檔案用來存放對映檔案
技巧02：在對映介面中宣告一個方法
package com.example.spring_mybatisplus_redis.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.spring_mybatisplus_redis.pojo.dataobject.Student;
/**
* @author 王楊帥
* @create 2018-09-16 22:31
* @desc
**/
public interface StudentMapper extends BaseMapper<Student> {
Student getById(Long id);
}
StudentMapper.java
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.spring_mybatisplus_redis.mapper.StudentMapper">
<select id="getById" resultType="Student">
SELECT *
FROM student
WHERE id = #{id}
</select>
</mapper>
StudentMapper.xml
3.3 配置檔案
在 application.yml 中配置mybatis配置檔案和對映檔案位置
3.4 測試效果
4 MyBatis-Plus開啟二級快取
技巧01：mybatis的以及快取預設是開啟的，二級快取預設是關閉的
技巧02：一級快取是SqlSession級別，二級快取是SqlSessionFactory級別
技巧03：從二級換粗中獲取到的資料都是快取資料的副本，從一級快取中獲取到的資料是快取資料的引用
4.1 Mybatis預設的二級快取
技巧01：直接在對映檔案中新增 <cache /> 即可開啟二級快取
技巧02：mybatis預設的二級快取是利用Map實現的
4.1.1 序列化實體類
使用二級快取時必須對實體類進行序列化
4.1.2 對映檔案修改
在對映檔案中新增 <cache />
4.1.3 利用對映器進行資料操作
技巧01：對映器 = 對映介面 + 對映檔案
說明：本案例比較簡單，直接在controller類中依賴注入對映器介面，實際開發中應該在service中進行的
4.1.4 測試效果
啟動應用後，訪問多次 /test/{id}
技巧01：第一次訪問時會從資料庫中讀取資料，後面的就會從二級快取中讀取資料
技巧02：delete、update、insert操作都會清空二級快取，前提是這三種操作對應的標籤上的 flushCache屬性值為true（預設值就是true）
4.2 利用EhCache實現二級快取
4.2.1 引入ehcache依賴
<dependency> <groupId>org.mybatis.caches</groupId> <artifactId>mybatis-ehcache</artifactId> <version>1.1.0</version> </dependency>
4.2.2 配置EhCache
<?xml version="1.0" encoding="UTF-8"?> <ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="ehcache.xsd"> <diskStore path="java.io.tmpdir/Tmp_EhCache" /> <defaultCache eternal="false" maxElementsInMemory="1000" overflowToDisk="false" diskPersistent="false" timeToIdleSeconds="0" timeToLiveSeconds="3600" memoryStoreEvictionPolicy="LRU" /> <cache name="content" maxEntriesLocalHeap="200" timeToLiveSeconds="3600"> </cache> </ehcache> ehcache.xml
4.2.3 修改對映檔案
4.2.4 測試效果
啟動應用多次訪問 /student/{id}
4.3 利用Spring Cache實現快取
待更新
4.4 利用Redis實現快取
待更新
5 SpringBoot 整合 Spring Cache
待更新
6 SpringBoot整合Redis
6.1 安裝redis伺服器
6.2 建立SpringBoot專案
引入web redis lombok devtools依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
6.3 配置redis服務資訊
spring.redis.host=127.0.0.1 spring.redis.port=6379
6.4 重寫配置RedisTemplate對應Bean的配置
主要是為了設定序列化方式
package com.example.spring_redis02.configs;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import java.net.UnknownHostException;
@Configuration
public class RedisConfiguration {
/**
* 重寫RedisTemplate的Bean
* @param redisConnectionFactory
* @return
* @throws UnknownHostException
*/
@Bean
public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
RedisTemplate<Object, Object> template = new RedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
jackson2JsonRedisSerializer.setObjectMapper(new ObjectMapper());
template.setKeySerializer(jackson2JsonRedisSerializer);
template.setValueSerializer(jackson2JsonRedisSerializer);
return template;
}
}
RedisConfiguration.java
6.5 編寫RedisTemplate工具類
技巧01：這個工具類只是為了簡化操作而言的，沒有也沒關係
package com.example.spring_redis02.utils;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
@Component
public class RedisUtil {
@Autowired
private RedisTemplate redisTemplate;
/**
* 指定快取失效時間
*
* @param key鍵
* @param time 時間(秒)
* @return
*/
public boolean expire(String key, long time) {
try {
if (time > 0) {
redisTemplate.expire(key, time, TimeUnit.SECONDS);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 根據key 獲取過期時間
*
* @param key 鍵 不能為null
* @return 時間(秒) 返回0代表為永久有效
*/
public long getExpire(String key) {
return redisTemplate.getExpire(key, TimeUnit.SECONDS);
}
/**
* 判斷key是否存在
*
* @param key 鍵
* @return true 存在 false不存在
*/
public boolean hasKey(String key) {
try {
return redisTemplate.hasKey(key);
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 刪除快取
*
* @param key 可以傳一個值 或多個
*/
@SuppressWarnings("unchecked")
public void del(String... key) {
if (key != null && key.length > 0) {
if (key.length == 1) {
redisTemplate.delete(key[0]);
} else {
redisTemplate.delete(CollectionUtils.arrayToList(key));
}
}
}
//============================String=============================
/**
* 普通快取獲取
*
* @param key 鍵
* @return 值
*/
public Object get(String key) {
return key == null ? null : redisTemplate.opsForValue().get(key);
}
/**
* 普通快取放入
*
* @param key鍵
* @param value 值
* @return true成功 false失敗
*/
public boolean set(String key, Object value) {
try {
redisTemplate.opsForValue().set(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 普通快取放入並設定時間
*
* @param key鍵
* @param value 值
* @param time時間(秒) time要大於0 如果time小於等於0 將設定無限期
* @return true成功 false 失敗
*/
public boolean set(String key, Object value, long time) {
try {
if (time > 0) {
redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
} else {
set(key, value);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 遞增
*
* @param key 鍵
* @param by要增加幾(大於0)
* @return
*/
public long incr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("遞增因子必須大於0");
}
return redisTemplate.opsForValue().increment(key, delta);
}
/**
* 遞減
*
* @param key 鍵
* @param by要減少幾(小於0)
* @return
*/
public long decr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("遞減因子必須大於0");
}
return redisTemplate.opsForValue().increment(key, -delta);
}
//================================Map=================================
/**
* HashGet
*
* @param key鍵 不能為null
* @param item 項 不能為null
* @return 值
*/
public Object hget(String key, String item) {
return redisTemplate.opsForHash().get(key, item);
}
/**
* 獲取hashKey對應的所有鍵值
*
* @param key 鍵
* @return 對應的多個鍵值
*/
public Map<Object, Object> hmget(String key) {
return redisTemplate.opsForHash().entries(key);
}
/**
* HashSet
*
* @param key 鍵
* @param map 對應多個鍵值
* @return true 成功 false 失敗
*/
public boolean hmset(String key, Map<String, Object> map) {
try {
redisTemplate.opsForHash().putAll(key, map);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* HashSet 並設定時間
*
* @param key鍵
* @param map對應多個鍵值
* @param time 時間(秒)
* @return true成功 false失敗
*/
public boolean hmset(String key, Map<String, Object> map, long time) {
try {
redisTemplate.opsForHash().putAll(key, map);
if (time > 0) {
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 向一張hash表中放入資料,如果不存在將建立
*
* @param key鍵
* @param item項
* @param value 值
* @return true 成功 false失敗
*/
public boolean hset(String key, String item, Object value) {
try {
redisTemplate.opsForHash().put(key, item, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 向一張hash表中放入資料,如果不存在將建立
*
* @param key鍵
* @param item項
* @param value 值
* @param time時間(秒)注意:如果已存在的hash表有時間,這裡將會替換原有的時間
* @return true 成功 false失敗
*/
public boolean hset(String key, String item, Object value, long time) {
try {
redisTemplate.opsForHash().put(key, item, value);
if (time > 0) {
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 刪除hash表中的值
*
* @param key鍵 不能為null
* @param item 項 可以使多個 不能為null
*/
public void hdel(String key, Object... item) {
redisTemplate.opsForHash().delete(key, item);
}
/**
* 判斷hash表中是否有該項的值
*
* @param key鍵 不能為null
* @param item 項 不能為null
* @return true 存在 false不存在
*/
public boolean hHasKey(String key, String item) {
return redisTemplate.opsForHash().hasKey(key, item);
}
/**
* hash遞增 如果不存在,就會建立一個 並把新增後的值返回
*
* @param key鍵
* @param item 項
* @param by要增加幾(大於0)
* @return
*/
public double hincr(String key, String item, double by) {
return redisTemplate.opsForHash().increment(key, item, by);
}
/**
* hash遞減
*
* @param key鍵
* @param item 項
* @param by要減少記(小於0)
* @return
*/
public double hdecr(String key, String item, double by) {
return redisTemplate.opsForHash().increment(key, item, -by);
}
//============================set=============================
/**
* 根據key獲取Set中的所有值
*
* @param key 鍵
* @return
*/
public Set<Object> sGet(String key) {
try {
return redisTemplate.opsForSet().members(key);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 根據value從一個set中查詢,是否存在
*
* @param key鍵
* @param value 值
* @return true 存在 false不存在
*/
public boolean sHasKey(String key, Object value) {
try {
return redisTemplate.opsForSet().isMember(key, value);
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將資料放入set快取
*
* @param key鍵
* @param values 值 可以是多個
* @return 成功個數
*/
public long sSet(String key, Object... values) {
try {
return redisTemplate.opsForSet().add(key, values);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 將set資料放入快取
*
* @param key鍵
* @param time時間(秒)
* @param values 值 可以是多個
* @return 成功個數
*/
public long sSetAndTime(String key, long time, Object... values) {
try {
Long count = redisTemplate.opsForSet().add(key, values);
if (time > 0) expire(key, time);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 獲取set快取的長度
*
* @param key 鍵
* @return
*/
public long sGetSetSize(String key) {
try {
return redisTemplate.opsForSet().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 移除值為value的
*
* @param key鍵
* @param values 值 可以是多個
* @return 移除的個數
*/
public long setRemove(String key, Object... values) {
try {
Long count = redisTemplate.opsForSet().remove(key, values);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
//===============================list=================================
/**
* 獲取list快取的內容
*
* @param key鍵
* @param start 開始
* @param end結束0 到 -1代表所有值
* @return
*/
public List<Object> lGet(String key, long start, long end) {
try {
return redisTemplate.opsForList().range(key, start, end);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 獲取list快取的長度
*
* @param key 鍵
* @return
*/
public long lGetListSize(String key) {
try {
return redisTemplate.opsForList().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 通過索引 獲取list中的值
*
* @param key鍵
* @param index 索引index>=0時， 0 表頭，1 第二個元素，依次類推；index<0時，-1，表尾，-2倒數第二個元素，依次類推
* @return
*/
public Object lGetIndex(String key, long index) {
try {
return redisTemplate.opsForList().index(key, index);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 將list放入快取
*
* @param key鍵
* @param value 值
* @param time時間(秒)
* @return
*/
public boolean lSet(String key, Object value) {
try {
redisTemplate.opsForList().rightPush(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將list放入快取
*
* @param key鍵
* @param value 值
* @param time時間(秒)
* @return
*/
public boolean lSet(String key, Object value, long time) {
try {
redisTemplate.opsForList().rightPush(key, value);
if (time > 0) expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將list放入快取
*
* @param key鍵
* @param value 值
* @param time時間(秒)
* @return
*/
public boolean lSet(String key, List<Object> value) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 將list放入快取
*
* @param key鍵
* @param value 值
* @param time時間(秒)
* @return
*/
public boolean lSet(String key, List<Object> value, long time) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
if (time > 0) expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 根據索引修改list中的某條資料
*
* @param key鍵
* @param index 索引
* @param value 值
* @return
*/
public boolean lUpdateIndex(String key, long index, Object value) {
try {
redisTemplate.opsForList().set(key, index, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 移除N個值為value
*
* @param key鍵
* @param count 移除多少個
* @param value 值
* @return 移除的個數
*/
public long lRemove(String key, long count, Object value) {
try {
Long remove = redisTemplate.opsForList().remove(key, count, value);
return remove;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
}
RedisUtil.java
6.6 測試效果
