Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

沙海
沙海
沙海
718
文章
2
评论
2021年3月26日12:24:34
评论
3 16925字阅读56分25秒
摘要

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类 戳一戳→ 程序员的成长之路

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

戳一戳→ 程序员的成长之路

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

程序员的成长之路

互联网/程序员/技术/资料共享 

关注

阅读本文大概需要 9.5 分钟。

作者:陈彦斌链接:cnblogs.com/chenyanbin/p/13515268.html

0. 创建 Spring Boot 项目

在线创建方式

网址:https://start.spring.io/

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

然后创建Controller、Mapper、Service包

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

1. SpringBoot整合Redis

引入Redis依赖

<!--SpringBoot与Redis整合依赖--><dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-data-redis</artifactId></dependency>

完整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>

设置Redis的Template

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

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;    }}

设置Redis连接信息

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

# 连接的那个数据库spring.redis.database=0# redis服务的ip地址spring.redis.host=192.168.199.142# redis端口号spring.redis.port=6379# redis的密码,没设置过密码,可为空spring.redis.password=12345678

Redis工具类

redisTemplate API

  1. opsForValue  -> String

  2. opsForSet  -> Set

  3. opsForHash  -> hash

  4. opsForZset  -> SortSet

  5. opsForList  -> list队列

RedisUtils.java

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

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;    }}

控制层

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

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);    }}

测试

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类2. SpringBoot整合Mybatis

添加依赖

<!--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>

完整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>

设置配置文件

application.properties

# 连接的那个数据库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

启动类上添加扫描路径

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

NbaPlayer.java(实体类)

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

NbaPlayerMapper.xml

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

<?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>

NbaPlayerMapper.java

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

NbaPlayerService.java

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

NbaPlayerServiceImpl.java

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

控制器(Controller)

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

测试

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

3. redis作为mybatis缓存

  1. 用户第一次访问的时候获取数据库的值,再次访问时直接从缓存中获取数据

  2. 设置缓存过期时间

代码演示

添加FastJSON依赖

<!--fastjson依赖--><dependency>    <groupId>com.alibaba</groupId>    <artifactId>fastjson</artifactId>    <version>1.2.73</version></dependency>

@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);    }}

注意

项目8080是对外端口(向外部暴露的端口),区别于内部进程号,查内部端口用ps -ef|grep port,查外部端口用lsof -i:port

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类4. 压测工具

上面我们已经SpringBoot整合Redis和Mybatis,但是无法知道具体QPS多少,此时我们可以使用压测工具来测压,参考:

https://www.cnblogs.com/chenyanbin/p/13332068.html

5. 资料下载

链接: 链接: https://pan.baidu.com/s/1_KBAsAcr5c2oujYrnHpTnQ  密码: id15  

<END>

扫码加入技术交流群,本周末送书

Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

推荐阅读:

数据持久化框架为什么放弃 Hibernate、JPA、Mybatis,最终选择 JDBCTemplate!

基于SpringBoot的ERP系统,自带进销存+财务+生产功能

最近面试BAT,整理一份面试资料《Java面试BATJ通关手册》,覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。

获取方式:点个「在看」,关注上面公众号并回复「面试题」领取,更多内容陆续奉上。

朕已阅 Spring Boot实战:整合Redis、MyBatis,封装RedisUtils工具类

继续阅读
weinxin
资源分享QQ群
本站是一个IT技术分享社区, 会经常分享资源和教程; 分享的时代, 请别再沉默!
沙海
匿名

发表评论

匿名网友 填写信息

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: