创建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

Logo
魔乐社区

魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。

更多推荐

cover

全家桶集齐！Qwen3.5四款小模型上线魔乐社区，附昇腾全套实践教程

avatar 魔乐社区

Pont - 搭建前后端之桥：高效、灵活的接口管理工具

Pont 是一款强大的数据服务层解决方案，它能够帮助开发者快速搭建前后端之间的桥梁，实现接口的高效管理和代码自动生成。无论是新手还是有经验的开发者，都能通过 Pont 轻松处理接口文档、生成类型安全的 API 代码，从而显著提升开发效率。[![Pont 工具标志](https://raw.gitcode.com/gh_mirrors/po/pont/raw/3f1b7d4bbba3fd2dda

avatar 魔乐社区
cover

魔乐社区月度精选（26年2月）

avatar 魔乐社区