缓存菜品操作

一：问题说明

用户端小程序展示的菜品数据都是通过查询数据库获得，如果用户端访问量比较大，数据库访问压力随之增大。

二：实现思路 

通过Redis来缓存菜品数据，减少数据库查询操作。

缓存逻辑分析：

  • 每个分类下的菜品保存一份缓存数据
  • 数据库中菜品数据有变更时清理缓存数据 

 三：具体的代码实现：

DishControll层（用户端）：

我们需要在dishcontrol层加入缓存处理

  1. 注入redis
  2. 构造redis的key（根据我们上面的规则，redis中的key是为dish_ + 分类的id）
  3. 查询redis中是否有这个菜品
  4. 如果有，直接返回
  5. 如果没有，请求数据库，并且把这个菜品放到redis中
package com.sky.controller.user;

import com.sky.constant.StatusConstant;
import com.sky.entity.Dish;
import com.sky.result.PageResult;
import com.sky.result.Result;
import com.sky.service.DishService;
import com.sky.vo.DishVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController("userDishController")
@RequestMapping("/user/dish")
@Api(tags = "菜品相关接口")
@Slf4j
public class DishController {
    @Autowired
    private DishService dishService;

    @Autowired
    private RedisTemplate redisTemplate;

    /**
     * 根据分类id查询菜品
     * @param categoryId
     * @return
     */
    @GetMapping("/list")
    @ApiOperation("根据分类id查询菜品")
    public Result<List<DishVO>> selectById(Long categoryId){
        log.info("根据分类id查询菜品：{}",categoryId);
        //构造redis中的key ，规则：dish_分类id
        String key = "dish_" + categoryId;
        //查询redis中是否又菜品数据
        List<DishVO> dishVOList = (List<DishVO>) redisTemplate.opsForValue().get(key);
        if(dishVOList != null|| dishVOList.size()>0){
            //如果存在，直接返回，不用查询数据库
            return Result.success(dishVOList);
        }
        Dish dish = new Dish();
        dish.setCategoryId(categoryId);
        dish.setStatus(StatusConstant.ENABLE);
        /*
        这里的dish对象的作用就是充当一个判断条件
        我们返回的是一个List<DishVO>对象，那这个对象的条件是什么呢？
        是：这个dish的分类id和这个categoryId相等，并且呢，还得是在起售的产品
         */
        List<DishVO> list = dishService.listWithFlavor(dish);
        //如果不存在，查询数据库，将查询到的数据放到redis中
        redisTemplate.opsForValue().set(key,list);
        return Result.success(list);
    }
}

 清理缓存：

上面的操作有一个很大的问题就是，如果我们修改了数据库里面的数据，怎么同步到redis中

这就涉及到这个请求缓存的操作了

我们的解决方法是在服务端DishControll层（因为客户肯定不可能修改我的数据，只有客户端可以）进行清理缓存的操作。

那这个时候又要具体分析了，什么样的方法需要清理缓存，是不是对数据库能进行修改的操作嘞

