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>
2.2 配置數據庫連接
在 application.yml中配置數據庫的連接信息
2.3 創建實體類
根據數據表創建對應的實體類
/* Navicat 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);
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>
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); }
<?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>
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>
4.2.3 修改映射文件
4.2.4 測試效果
啟動應用多次訪問 /student/{id}
4.3 利用Spring Cache實現緩存
4.3.1 新建一個SpringBoot項目
引入web springcache依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId>
</dependency>
4.3.2 開啟SpringCache依賴
在啟動類上利用@EnableCaching來引入SpringCache的默認配置
4.3.3 如何使用
在需要使用緩存的方法上添加相關注解就可以啦，例如
4.4.4 測試效果
啟動應用，多次訪問 /test/test01 時，只打印了一次日志，因為從第二次開始就會到SpringCache中去尋找對應的緩存數據
說明：SpringCache一般用於service層中的方法的，這里只是為了達到測試效果就直接在controller層中進行了測試
4.4 利用Redis實現緩存
注意使用Redis實現緩存時需要用到SpringCache相關技術，因為SrpingCache支持多種緩存實現
SpringBoot項目集成好SpringCache和Redis后，只需要在application.yml文件中配置 spring.cache.type=redis 就可以啦
技巧01：具體使用時在方法上添加@Cacheable等類似注解就可以啦
spring: datasource: url: jdbc:mysql://127.0.0.1/javaarchitect?characterEncoding=utf-8&useSSL=false username: root password: 182838 thymeleaf: cache: false redis: host: 127.0.0.1 port: 6379 cache: type: redis jpa: properties: hibernate: format_sql: true show_sql: true mybatis-plus: type-aliases-package: com.example.homework.pojo config-location: classpath:/mybatis-config.xml mapper-locations: classpath:xml/*Mapper.xml
5 SpringBoot 集成 Spring Cache
請參見第4.3小節
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; } }
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; } } }
6.6 測試效果
