devbox
小丑西瓜9
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

springboot+mybatis-plus+redis整合_spring boot整合mybatis-plus,redis

作者：小丑西瓜9 | 2024-06-14 01:51:48

赞

踩

spring boot整合mybatis-plus,redis

1、创建springboot项目

2、在pom.xml内添加依赖

  1.     <properties>
  2.         <mybatis-plus.version>3.1.0</mybatis-plus.version>
  3.         <redisson.version>3.10.6</redisson.version>
  4.     </properties>
  1.  
  2.             <!-- 使用redisson集成分布式锁等 -->
  3.             <dependency>
  4.                 <groupId>org.redisson</groupId>
  5.                 <artifactId>redisson-spring-boot-starter</artifactId>
  6.                 <version>${redisson.version}</version>
  7.             </dependency>
  8.  
  9.             <dependency>
  10.                 <groupId>com.baomidou</groupId>
  11.                 <artifactId>mybatis-plus-boot-starter</artifactId>
  12.                 <version>${mybatis-plus.version}</version>
  13.             </dependency>

3、数据库建表

如：

  1. CREATE TABLE `tz_area` (
  2.   `area_id` bigint(20) NOT NULL AUTO_INCREMENT,
  3.   `area_name` varchar(50) DEFAULT NULL,
  4.   `parent_id` bigint(20) DEFAULT NULL,
  5.   `level` int(1) DEFAULT NULL,
  6.   PRIMARY KEY (`area_id`),
  7.   KEY `parent_id` (`parent_id`) COMMENT '上级id'
  8. ) ENGINE=InnoDB AUTO_INCREMENT=659006000001 DEFAULT CHARSET=utf8;

4、在model内创建好实体类

  1. import java.io.Serializable;
  2. import java.util.List;
  3.  
  4. import com.baomidou.mybatisplus.annotation.*;
  5.  
  6. import io.swagger.annotations.ApiModelProperty;
  7. import lombok.Data;
  8.  
  9. @Data
  10. @TableName("tz_area")
  11. public class Area implements Serializable {
  12.     private static final long serialVersionUID = -6013320537436191451L;
  13.     @TableId
  14.     @ApiModelProperty(value = "地区id",required=true)
  15.     private Long areaId;
  16.  
  17.     @ApiModelProperty(value = "地区名称",required=true)
  18.     private String areaName;
  19.  
  20.     @ApiModelProperty(value = "地区上级id",required=true)
  21.     private Long parentId;
  22.  
  23.     @ApiModelProperty(value = "地区层级",required=true)
  24.     private Integer level;
  25.  
  26.     @TableField(exist=false)
  27.     private List<Area> areas;
  28. }

5、创建dao层的接口方法

  1. import com.shop.bean.model.Area;
  2.  
  3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  4. import com.shop.common.util.PageAdapter;
  5. import org.apache.ibatis.annotations.Param;
  6.  
  7. import java.util.List;
  8.  
  9. public interface AreaMapper extends BaseMapper<Area> {
  10. }

对应dao层的方法，在mapper.xml配置sql语句

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.shop.dao.AreaMapper">
  4.     <resultMap id="BaseResultMap" type="com.yami.shop.bean.model.Area">
  5.         <!--
  6.           WARNING - @mbg.generated
  7.         -->
  8.         <id column="area_id" jdbcType="BIGINT" property="areaId"/>
  9.         <result column="area_name" jdbcType="VARCHAR" property="areaName"/>
  10.         <result column="parent_id" jdbcType="BIGINT" property="parentId"/>
  11.         <result column="level" jdbcType="INTEGER" property="level"/>
  12.     </resultMap>
  13.  
  14. </mapper>