(增删改）

所以我们在dishcontroll层对这三类方法采用的方法是：

只要你对这个数据库进行了操作，我们直接把相关的缓存全部删掉

 DishControll层（服务端）：

package com.sky.controller.admin;


import com.github.pagehelper.Page;
import com.sky.dto.DishDTO;
import com.sky.dto.DishPageQueryDTO;
import com.sky.entity.Dish;
import com.sky.result.PageResult;
import com.sky.result.Result;
import com.sky.service.DishService;
import com.sky.vo.DishVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;

import java.util.ArrayList;
import java.util.List;
import java.util.Set;

@RestController("adminDishController")
@RequestMapping("/admin/dish")
@Api(tags = "菜品相关接口")
@Slf4j
public class DishController {

    @Autowired
    private DishService dishService;

    @Autowired
    private RedisTemplate redisTemplate;

    /**
     * 新增菜品操作
     * @param dishDTO
     * @return
     */
    @PostMapping
    @ApiOperation("新增菜品操作")
    public Result save(@RequestBody DishDTO dishDTO){
        log.info("新增菜品：{}",dishDTO);
        dishService.insert(dishDTO);
        //清理缓存数据
        String pattern = "dish_"+dishDTO.getCategoryId();
        cleanCache(pattern);
        return Result.success();
    }

    /**
     * 分页查询菜品
     * @param dishPageQueryDTO
     * @return
     */
    @GetMapping("/page")
    @ApiOperation("分页查询菜品操作")
    public Result<PageResult> page(DishPageQueryDTO dishPageQueryDTO){
        log.info("分页查询菜品");
        PageResult pageresult = dishService.page(dishPageQueryDTO);
        return Result.success(pageresult);
    }

    /**
     * 批量删除菜品
     * @param ids
     * @return
     */
    @DeleteMapping
    @ApiOperation("批量删除菜品")
    public Result delete(@RequestParam List<Long> ids){
        log.info("批量删除菜品：{}",ids);
        dishService.deletebatch(ids);
        //清理缓存数据
        String pattern = "dish_*";
        cleanCache(pattern);
        return Result.success();
    }


    /**
     * 根据id查询菜品
     * @param id
     * @return
     */
    @GetMapping("/{id}")
    @ApiOperation("根据id查询菜品接口")
    public Result<DishVO> selectById(@PathVariable Long id){
        log.info("根据id查询菜品：{}",id);
        DishVO dishVO = dishService.selectById(id);
        return Result.success(dishVO);
    }

    /**
     * 修改菜品
     * @param dishDTO
     * @return
     */
    @PutMapping
    @ApiOperation("修改菜品接口")
    public Result update(@RequestBody DishDTO dishDTO){
        log.info("修改菜品：{}",dishDTO);
        dishService.updateWithFlavor(dishDTO);
        //清理缓存数据
        String pattern = "dish_*";
        cleanCache(pattern);
        return Result.success();
    }

    /**
     * 菜品起售停售
     * @param status
     * @param id
     * @return
     */
    @PostMapping("/status/{status}")
    @ApiOperation("菜品起售停售")
    public Result<String> startOrStop(@PathVariable Integer status, Long id){
        dishService.startOrStop(status,id);
        //清理缓存数据
        String pattern = "dish_*";
        cleanCache(pattern);
        return Result.success();
    }

    /**
     * 清理缓存
     * @param pattern
     */
    private void cleanCache(String pattern){
        final Set keys = redisTemplate.keys(pattern);
        redisTemplate.delete(keys);
    }
}

四：Spring Cache框架：

Spring Cache 是一个框架，实现了基于注解的缓存功能，只需要简单地加一个注解，就能实现缓存功能

Spring Cache中的常用注解：

Spring Cache入门小程序：

 @EnableCaching注解：

直接加在启动类上就行。

@Slf4j
@SpringBootApplication
@EnableCaching//启动缓存注解
public class CacheDemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(CacheDemoApplication.class,args);
        log.info("项目启动成功...");
    }
}
 @CachePut注解：

（cacheput这个注解一般加在插入数据的方法上）

    @PostMapping
    @CachePut(cacheNames = "userNames",key = "#user.id")
    public User save(@RequestBody User user){
        userMapper.insert(user);
        return user;
    }

 这里的cacheNames其实就是这个缓存的名字。

key的生成：cacheNames::#user.id

我们这个使用的时候这个返回值的id，

    @Insert("insert into spring_cache_demo.user(name,age) values (#{name},#{age})")
    @Options(useGeneratedKeys = true,keyProperty = "id")
    void insert(User user);

这里需要注意的是，我们需要在mapper层中的插入方法下加入将id返回这个一个选项功能。

因为id是自增的，所以不一定要从前端传。 

@Cacheable注解：
    @GetMapping
    @Cacheable(cacheNames = "userNames",key = "#id")
    public User getById(Long id){
        User user = userMapper.getById(id);
        return user;
    }

