redis封装类java_SpringBoot实战：整合Redis、mybatis，封装RedisUtils工具类等（附源码）...

深碍√TFBOYSˉ_ 2022-11-05 13:53 164阅读 0赞

创建SpringBoot项目

在线创建方式

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

![a5e75f7e2df15a25a964bd16ae38374d.png][]

然后创建Controller、Mapper、Service包

![2d1bd364ca6deb8d043c39018e6f7c60.png][]

SpringBoot整合Redis

引入Redis依赖

org.springframework.boot

spring-boot-starter-data-redis

完整pom.xml

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

org.springframework.boot

spring-boot-starter-parent

2.3.3.RELEASE

com.cyb

chenyb-mobile-redis

0.0.1-SNAPSHOT

chenyb-mobile-redis

Demo project for Spring Boot

1.8

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-test

test

org.junit.vintage

junit-vintage-engine

io.projectreactor

reactor-test

test

org.springframework.boot

spring-boot-starter-data-redis

org.springframework.boot

spring-boot-maven-plugin

设置Redis的Template

![7c7c4cf2c3184f9f87007744e575e5ae.png][]

RedisConfig.java

package com.cyb.mobile.config;

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.RedisSerializer;

import org.springframework.data.redis.serializer.StringRedisSerializer;

/\*\*

\* @ClassName：RedisConfig

\* @Description：Redis配置类

\* @Author：chenyb

\* @Date：2020/8/16 11:48 下午

\* @Versiion：1.0

\*/

@Configuration //当前类为配置类