6、配置application.yml配置文件

  1. spring:
  2.   # 环境 dev|test|prod quart定时任务
  3.   profiles:
  4.     active: dev,quartz
  5.   #文件上传设置
  6.   servlet:
  7.     multipart:
  8.       max-file-size: 100MB
  9.       max-request-size: 100MB
  10.       enabled: true
  11.   jackson:
  12.     date-format: yyyy-MM-dd HH:mm:ss
  13.     time-zone: GMT+8
  14. # mybaits-plus配置
  15. mybatis-plus:
  16.   # MyBatis Mapper所对应的XML文件位置
  17.   mapper-locations: classpath*:/mapper/*Mapper.xml
  18.   global-config:
  19.     # 关闭MP3.0自带的banner
  20.     banner: false
  21.     db-config:
  22.       # 主键类型 0:数据库ID自增 1.未定义 2.用户输入 3 id_worker 4.uuid 5.id_worker字符串表示
  23.       id-type: AUTO
  24.       #字段策略 0:"忽略判断",1:"非 NULL 判断"),2:"非空判断"
  25.       field-strategy: NOT_NULL
  26.       # 默认数据库表下划线命名
  27.       table-underline: true

7、在service层中写具体的业务

  1. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  2. import com.baomidou.mybatisplus.extension.service.IService;
  3. import com.shop.bean.model.Area;
  4.  
  5. import java.util.List;
  6. import java.util.Map;
  7.  
  8. public interface AreaService extends IService<Area> {
  9.  
  10.     /**
  11.      * 通过pid 查找地址接口
  12.      *
  13.      * @param pid 父id
  14.      * @return
  15.      */
  16.     List<Area> listByPid(Long pid);
  17.  
  18.     /**
  19.      * 通过pid 清除地址缓存
  20.      *
  21.      * @param pid
  22.      */
  23.     void removeAreaCacheByParentId(Long pid);
  24.  
  25. }
  1. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  2. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  3. import com.shop.bean.model.Area;
  4. import com.shop.dao.AreaMapper;
  5. import com.shop.service.AreaService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.cache.annotation.CacheEvict;
  8. import org.springframework.cache.annotation.Cacheable;
  9. import org.springframework.stereotype.Service;
  10.  
  11. import java.util.ArrayList;
  12. import java.util.HashMap;
  13. import java.util.List;
  14. import java.util.Map;
  15. import java.util.stream.Collectors;
  16.  
  17. @Service
  18. public class AreaServiceImpl extends ServiceImpl<AreaMapper, Area> implements AreaService {
  19.  
  20.     @Autowired
  21.     private AreaMapper areaMapper;
  22.  
  23.     @Override
  24.     @Cacheable(cacheNames = "area", key = "#pid")
  25.     public List<Area> listByPid(Long pid) {
  26.         return areaMapper.selectList(new LambdaQueryWrapper<Area>().eq(Area::getParentId, pid));
  27.     }
  28.  
  29.     @Override
  30.     @CacheEvict(cacheNames = "area", key = "#pid")
  31.     public void removeAreaCacheByParentId(Long pid) {
  32.  
  33.     }
  34. }

8、编写controller层的接口方法

  1. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  2. import com.baomidou.mybatisplus.core.metadata.IPage;
  3. import com.shop.common.util.PageParam;
  4. import com.shop.bean.model.Area;
  5. import com.shop.service.AreaService;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.http.ResponseEntity;
  8. import org.springframework.security.access.prepost.PreAuthorize;
  9. import org.springframework.web.bind.annotation.*;
  10.  
  11. import javax.validation.Valid;
  12. import java.util.List;
  13. import java.util.Map;
  14.  
  15. /**
  16.  * @author lgh on 2018/10/26.
  17.  */
  18. @RestController
  19. @RequestMapping("/admin/area")
  20. public class AreaController {
  21.  
  22.     @Autowired
  23.     private AreaService areaService;
  24.  
  25.     /**
  26.      * 分页获取
  27.      */
  28.     @GetMapping("/page")
  29.     @PreAuthorize("@pms.hasPermission('admin:area:page')")
  30.     public ResponseEntity<IPage<Area>> page(Area area,PageParam<Area> page) {
  31.         IPage<Area> sysUserPage = areaService.page(page, new LambdaQueryWrapper<Area>());
  32.         return ResponseEntity.ok(sysUserPage);
  33.     }
  34.  
  35.     /**
  36.      * 获取省市
  37.      */
  38.     @GetMapping("/list")
  39.     @PreAuthorize("@pms.hasPermission('admin:area:list')")
  40.     public ResponseEntity<List<Area>> list(Area area) {
  41.         List<Area> areas = areaService.list(new LambdaQueryWrapper<Area>()
  42.                 .like(area.getAreaName() != null, Area::getAreaName, area.getAreaName()));
  43.         return ResponseEntity.ok(areas);
  44.     }
  45.  
  46.     /**
  47.      * 通过父级id获取区域列表
  48.      */
  49.     @GetMapping("/listByPid")
  50.     public ResponseEntity<List<Area>> listByPid(Long pid) {
  51.         List<Area> list = areaService.listByPid(pid);
  52.         return ResponseEntity.ok(list);
  53.     }
  54.  
  55.     /**
  56.      * 获取信息
  57.      */
  58.     @GetMapping("/info/{id}")
  59.     @PreAuthorize("@pms.hasPermission('admin:area:info')")
  60.     public ResponseEntity<Area> info(@PathVariable("id") Long id) {
  61.         Area area = areaService.getById(id);
  62.         return ResponseEntity.ok(area);
  63.     }
  64.  
  65.     /**
  66.      * 保存
  67.      */
  68.     @PostMapping
  69.     @PreAuthorize("@pms.hasPermission('admin:area:save')")
  70.     public ResponseEntity<Void> save(@Valid @RequestBody Area area) {
  71.         if (area.getParentId() != null) {
  72.             Area parentArea = areaService.getById(area.getParentId());
  73.             area.setLevel(parentArea.getLevel() + 1);
  74.             areaService.removeAreaCacheByParentId(area.getParentId());
  75.         }
  76.         areaService.save(area);
  77.         return ResponseEntity.ok().build();
  78.     }
  79.  
  80.     /**
  81.      * 修改
  82.      */
  83.     @PutMapping
  84.     @PreAuthorize("@pms.hasPermission('admin:area:update')")
  85.     public ResponseEntity<Void> update(@Valid @RequestBody Area area) {
  86.         areaService.updateById(area);
  87.         areaService.removeAreaCacheByParentId(area.getParentId());
  88.         return ResponseEntity.ok().build();
  89.     }
  90.  
  91.     /**
  92.      * 删除
  93.      */
  94.     @DeleteMapping("/{id}")
  95.     @PreAuthorize("@pms.hasPermission('admin:area:delete')")
  96.     public ResponseEntity<Void> delete(@PathVariable Long id) {
  97.         Area area = areaService.getById(id);
  98.         areaService.removeById(id);
  99.         areaService.removeAreaCacheByParentId(area.getParentId());
  100.         return ResponseEntity.ok().build();
  101.     }
  102.  
  103. }

