Spring Boot实战：整合Redis、MyBatis，封装RedisUtils工具类
戳一戳→ 程序员的成长之路 文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
程序员的成长之路文章源自JAVA秀-https://www.javaxiu.com/6708.html
互联网/程序员/技术/资料共享 文章源自JAVA秀-https://www.javaxiu.com/6708.html
关注文章源自JAVA秀-https://www.javaxiu.com/6708.html
阅读本文大概需要 9.5 分钟。文章源自JAVA秀-https://www.javaxiu.com/6708.html
作者：陈彦斌链接：cnblogs.com/chenyanbin/p/13515268.html
0. 创建 Spring Boot 项目文章源自JAVA秀-https://www.javaxiu.com/6708.html
在线创建方式文章源自JAVA秀-https://www.javaxiu.com/6708.html
网址：https://start.spring.io/文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
然后创建Controller、Mapper、Service包文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
1. SpringBoot整合Redis文章源自JAVA秀-https://www.javaxiu.com/6708.html
引入Redis依赖
<!--SpringBoot与Redis整合依赖--><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId></dependency>文章源自JAVA秀-https://www.javaxiu.com/6708.html
完整pom.xml
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.3.3.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.cyb</groupId> <artifactId>chenyb-mobile-redis</artifactId> <version>0.0.1-SNAPSHOT</version> <name>chenyb-mobile-redis</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> <exclusions> <exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>io.projectreactor</groupId> <artifactId>reactor-test</artifactId> <scope>test</scope> </dependency> <!--SpringBoot与Redis整合依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build></project>文章源自JAVA秀-https://www.javaxiu.com/6708.html
设置Redis的Template文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
RedisConfig.java
/** * @ClassName：RedisConfig * @Description：Redis配置类 * @Author：chenyb * @Date：2020/8/16 11:48 下午 * @Versiion：1.0 */@Configuration //当前类为配置类public class RedisConfig { @Bean //redisTemplate注入到Spring容器 public RedisTemplate<String,String> redisTemplate(RedisConnectionFactory factory){ RedisTemplate<String,String> redisTemplate=new RedisTemplate<>(); RedisSerializer<String> redisSerializer = new StringRedisSerializer(); redisTemplate.setConnectionFactory(factory); //key序列化 redisTemplate.setKeySerializer(redisSerializer); //value序列化 redisTemplate.setValueSerializer(redisSerializer); //value hashmap序列化 redisTemplate.setHashKeySerializer(redisSerializer); //key hashmap序列化 redisTemplate.setHashValueSerializer(redisSerializer); return redisTemplate; }}文章源自JAVA秀-https://www.javaxiu.com/6708.html设置Redis连接信息文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
# 连接的那个数据库spring.redis.database=0# redis服务的ip地址spring.redis.host=192.168.199.142# redis端口号spring.redis.port=6379# redis的密码，没设置过密码，可为空spring.redis.password=12345678文章源自JAVA秀-https://www.javaxiu.com/6708.html
Redis工具类
redisTemplate API
opsForValue -> String文章源自JAVA秀-https://www.javaxiu.com/6708.html
opsForSet -> Set文章源自JAVA秀-https://www.javaxiu.com/6708.html
opsForHash -> hash文章源自JAVA秀-https://www.javaxiu.com/6708.html
opsForZset -> SortSet文章源自JAVA秀-https://www.javaxiu.com/6708.html
opsForList -> list队列文章源自JAVA秀-https://www.javaxiu.com/6708.html
RedisUtils.java
文章源自JAVA秀-https://www.javaxiu.com/6708.html
package com.cyb.mobile.utils;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.*;import org.springframework.stereotype.Service;import java.io.Serializable;import java.util.List;import java.util.Set;import java.util.concurrent.TimeUnit;/** * @ClassName：RedisUtils * @Description：Redis工具类 * @Author：chenyb * @Date：2020/8/17 12:05 上午 * @Versiion：1.0 */@Servicepublic class RedisUtils { @Autowired private RedisTemplate redisTemplate; private static double size = Math.pow(2, 32); /** * 写入缓存 * * @param key * @param offset 位 8Bit=1Byte * @return */ public boolean setBit(String key, long offset, boolean isShow) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); operations.setBit(key, offset, isShow); result = true; } catch (Exception e) { e.printStackTrace(); } return result; } /** * 写入缓存 * * @param key * @param offset * @return */ public boolean getBit(String key, long offset) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); result = operations.getBit(key, offset); } catch (Exception e) { e.printStackTrace(); } return result; } /** * 写入缓存 * * @param key * @param value * @return */ public boolean set(final String key, Object value) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); operations.set(key, value); result = true; } catch (Exception e) { e.printStackTrace(); } return result; } /** * 写入缓存设置时效时间 * * @param key * @param value * @return */ public boolean set(final String key, Object value, Long expireTime) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); operations.set(key, value); redisTemplate.expire(key, expireTime, TimeUnit.SECONDS); result = true; } catch (Exception e) { e.printStackTrace(); } return result; } /** * 批量删除对应的value * * @param keys */ public void remove(final String... keys) { for (String key : keys) { remove(key); } } /** * 删除对应的value * * @param key */ public void remove(final String key) { if (exists(key)) { redisTemplate.delete(key); } } /** * 判断缓存中是否有对应的value * * @param key * @return */ public boolean exists(final String key) { return redisTemplate.hasKey(key); } /** * 读取缓存 * * @param key * @return */ public Object get(final String key) { Object result = null; ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); result = operations.get(key); return result; } /** * 哈希 添加 * * @param key * @param hashKey * @param value */ public void hmSet(String key, Object hashKey, Object value) { HashOperations<String, Object, Object> hash = redisTemplate.opsForHash(); hash.put(key, hashKey, value); } /** * 哈希获取数据 * * @param key * @param hashKey * @return */ public Object hmGet(String key, Object hashKey) { HashOperations<String, Object, Object> hash = redisTemplate.opsForHash(); return hash.get(key, hashKey); } /** * 列表添加 * * @param k * @param v */ public void lPush(String k, Object v) { ListOperations<String, Object> list = redisTemplate.opsForList(); list.rightPush(k, v); } /** * 列表获取 * * @param k * @param l * @param l1 * @return */ public List<Object> lRange(String k, long l, long l1) { ListOperations<String, Object> list = redisTemplate.opsForList(); return list.range(k, l, l1); } /** * 集合添加 * * @param key * @param value */ public void add(String key, Object value) { SetOperations<String, Object> set = redisTemplate.opsForSet(); set.add(key, value); } /** * 集合获取 * * @param key * @return */ public Set<Object> setMembers(String key) { SetOperations<String, Object> set = redisTemplate.opsForSet(); return set.members(key); } /** * 有序集合添加 * * @param key * @param value * @param scoure */ public void zAdd(String key, Object value, double scoure) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); zset.add(key, value, scoure); } /** * 有序集合获取 * * @param key * @param scoure * @param scoure1 * @return */ public Set<Object> rangeByScore(String key, double scoure, double scoure1) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); redisTemplate.opsForValue(); return zset.rangeByScore(key, scoure, scoure1); } //第一次加载的时候将数据加载到redis中 public void saveDataToRedis(String name) { double index = Math.abs(name.hashCode() % size); long indexLong = new Double(index).longValue(); boolean availableUsers = setBit("availableUsers", indexLong, true); } //第一次加载的时候将数据加载到redis中 public boolean getDataToRedis(String name) { double index = Math.abs(name.hashCode() % size); long indexLong = new Double(index).longValue(); return getBit("availableUsers", indexLong); } /** * 有序集合获取排名 * * @param key 集合名称 * @param value 值 */ public Long zRank(String key, Object value) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); return zset.rank(key,value); } /** * 有序集合获取排名 * * @param key */ public Set<ZSetOperations.TypedTuple<Object>> zRankWithScore(String key, long start,long end) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); Set<ZSetOperations.TypedTuple<Object>> ret = zset.rangeWithScores(key,start,end); return ret; } /** * 有序集合添加 * * @param key * @param value */ public Double zSetScore(String key, Object value) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); return zset.score(key,value); } /** * 有序集合添加分数 * * @param key * @param value * @param scoure */ public void incrementScore(String key, Object value, double scoure) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); zset.incrementScore(key, value, scoure); } /** * 有序集合获取排名 * * @param key */ public Set<ZSetOperations.TypedTuple<Object>> reverseZRankWithScore(String key, long start,long end) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); Set<ZSetOperations.TypedTuple<Object>> ret = zset.reverseRangeByScoreWithScores(key,start,end); return ret; } /** * 有序集合获取排名 * * @param key */ public Set<ZSetOperations.TypedTuple<Object>> reverseZRankWithRank(String key, long start, long end) { ZSetOperations<String, Object> zset = redisTemplate.opsForZSet(); Set<ZSetOperations.TypedTuple<Object>> ret = zset.reverseRangeWithScores(key, start, end); return ret; }}文章源自JAVA秀-https://www.javaxiu.com/6708.html控制层文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
RedisController.java
/** * @ClassName：TestController * @Description：Redis控制器 * @Author：chenyb * @Date：2020/8/17 12:07 上午 * @Versiion：1.0 */@RestControllerpublic class RedisController { @Autowired private RedisUtils redisUtils; @RequestMapping("setAndGet") public String test(String k,String v){ redisUtils.set(k,v); return (String) redisUtils.get(k); }}文章源自JAVA秀-https://www.javaxiu.com/6708.html测试文章源自JAVA秀-https://www.javaxiu.com/6708.html
2. SpringBoot整合Mybatis文章源自JAVA秀-https://www.javaxiu.com/6708.html
添加依赖文章源自JAVA秀-https://www.javaxiu.com/6708.html
<!--mybatis依赖--><dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.3</version></dependency><!--mysql驱动--><dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId></dependency><!--druid--><dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.23</version></dependency>文章源自JAVA秀-https://www.javaxiu.com/6708.html
完整pom.xml
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.3.3.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.cyb</groupId> <artifactId>chenyb-mobile-redis</artifactId> <version>0.0.1-SNAPSHOT</version> <name>chenyb-mobile-redis</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> <exclusions> <exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>io.projectreactor</groupId> <artifactId>reactor-test</artifactId> <scope>test</scope> </dependency> <!--SpringBoot与Redis整合依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!--mybatis依赖--> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.3</version> </dependency> <!--mysql驱动--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <!--druid--> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.23</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build></project>文章源自JAVA秀-https://www.javaxiu.com/6708.html
设置配置文件文章源自JAVA秀-https://www.javaxiu.com/6708.html
application.properties文章源自JAVA秀-https://www.javaxiu.com/6708.html
# 连接的那个数据库spring.redis.database=0# redis服务的ip地址spring.redis.host=192.168.199.142# redis端口号spring.redis.port=6379# redis的密码，没设置过密码，可为空spring.redis.password=12345678# 端口号server.port=8081# ========================数据库相关配置=====================spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverspring.datasource.url=jdbc:mysql://localhost:3306/nba?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghaispring.datasource.username=rootspring.datasource.password=root# 使用阿里巴巴druid数据源，默认使用自带spring.datasource.type=com.alibaba.druid.pool.DruidDataSource#开启控制台打印sqlmybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl# mybatis 下划线转驼峰配置，两者都可以# mybatis.configuration.mapUnderscoreToCamelCase=truemybatis.configuration.map-underscore-to-camel-case=true# 配置扫描mybatis.mapper-locations=classpath:mapper/*.xml# 实体类所在的包别名mybatis.type-aliases-package=com.cyb.mobile.domain文章源自JAVA秀-https://www.javaxiu.com/6708.html
启动类上添加扫描路径文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
NbaPlayer.java（实体类）文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
NbaPlayerMapper.xml文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
<?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.cyb.mobile.mapper.NbaPlayerMapper"> <select id="ListNbaPlayer" resultType="NbaPlayer"> SELECT * FROM nba_player </select></mapper>文章源自JAVA秀-https://www.javaxiu.com/6708.html
NbaPlayerMapper.java
文章源自JAVA秀-https://www.javaxiu.com/6708.html
NbaPlayerService.java文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
NbaPlayerServiceImpl.java文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
控制器(Controller)文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
测试文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
3. redis作为mybatis缓存文章源自JAVA秀-https://www.javaxiu.com/6708.html
用户第一次访问的时候获取数据库的值，再次访问时直接从缓存中获取数据文章源自JAVA秀-https://www.javaxiu.com/6708.html
设置缓存过期时间文章源自JAVA秀-https://www.javaxiu.com/6708.html
代码演示
添加FastJSON依赖文章源自JAVA秀-https://www.javaxiu.com/6708.html
<!--fastjson依赖--><dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.73</version></dependency>文章源自JAVA秀-https://www.javaxiu.com/6708.html
@RequestMapping("test")public Object test(){ //step1 先从redis中取 String strJson=(String) redisUtils.get("nbaPlayerCache"); if (strJson==null){ System.out.println("从db取值"); // step2如果拿不到则从DB取值 List<NbaPlayer> listNbaPlayer=nbaPlayerService.ListNbaPlayer(); // step3 DB非空情况刷新redis值 if (listNbaPlayer!=null){ redisUtils.set("nbaPlayerCache", JSON.toJSONString(listNbaPlayer)); return listNbaPlayer; } return null; }else { System.out.println("从redis缓存取值"); return JSONObject.parseArray(strJson,NbaPlayer.class); }}文章源自JAVA秀-https://www.javaxiu.com/6708.html注意文章源自JAVA秀-https://www.javaxiu.com/6708.html
项目8080是对外端口(向外部暴露的端口)，区别于内部进程号，查内部端口用ps -ef|grep port，查外部端口用lsof -i:port文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
4. 压测工具文章源自JAVA秀-https://www.javaxiu.com/6708.html
上面我们已经SpringBoot整合Redis和Mybatis，但是无法知道具体QPS多少，此时我们可以使用压测工具来测压，参考：文章源自JAVA秀-https://www.javaxiu.com/6708.html
https://www.cnblogs.com/chenyanbin/p/13332068.html文章源自JAVA秀-https://www.javaxiu.com/6708.html
5. 资料下载
链接: 链接: https://pan.baidu.com/s/1_KBAsAcr5c2oujYrnHpTnQ 密码: id15 文章源自JAVA秀-https://www.javaxiu.com/6708.html
<END>文章源自JAVA秀-https://www.javaxiu.com/6708.html
扫码加入技术交流群，本周末「送书」文章源自JAVA秀-https://www.javaxiu.com/6708.html
文章源自JAVA秀-https://www.javaxiu.com/6708.html
推荐阅读：文章源自JAVA秀-https://www.javaxiu.com/6708.html
数据持久化框架为什么放弃 Hibernate、JPA、Mybatis，最终选择 JDBCTemplate！文章源自JAVA秀-https://www.javaxiu.com/6708.html
基于SpringBoot的ERP系统，自带进销存+财务+生产功能文章源自JAVA秀-https://www.javaxiu.com/6708.html
最近面试BAT，整理一份面试资料《Java面试BATJ通关手册》，覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。
文章源自JAVA秀-https://www.javaxiu.com/6708.html
获取方式：点个「在看」，关注上面公众号并回复「面试题」领取，更多内容陆续奉上。文章源自JAVA秀-https://www.javaxiu.com/6708.html
朕已阅 
文章源自JAVA秀-https://www.javaxiu.com/6708.html
继续阅读
速蛙云 - 极致体验，强烈推荐！！！购买套餐就免费送各大视频网站会员！快速稳定、独家福利社、流媒体稳定解锁！速度快，全球上网、视频、游戏加速、独立IP均支持！基础套餐性价比很高！这里不多说，我一直正在使用，推荐购买：https://www.javaxiu.com/59919.html
资源分享QQ群
本站是JAVA秀团队的技术分享社区, 会经常分享资源和教程; 分享的时代, 请别再沉默！
评论