这里的两个参数就和刚刚的@CachePut的参数一样就行。

下面是我查询了一个id为1的数据，因为id为1的数据还没放到缓存中，所以还是从数据库里面查的

 然后我查询了一个id为2的数据，控制台没有任何反应。

并且这个Cacheable注解还会把数据直接插入缓存中：

下面是我又查了一次id为1的数据。

控制台没有任何的反应

 @Cacheable 这个注解使用了一个代理对象的技术（AOP），

就是当你给controller层的方法加了这个Cacheable注解，其实这个框架就会创建一个代理对象，我们查询的数据会先被这个代理对象接收，如果这个代理对象没查到，才会交给这个方法来查。

具体的体现就是，如果这个数据在这个缓存中，就连这个select的方法都不会调用（用断点的方式可以测出）

 @CacheEvict注解：
    @DeleteMapping
    @CacheEvict(cacheNames = "userNames",key = "#id")
    public void deleteById(Long id){
        userMapper.deleteById(id);
    }

这个注解主要的作用就是帮我们清楚缓存，我们直接在发一条sql语句，同时能删除数据库中和redis中的数据。 

@CacheEvict(cacheNames = "setmealCache",allEntries = true)

如果指定这个allEntries = true，那就代表把所有的缓存都给删掉

 Spring Cache缓存套餐具体思路：

具体的实现思路如下：

  • 导入Spring Cache和Redis相关maven坐标
  • 在启动类上加入@EnableCaching注解，开启缓存注解功能
  • 在用户端接口SetmealController的 list 方法上加入@Cacheable注解
  • 在管理端接口SetmealController的 save、delete、update、startOrStop等方法上加入CacheEvict注解

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mfbz.cn/a/597574.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

k8s保持pod健康

k8s保持pod健康

存活探针 Kubemetes 可以通过存活探针 (liveness probe) 检查容器是否还在运行。可以为 pod 中的每个容器单独指定存活探针。如果探测失败&#xff0c;Kubemetes 将定期执行探针并重新启动容器。 Kubemetes 有以下三种探测容器的机制&#xff1a; HTTP GET 探针对容器的 IP 地…
阅读更多...
Day61:单调栈 739. 每日温度 496.下一个更大元素 I

Day61:单调栈 739. 每日温度 496.下一个更大元素 I

739. 每日温度 给定一个整数数组 temperatures &#xff0c;表示每天的温度&#xff0c;返回一个数组 answer &#xff0c;其中 answer[i] 是指对于第 i 天&#xff0c;下一个更高温度出现在几天后。如果气温在这之后都不会升高&#xff0c;请在该位置用 0 来代替。 示例 1: 输…
阅读更多...
发表博客之：gemm/threadblock/threadblock_swizzle.h 文件夹讲解，cutlass深入讲解

发表博客之：gemm/threadblock/threadblock_swizzle.h 文件夹讲解，cutlass深入讲解

