Java redis使用場(chǎng)景介紹
更新時(shí)間：2022年08月25日 15:12:07 作者：青檸果
Redis是一個(gè)完全開(kāi)源、遵守 BSD 協(xié)議、簡(jiǎn)單的、高效的、分布式的、基于內(nèi)存的k-v數(shù)據(jù)庫(kù)，本篇文章帶你了解它的使用場(chǎng)景，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
1.作為緩存
1.1 為何使用
數(shù)據(jù)存儲(chǔ)在內(nèi)存中，數(shù)據(jù)查詢速度快?？梢苑?jǐn)倲?shù)據(jù)庫(kù)壓力。
1.2 什么樣的數(shù)據(jù)適合放入緩存
查詢頻率比較高，修改頻率比較低。
安全系數(shù)低的數(shù)據(jù)
1.3 使用redis作為緩存
1.3.1 未使用配置類
注意要將實(shí)體類實(shí)現(xiàn)序列化：
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "tb_dept")
public class Dept implements Serializable {
@TableId(value = "id",type = IdType.AUTO)
private Integer id;
private String name;
private String realname;
}對(duì)應(yīng)依賴：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--連接數(shù)據(jù)源-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!--mp的依賴-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.2</version>
</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>controller層對(duì)應(yīng)代碼：
@RestController
@RequestMapping("order")
public class DeptController {
@Resource
private DeptService deptService;
@GetMapping("getById/{id}")
//order/getById/1
//{}可以放多個(gè)，由下面的傳參函數(shù)對(duì)應(yīng)
//@PathVariable:獲取請(qǐng)求映射中{}的值
public Dept getById(@PathVariable Integer id){
return deptService.findById(id);
}
@GetMapping("deleteById/{id}")
public String deleteById(@PathVariable Integer id){
int i = deptService.deleteById(id);
return i>0?"刪除成功":"刪除失敗";
}
@GetMapping("insert")
public Dept insert(Dept dept){
Dept insert = deptService.insert(dept);
return insert;
}
@GetMapping("update")
public Dept update(Dept dept){
Dept update = deptService.update(dept);
return update;
}
}service層對(duì)應(yīng)代碼：
@Service
public class DeptService {
@Resource
private DeptMapper deptMapper;
//當(dāng)存儲(chǔ)的value類型為對(duì)象類型使用redisTemplate
//存儲(chǔ)的value類型為字符串。StringRedisTemplate
@Autowired
private RedisTemplate redisTemplate;
//業(yè)務(wù)代碼
public Dept findById(Integer id){
ValueOperations forValue = redisTemplate.opsForValue();
//查詢緩存
Object o = forValue.get("dept::" + id);
//緩存命中
if(o!=null){
return (Dept) o;
}
Dept dept = deptMapper.selectById(id);
if(dept!=null){
//存入緩存中
forValue.set("dept::"+id,dept,24, TimeUnit.HOURS);
}
return dept;
}
public int deleteById(Integer id){
redisTemplate.delete("dept::"+id);
int i = deptMapper.deleteById(id);
return i;
}
public Dept insert(Dept dept){
int insert = deptMapper.insert(dept);
return dept;
}
public Dept update(Dept dept){
redisTemplate.delete("dept::"+dept.getId());
int i = deptMapper.updateById(dept);
return dept;
}
}配置源：
# 配置數(shù)據(jù)源
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/mydb?serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root
#sql日志
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
#連接redis
spring.redis.host=192.168.22*.1**
spring.redis.port=6379
查看的緩存: 前部分代碼相同@before通知，后部分代碼也相同后置通知。 我們可以AOP完成緩存代碼和業(yè)務(wù)代碼分離。
spring框架它應(yīng)該也能想到。--使用注解即可完成。解析該注解。
1.3.2 使用配置類
（1）把緩存的配置類加入
@Bean
public CacheManager cacheManager(RedisConnectionFactory factory) {
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
//解決查詢緩存轉(zhuǎn)換異常的問(wèn)題
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
// 配置序列化（解決亂碼的問(wèn)題）,過(guò)期時(shí)間600秒
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
.entryTtl(Duration.ofSeconds(600)) //緩存過(guò)期10分鐘 ---- 業(yè)務(wù)需求。
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))//設(shè)置key的序列化方式
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)) //設(shè)置value的序列化
.disableCachingNullValues();
RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
.cacheDefaults(config)
.build();
return cacheManager;
(2) 使用開(kāi)啟緩存注解
（3）使用注解
//業(yè)務(wù)代碼
//使用查詢注解:cacheNames表示緩存的名稱 key:唯一標(biāo)志---dept::key
//先從緩存中查看key為（cacheNames::key）是否存在，如果存在則不會(huì)執(zhí)行方法體，如果不存在則執(zhí)行方法體并把方法的返回值存入緩存中
@Cacheable(cacheNames = {"dept"},key="#id")
public Dept findById(Integer id){
Dept dept = deptMapper.selectById(id);
return dept;
}
//先刪除緩存在執(zhí)行方法體。
@CacheEvict(cacheNames = {"dept"},key = "#id")
public int deleteById(Integer id){
int row = deptMapper.deleteById(id);
return row;
}
//這個(gè)注釋可以確保方法被執(zhí)行，同時(shí)方法的返回值也被記錄到緩存中，實(shí)現(xiàn)緩存與數(shù)據(jù)庫(kù)的同步更新。
@CachePut(cacheNames = "dept",key="#dept.id")
public Dept update(Dept dept){
int insert = deptMapper.updateById(dept);
return dept;
}2.分布式鎖
使用壓測(cè)工具測(cè)試高并發(fā)下帶來(lái)線程安全問(wèn)題
2.1 壓測(cè)工具的使用
內(nèi)部配置：
2.2 庫(kù)存項(xiàng)目
2.2.1 controller層
@RestController
@RequestMapping("bucket")
public class BucketController {
@Autowired
private BucketService bucketService;
@GetMapping("update/{productId}")
public String testUpdate(@PathVariable Integer productId){
String s = bucketService.updateById(productId);
return s;
}
}2.2.2 dao層
//此處寫(xiě)就不需要在啟動(dòng)類使用注解
@Mapper
public interface BucketMapper extends BaseMapper<Bucket> {
public Integer updateBucketById(Integer productId);
}2.2.3 entity層
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Bucket {
@TableId(value = "productId",type = IdType.AUTO)
private Integer productId;
private Integer num;
}2.2.4 service層
@Service
public class BucketService {
@Resource
private BucketMapper bucketMapper;
public String updateById(Integer productId){
//查看該商品的庫(kù)存數(shù)量
Bucket bucket = bucketMapper.selectById(productId);
if(bucket.getNum()>0){
//修改庫(kù)存每次減1
Integer integer = bucketMapper.updateBucketById(productId);
System.out.println("扣減成功！剩余庫(kù)存數(shù)："+(bucket.getNum()-1));
return "success";
}else {
System.out.println("扣減失??！庫(kù)存數(shù)不足");
return "fail";
}
}
}2.2.5 mapper
<?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.qy151wd.dao.BucketMapper">
<update id="updateBucketById" parameterType="int">
update bucket set num=num-1 where productId=#{productId}
</update>
</mapper>2.2.6 依賴
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--連接數(shù)據(jù)源-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!--mp的依賴-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.2</version>
</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>2.2.7 測(cè)試結(jié)果
我們看到同一個(gè)庫(kù)存被使用了n次。以及數(shù)據(jù)庫(kù)中庫(kù)存為負(fù)數(shù)。 線程安全問(wèn)題導(dǎo)致。
2.3 解決方案
2.3.1 使用 synchronized 或者lock鎖
對(duì)應(yīng)的service層修改為
@Service
public class BucketService {
@Resource
private BucketMapper bucketMapper;
public String updateById(Integer productId){
//加自動(dòng)鎖
synchronized (this){
//查看該商品的庫(kù)存數(shù)量
Bucket bucket = bucketMapper.selectById(productId);
if(bucket.getNum()>0){
//修改庫(kù)存每次減1
Integer integer = bucketMapper.updateBucketById(productId);
System.out.println("扣減成功！剩余庫(kù)存數(shù)："+(bucket.getNum()-1));
return "success";
}else {
System.out.println("扣減失敗！庫(kù)存數(shù)不足");
return "fail";
}
}
}
}如果搭建了項(xiàng)目集群，那么該鎖無(wú)效 。
2.3.2 使用redisTemplate
（1）使用idea開(kāi)集群項(xiàng)目
（2）使用nginx
（3）測(cè)試結(jié)果
發(fā)現(xiàn)又出現(xiàn): 重復(fù)數(shù)字以及庫(kù)存為負(fù)數(shù)。
（4）解決方法
service對(duì)應(yīng)代碼修改
@Service
public class BucketService {
@Resource
private BucketMapper bucketMapper;
@Autowired
private RedisTemplate redisTemplate;
public String updateById(Integer productId){
ValueOperations<String,String> forValue = redisTemplate.opsForValue();
Boolean flag = forValue.setIfAbsent("aaa::" + productId, "-----------------");
if(flag){
try{
//查看該商品的庫(kù)存數(shù)量
Bucket bucket = bucketMapper.selectById(productId);
if(bucket.getNum()>0){
//修改庫(kù)存每次減1
Integer integer = bucketMapper.updateBucketById(productId);
System.out.println("扣減成功！剩余庫(kù)存數(shù)："+(bucket.getNum()-1));
return "success";
}else {
System.out.println("扣減失敗！庫(kù)存數(shù)不足");
return "fail";
}
}finally {
redisTemplate.delete("aaa::"+productId);
}
}
return "服務(wù)器正忙，請(qǐng)稍后再試.......";
}
}注意此處的測(cè)壓速度不易太快（推薦使用5秒100個(gè)線程）
經(jīng)過(guò)測(cè)壓測(cè)試后，結(jié)果為：
到此這篇關(guān)于Java redis數(shù)據(jù)庫(kù)使用場(chǎng)景介紹的文章就介紹到這了,更多相關(guān)Java redis內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
相關(guān)文章
這篇文章主要介紹了基于@LastModifiedDate不起作用的解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-10-10
SpringBoot利用@Validated注解優(yōu)雅實(shí)現(xiàn)參數(shù)校驗(yàn)
在開(kāi)發(fā) Web 應(yīng)用時(shí),用戶輸入的合法性校驗(yàn)是保障系統(tǒng)穩(wěn)定性的基礎(chǔ),?Spring Boot 的 @Validated 注解 提供了一種更優(yōu)雅的解決方案,下面就跟隨小編一起學(xué)習(xí)一下吧2025-04-04
這篇文章主要介紹了java解析.yml文件方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-01-01
springboot項(xiàng)目接入第三方qq郵箱驗(yàn)證登錄的全過(guò)程
互聯(lián)網(wǎng)發(fā)展到現(xiàn)在,相必大家都知道發(fā)送郵件應(yīng)該是網(wǎng)站的必備功能之一,下面這篇文章主要給大家介紹了關(guān)于springboot項(xiàng)目接入第三方qq郵箱驗(yàn)證登錄的相關(guān)資料,文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下2024-04-04
異常處理的兩大元素：拋出異常、捕獲異常，非正常處理的兩個(gè)方法。下面這篇文章主要給大家介紹了關(guān)于JVM如何處理異常的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，需要的朋友可以參考下2019-01-01
RocketMQ消息過(guò)濾與查詢的實(shí)現(xiàn)
這篇文章主要介紹了RocketMQ消息過(guò)濾與查詢的實(shí)現(xiàn)方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07
Java中documentHelper解析xml獲取想要的數(shù)據(jù)
本文主要介紹了Java中documentHelper解析xml獲取想要的數(shù)據(jù)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02
Socket+JDBC+IO實(shí)現(xiàn)Java文件上傳下載器DEMO詳解
這篇文章主要介紹了Socket+JDBC+IO實(shí)現(xiàn)Java文件上傳下載器DEMO詳解,需要的朋友可以參考下2017-05-05
以下是對(duì)JAVA_HOME,CLASSPATH和PATH的作用進(jìn)行了詳細(xì)的分析介紹，需要的朋友可以過(guò)來(lái)參考下2013-07-07
SpringBoot啟動(dòng)后的初始化數(shù)據(jù)加載原理解析與實(shí)戰(zhàn)
本文主要圍繞?Spring?Boot?啟動(dòng)后的初始化數(shù)據(jù)加載展開(kāi),介紹了初始化任務(wù)的基本需求,包括全局配置加載、數(shù)據(jù)庫(kù)表初始化等,闡述了多種初始化加載方式,分析了它們的優(yōu)缺點(diǎn),需要的朋友可以參考下2024-11-11