9、运行启动类

10、整合上Redis缓存

配置redission.yml

  1. # 单节点设置
  2. singleServerConfig:
  3.   address: redis://127.0.0.1:6379
  4.   database: 0
  5.   password: null
  6.   idleConnectionTimeout: 10000
  7.   pingTimeout: 1000
  8.   connectTimeout: 10000
  9.   timeout: 3000
  10.   retryAttempts: 3
  11.   retryInterval: 1500
  12.   reconnectionTimeout: 3000
  13.   failedAttempts: 3
  14.   clientName: null
  15.   # 发布和订阅连接的最小空闲连接数 默认1
  16.   subscriptionConnectionMinimumIdleSize: 1
  17.   # 发布和订阅连接池大小 默认50
  18.   subscriptionConnectionPoolSize: 10
  19.   # 单个连接最大订阅数量 默认5
  20.   subscriptionsPerConnection: 5
  21.   # 最小空闲连接数 默认32，现在暂时不需要那么多的线程
  22.   connectionMinimumIdleSize: 4
  23.   # connectionPoolSize 默认64，现在暂时不需要那么多的线程
  24.   connectionPoolSize: 20
  25. # 这个线程池数量被所有RTopic对象监听器，RRemoteService调用者和RExecutorService任务共同共享。
  26. threads: 0
  27. # 这个线程池数量是在一个Redisson实例内，被其创建的所有分布式数据类型和服务，以及底层客户端所一同共享的线程池里保存的线程数量。
  28. nettyThreads: 0
  29. codec:
  30.   class: com.yami.shop.common.serializer.redisson.FstCodec
  31. transportMode: NIO