文章目录 [发表博客之&#xff1a;gemm/threadblock/threadblock_swizzle.h 文件夹讲解&#xff0c;cutlass深入讲解](https://cyj666.blog.csdn.net/article/details/138514145)先来看一下最简单的struct GemmIdentityThreadblockSwizzle结构体 发表博客之&#xff1a;gemm/th…
阅读更多...
vue2 webpack-dev-server Unknown promise rejection reason

vue2 webpack-dev-server Unknown promise rejection reason

在vue.config.js中添加如下配置&#xff0c;重启项目即可 module.exports defineConfig({devServer: {client: {overlay: false,},} })参考
阅读更多...
探索中位数快速排序算法：高效寻找数据集的中间值

探索中位数快速排序算法：高效寻找数据集的中间值

在计算机科学领域&#xff0c;寻找数据集的中位数是一个常见而重要的问题。而快速排序算法作为一种高效的排序算法&#xff0c;可以被巧妙地利用来解决中位数查找的问题。本文将深入探讨中位数快速排序算法的原理、实现方法以及应用场景&#xff0c;带你领略这一寻找中间值的高…
阅读更多...
vue 金额组件，输入提示单位：‘千’、‘万’、‘十万’...并用‘，’三个格式化

vue 金额组件，输入提示单位：‘千’、‘万’、‘十万’...并用‘，’三个格式化

近期项目中遇到一个需求&#xff0c;金额输入框&#xff0c;输入过程中自动提示‘千’、‘万’、‘十万’、‘百万’......等单位提示&#xff0c;鼠标失去焦点后&#xff0c;并用‘,’三位隔开计数。 例如&#xff1a; 输入&#xff1a;12345.99 失去焦点&#xff1a;12,34…
阅读更多...
Vue--》从零开始打造交互体验一流的电商平台（一）

Vue--》从零开始打造交互体验一流的电商平台（一）

今天开始使用 vue3 ts 搭建一个电商项目平台&#xff0c;因为文章会将项目的每处代码的书写都会讲解到&#xff0c;所以本项目会分成好几篇文章进行讲解&#xff0c;我会在最后一篇文章中会将项目代码开源到我的github上&#xff0c;大家可以自行去进行下载运行&#xff0c;希…
阅读更多...
【Node.js工程师养成计划】之express中间件与接口规范

【Node.js工程师养成计划】之express中间件与接口规范

一、Express中间件的概念与基本应用 const express require(express)// 加一个注释&#xff0c;用以说明&#xff0c;本项目代码可以任意定制更改 const app express()const PORT process.env.PORT || 3000// // 挂载路由 // app.use(/api, router)// // 挂载统一处理服务端…
阅读更多...
【倪亲斫经典水墨云纹仲尼式】倪诗韵亲斫古琴

【倪亲斫经典水墨云纹仲尼式】倪诗韵亲斫古琴

【倪亲斫经典水墨云纹仲尼式】倪诗韵亲斫古琴 松透润&#xff0c;适合大曲文曲潇湘欸乃平沙&#xff0c;余韵悠长&#xff0c;手感极其舒适&#xff0c;久弹不疲。
阅读更多...
[Linux][网络][TCP][三][超时重传][快速重传][SACK][D-SACK][滑动窗口]详细讲解

[Linux][网络][TCP][三][超时重传][快速重传][SACK][D-SACK][滑动窗口]详细讲解

目录 1.超时重传1.什么是超时重传&#xff1f;2.超时时间是如何确定的&#xff1f; 2.快速重传3.SACK4.D-SACK1.ACK丢失2.网络延迟 5.滑动窗口0.问题抛出1.发送方的滑动窗口2.如何表示发送方的四个部分&#xff1f;3.接收方的滑动窗口4.滑动窗口的完善理解 1.超时重传 1.什么是…
阅读更多...
C++手写协程项目（协程实现线程结构体、线程调度器定义，线程挂起函数、线程切换函数、线程恢复函数、线程结束函数、线程结束判断函数，模块测试）

C++手写协程项目（协程实现线程结构体、线程调度器定义，线程挂起函数、线程切换函数、线程恢复函数、线程结束函数、线程结束判断函数，模块测试）

协程结构体定义 之前我们使用linux下协程函数实现了线程切换&#xff0c;使用的是ucontext_t结构体&#xff0c;和基于这个结构体的四个函数。现在我们要用这些工具来实现我们自己的一个线程结构体&#xff0c;并实现线程调度和线程切换、挂起。 首先我们来实现以下线程结构体…
阅读更多...
Splay 树简介

Splay 树简介

【Splay 树简介】 ● Treap 树解决平衡的办法是给每个结点加上一个随机的优先级&#xff0c;实现概率上的平衡。Splay 树直接用旋转调整树的形态&#xff0c;通过旋转改善树的平衡性。计算量小&#xff0c;效果好。 ● Splay 树的旋转主要分为“单旋”和“双旋”。 所谓“单旋”…
阅读更多...
基于52单片机的AS608指纹密码锁电路原理图+源程序+PCB实物制作

基于52单片机的AS608指纹密码锁电路原理图+源程序+PCB实物制作

目录 1、前言 2、实物图 3、PCB图 4、原理图 5、程序 资料下载地址&#xff1a;基于52单片机的AS608指纹密码锁电路原理图源程序PCB实物制作 1、前言 这是一个基于AS608STC89C52单片机的指纹识别和键盘密码锁。 里面包括程序&#xff0c;原理图&#xff0c;pcb图和实…
阅读更多...
OpenNJet：云原生技术中的创新者与实践者

OpenNJet：云原生技术中的创新者与实践者

目录 引言OpenNJet介绍OpenNJet优势1. 性能无损动态配置2. 灵活的CoPilot框架3. 支持HTTP/34. 支持国密5. 企业级应用6. 高效安全 OpenNJet 编译与安装环境准备编译环境配置配置yum源yum 安装软件包创建符号连接修改 ld.so.conf 配置 编译代码 部署 WEB SERVER配置OpenNJet部署…
阅读更多...
正点原子[第二期]Linux之ARM（MX6U）裸机篇学习笔记-13-按键实验

正点原子[第二期]Linux之ARM（MX6U）裸机篇学习笔记-13-按键实验

前言&#xff1a; 本文是根据哔哩哔哩网站上“正点原子[第二期]Linux之ARM&#xff08;MX6U&#xff09;裸机篇”视频的学习笔记&#xff0c;在这里会记录下正点原子 I.MX6ULL 开发板的配套视频教程所作的实验和学习笔记内容。本文大量引用了正点原子教学视频和链接中的内容。…
阅读更多...
FTP协议与工作原理

FTP协议与工作原理

一、FTP协议 FTP&#xff08;FileTransferProtocol&#xff09;文件传输协议&#xff1a;用于Internet上的控制文件的双向传输&#xff0c;是一个应用程序&#xff08;Application&#xff09;。基于不同的操作系统有不同的FTP应用程序&#xff0c;而所有这些应用程序都遵守同…
阅读更多...
计算机网络【应用层】邮件和DNS

计算机网络【应用层】邮件和DNS

文章目录 电子邮件DNSDNS提供的服务&#xff1a;域名分级域名解析流程DNS资源记录DNS服务器类型 电子邮件 使用SMTP协议发送邮件之前&#xff0c;需要将二进制多媒体数据编码为ASCII码SMTP一般不使用中间邮件服务器发送邮件&#xff0c;如果收件服务器没开机&#xff0c;那么会…
阅读更多...
解决jar包中没有主清单目录的问题

解决jar包中没有主清单目录的问题

文章目录 解决jar包中没有主清单目录的问题问题描述环境描述方法一 | 阿里巴巴构造器的通用解决方案方式二 | 指定MANIFEST.MF路径 解决jar包中没有主清单目录的问题 问题描述 很简单可能很多人都遇到过&#xff0c;maven项目打成jar包后执行报错&#xff1a;jar包中没有主清单…
阅读更多...
在模方中已经选好水岸线了，但是点处理瓦块的时候还是提示水岸线没选

在模方中已经选好水岸线了，但是点处理瓦块的时候还是提示水岸线没选

答&#xff1a;能部分位置不闭合&#xff0c;双击右键闭合一下&#xff0c;可以强行闭合缺口。 模方是一款针对实景三维模型的冗余碎片、水面残缺、道路不平、标牌破损、纹理拉伸模糊等共性问题研发的实景三维模型修复编辑软件。模方4.1新增自动单体化建模功能&#xff0c;支持…
阅读更多...
高情商回复（不是）

高情商回复（不是）

背景介绍 在抖音上有这样的视频&#xff0c;视频就是一张图&#xff0c;图上问了一个问题&#xff1a;饭局上&#xff0c;你去帮领导盛饭&#xff0c;领导接过后说&#xff1a;‘盛这么多&#xff0c;喂猪呢&#xff1f;’咋回&#xff1f; 底下有一个搞笑评论&#xff1a;猪可…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站