public class RedisConfig\{

@Bean //redisTemplate注入到Spring容器

public RedisTemplate redisTemplate(RedisConnectionFactory factory)\{

RedisTemplate redisTemplate=new RedisTemplate<>();

RedisSerializer 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连接信息

![059bc8e3f9f641e00563360c2d5e2bd2.png][]

\# 连接的那个数据库

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

opsForValue ==》String

opsForSet ==》Set

opsForHash ==》hash

opsForZset ==》SortSet

opsForList ==》list队列

RedisUtils.java

![059bc8e3f9f641e00563360c2d5e2bd2.png][]

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

\*/

@Service

public 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 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 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 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 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 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 hash = redisTemplate.opsForHash();

hash.put(key, hashKey, value);

/\*\*

\* 哈希获取数据

\* @param key

\* @param hashKey

\* @return

\*/

public Object hmGet(String key, Object hashKey)\{

HashOperations hash = redisTemplate.opsForHash();

return hash.get(key, hashKey);

/\*\*

\* 列表添加

\* @param k

\* @param v

\*/

public void lPush(String k, Object v)\{

ListOperations list = redisTemplate.opsForList();

list.rightPush(k, v);

/\*\*

\* 列表获取

\* @param k

\* @param l

\* @param l1

\* @return

\*/

public List lRange(String k, long l, long l1)\{

ListOperations list = redisTemplate.opsForList();

return list.range(k, l, l1);

/\*\*

\* 集合添加

\* @param key

\* @param value

\*/

public void add(String key, Object value)\{

SetOperations set = redisTemplate.opsForSet();

set.add(key, value);

/\*\*

\* 集合获取

\* @param key

\* @return

\*/

public Set setMembers(String key)\{

SetOperations set = redisTemplate.opsForSet();

return set.members(key);

/\*\*

\* 有序集合添加

\* @param key

\* @param value

\* @param scoure

\*/

public void zAdd(String key, Object value, double scoure)\{

ZSetOperations zset = redisTemplate.opsForZSet();

zset.add(key, value, scoure);

/\*\*

\* 有序集合获取

\* @param key

\* @param scoure

\* @param scoure1

\* @return

\*/

public Set rangeByScore(String key, double scoure, double scoure1)\{

ZSetOperations 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 zset = redisTemplate.opsForZSet();

return zset.rank(key,value);

/\*\*

\* 有序集合获取排名

\* @param key

\*/

public Set> zRankWithScore(String key, long start,long end) \{

ZSetOperations zset = redisTemplate.opsForZSet();

Set> ret = zset.rangeWithScores(key,start,end);

return ret;

/\*\*

\* 有序集合添加

\* @param key

\* @param value

\*/

public Double zSetScore(String key, Object value)\{

ZSetOperations zset = redisTemplate.opsForZSet();

return zset.score(key,value);

/\*\*

\* 有序集合添加分数

\* @param key

\* @param value

\* @param scoure

\*/

public void incrementScore(String key, Object value, double scoure)\{

ZSetOperations zset = redisTemplate.opsForZSet();

zset.incrementScore(key, value, scoure);

/\*\*

\* 有序集合获取排名

\* @param key

\*/

public Set> reverseZRankWithScore(String key, long start,long end) \{

ZSetOperations zset = redisTemplate.opsForZSet();

Set> ret = zset.reverseRangeByScoreWithScores(key,start,end);

return ret;

/\*\*

\* 有序集合获取排名

\* @param key

\*/

public Set> reverseZRankWithRank(String key, long start, long end) \{

ZSetOperations zset = redisTemplate.opsForZSet();

Set> ret = zset.reverseRangeWithScores(key, start, end);

return ret;

控制层

![5bbe595385714d4ae99479cddc28e1c9.png][]

RedisController.java

package com.cyb.mobile.controller;

import com.cyb.mobile.utils.RedisUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

/\*\*

\* @ClassName：TestController

\* @Description：Redis控制器

\* @Author：chenyb

\* @Date：2020/8/17 12:07 上午

\* @Versiion：1.0

\*/

@RestController

public class RedisController\{

@Autowired

private RedisUtils redisUtils;

@RequestMapping("setAndGet")

public String test(String k,String v)\{

redisUtils.set(k,v);

return (String) redisUtils.get(k);

测试

![681f639f62d515250dd90048507d8b5e.gif][]

SpringBoot整合Mybatis

添加依赖

org.mybatis.spring.boot

mybatis-spring-boot-starter

2.1.3

mysql

mysql-connector-java

com.alibaba

druid

1.1.23

完整pom.xml

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

org.springframework.boot

spring-boot-starter-parent

2.3.3.RELEASE

com.cyb

chenyb-mobile-redis

0.0.1-SNAPSHOT

chenyb-mobile-redis

Demo project for Spring Boot

1.8

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-test

test

org.junit.vintage

junit-vintage-engine

io.projectreactor

reactor-test

test

org.springframework.boot

spring-boot-starter-data-redis

org.mybatis.spring.boot

mybatis-spring-boot-starter

2.1.3

mysql

mysql-connector-java

com.alibaba

druid

1.1.23

org.springframework.boot

spring-boot-maven-plugin

设置配置文件

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.Driver

spring.datasource.url=jdbc:mysql://localhost:3306/nba?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai

spring.datasource.username=root

spring.datasource.password=root

\# 使用阿里巴巴druid数据源，默认使用自带

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

\#开启控制台打印sql

mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

\# mybatis 下划线转驼峰配置，两者都可以

\# mybatis.configuration.mapUnderscoreToCamelCase=true

mybatis.configuration.map-underscore-to-camel-case=true

\# 配置扫描

mybatis.mapper-locations=classpath:mapper/\*.xml

\# 实体类所在的包别名

mybatis.type-aliases-package=com.cyb.mobile.domain

启动类上添加扫描路径

![77d26a7dc1da05beb7d538b70ec7a8e9.png][]

NbaPlayer.java(实体类)

![4b5141fa598c451505b51f8e749e4712.png][]

NbaPlayerMapper.xml

![98b589230c9440ec59cc0e3cf7b01a62.png][]

mapper

PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd">

SELECT \* FROM nba\_player

NbaPlayerMapper.java

![f54549dad43357a4e4f58c4eb25a5155.png][]

NbaPlayerService.java

![a50aac18ac57c914febfd7dc1375e277.png][]

NbaPlayerServiceImpl.java

![59458612ba63f97cda42954fe0add006.png][]

控制器(Controller)

![fb0f8df5b4e227d231c5489b57b0d821.png][]

测试

![4dc9cb34cb96d62efb0549bfc1ed4ab0.png][]

redis作为mybatis缓存

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

设置缓存过期时间

练手项目，学习强化，点击这里

代码演示

添加FastJSON依赖

com.alibaba

fastjson

1.2.73

@RequestMapping("test")

public Object test()\{

//step1 先从redis中取

String strJson=(String) redisUtils.get("nbaPlayerCache");

if (strJson==null)\{

System.out.println("从db取值");

// step2如果拿不到则从DB取值

List 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

![847c90e82f4d1145451f38cb4ef124ff.png][]

![5e70fe590da747d071c87cb8a21cdecb.png][]

压测工具

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

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

资料下载

链接: https://pan.baidu.com/s/1d4xwXVfA6dYHvLFxha59Kg   密码: bff7

[a5e75f7e2df15a25a964bd16ae38374d.png]: /images/20221023/d0545201238b46219e0a596269457224.png
[2d1bd364ca6deb8d043c39018e6f7c60.png]: /images/20221023/36b33d180d1847b5b20cca4df293e90d.png
[7c7c4cf2c3184f9f87007744e575e5ae.png]: /images/20221023/8be635b48c83465fb25e8c7b1e4a3fd9.png
[059bc8e3f9f641e00563360c2d5e2bd2.png]: /images/20221023/6c73398be9e441e89b612129e2213c76.png
[5bbe595385714d4ae99479cddc28e1c9.png]: /images/20221023/1acb220b4a7547a8b098c2787c7ff521.png
[681f639f62d515250dd90048507d8b5e.gif]: /images/20221023/cd30449d86984dd1a0057364550f5b89.png
[77d26a7dc1da05beb7d538b70ec7a8e9.png]: /images/20221023/72ce1580fe3249d38b98a73de7203c19.png
[4b5141fa598c451505b51f8e749e4712.png]: /images/20221023/fe2f14a3885241c4b03ec0eaea0be610.png
[98b589230c9440ec59cc0e3cf7b01a62.png]: /images/20221023/1d3eda820da94b7b89be74a543a15859.png
[f54549dad43357a4e4f58c4eb25a5155.png]: /images/20221023/04e5bb75c33a44bbb9e146dea5f4485d.png
[a50aac18ac57c914febfd7dc1375e277.png]: /images/20221023/36f4e8eddc0d44238669fa0a5b0b5821.png
[59458612ba63f97cda42954fe0add006.png]: /images/20221023/fb7259e0a88e4427853d0327eb9388ab.png
[fb0f8df5b4e227d231c5489b57b0d821.png]: /images/20221023/8a809b624b30456d852b29ce013cb634.png
[4dc9cb34cb96d62efb0549bfc1ed4ab0.png]: /images/20221023/4cc918eaa29142838d1832d2b4e10ec1.png
[847c90e82f4d1145451f38cb4ef124ff.png]: /images/20221023/3e24c1269b5b4b649bda051ae6f6dd77.png
[5e70fe590da747d071c87cb8a21cdecb.png]: /images/20221023/bf7dc7b9db474d4fb6d50442bf9605bb.png