编写RedisUtil工具类

  1. import java.util.List;
  2. import java.util.Map;
  3. import java.util.Set;
  4. import java.util.concurrent.TimeUnit;
  5.  
  6. import org.springframework.data.redis.core.RedisTemplate;
  7. import org.springframework.util.CollectionUtils;
  8.  
  9. public class RedisUtil {
  10.     private static RedisTemplate<String,Object> redisTemplate = SpringContextUtils.getBean("redisTemplate",RedisTemplate.class);
  11.     
  12.     //=============================common============================
  13.     /**
  14.      * 指定缓存失效时间
  15.      * @param key 键
  16.      * @param time 时间(秒)
  17.      * @return
  18.      */
  19.     public static boolean expire(String key,long time){
  20.         try {
  21.             if(time>0){
  22.                 redisTemplate.expire(key, time, TimeUnit.SECONDS);
  23.             }
  24.             return true;
  25.         } catch (Exception e) {
  26.             e.printStackTrace();
  27.             return false;
  28.         }
  29.     }
  30.  
  31.     /**
  32.      * 根据key 获取过期时间
  33.      * @param key 键 不能为null
  34.      * @return 时间(秒) 返回0代表为永久有效 失效时间为负数，说明该主键未设置失效时间（失效时间默认为-1）
  35.      */
  36.     public static long getExpire(String key){
  37.         return redisTemplate.getExpire(key,TimeUnit.SECONDS);
  38.     }
  39.  
  40.     /**
  41.      * 判断key是否存在
  42.      * @param key 键
  43.      * @return true 存在 false 不存在
  44.      */
  45.     public static boolean hasKey(String key){
  46.         try {
  47.             return redisTemplate.hasKey(key);
  48.         } catch (Exception e) {
  49.             e.printStackTrace();
  50.             return false;
  51.         }
  52.     }
  53.  
  54.     /**
  55.      * 删除缓存
  56.      * @param key 可以传一个值 或多个
  57.      */
  58.     @SuppressWarnings("unchecked")
  59.     public static void del(String ... key){
  60.         if(key!=null&&key.length>0){
  61.             if(key.length==1){
  62.                 redisTemplate.delete(key[0]);
  63.             }else{
  64.                 redisTemplate.delete(CollectionUtils.arrayToList(key));
  65.             }
  66.         }
  67.     }
  68.  
  69.     //============================String=============================
  70.     /**
  71.      * 普通缓存获取
  72.      * @param key 键
  73.      * @return 值
  74.      */
  75.     @SuppressWarnings("unchecked")
  76.     public static <T> T get(String key){
  77.         return key==null?null:(T)redisTemplate.opsForValue().get(key);
  78.     }
  79.  
  80.     /**
  81.      * 普通缓存放入
  82.      * @param key 键
  83.      * @param value 值
  84.      * @return true成功 false失败
  85.      */
  86.     public static boolean set(String key,Object value) {
  87.         try {
  88.             redisTemplate.opsForValue().set(key, value);
  89.             return true;
  90.         } catch (Exception e) {
  91.             e.printStackTrace();
  92.             return false;
  93.         }
  94.  
  95.     }
  96.  
  97.     /**
  98.      * 普通缓存放入并设置时间
  99.      * @param key 键
  100.      * @param value 值
  101.      * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
  102.      * @return true成功 false 失败
  103.      */
  104.     public static boolean set(String key,Object value,long time){
  105.         try {
  106.             if(time>0){
  107.                 redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
  108.             }else{
  109.                 set(key, value);
  110.             }
  111.             return true;
  112.         } catch (Exception e) {
  113.             e.printStackTrace();
  114.             return false;
  115.         }
  116.     }
  117.  
  118.     /**
  119.      * 递增 此时value值必须为int类型 否则报错
  120.      * @param key 键
  121.      * @param delta 要增加几(大于0)
  122.      * @return
  123.      */
  124.     public static long incr(String key, long delta){
  125.         if(delta<0){
  126.             throw new RuntimeException("递增因子必须大于0");
  127.         }
  128.         return redisTemplate.opsForValue().increment(key, delta);
  129.     }
  130.  
  131.     /**
  132.      * 递减
  133.      * @param key 键
  134.      * @param delta 要减少几(小于0)
  135.      * @return
  136.      */
  137.     public static long decr(String key, long delta){
  138.         if(delta<0){
  139.             throw new RuntimeException("递减因子必须大于0");
  140.         }
  141.         return redisTemplate.opsForValue().increment(key, -delta);
  142.     }
  143. }

在需要缓存的地方调用该工具类即可，如controller层

  1. 	@GetMapping("/captcha.jpg")
  2. 	public void login(HttpServletResponse response,String uuid) {
  3. 		//定义图形验证码的长、宽、验证码字符数、干扰元素个数  300s后过期
  4. 		SimpleCaptcha simpleCaptcha = new SimpleCaptcha(200, 50, 4, 20);
  5. 		try {
  6. 			simpleCaptcha.write(response.getOutputStream());
  7. 			RedisUtil.set(SecurityConstants.SPRING_SECURITY_RESTFUL_IMAGE_CODE+uuid, simpleCaptcha.getCode(), 300);
  8. 		} catch (IOException e) {
  9. 			e.printStackTrace();
  10. 		}
  11. 	}

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小丑西瓜9/article/detail/715780
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号