Skip to content
/ mp-demo Public

spring boot + mybatis plus 多租户 以及各种框架整合

1 star 0 forks Branches Tags Activity
Star
Notifications You must be signed in to change notification settings

q888710631/mp-demo

BranchesTags

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

240 Commits
app
app
 
 
cover
cover
 
 
.gitignore
.gitignore
 
 
README.md
README.md
 
 
mvnw
mvnw
 
 
mvnw.cmd
mvnw.cmd
 
 
pom.xml
pom.xml
 
 

Repository files navigation

mp-demo

spring boot + mybatis plus 多租户 以及各种框架整合。

主要框架：

  1. spring boot 2.7.8 + undertow
  2. mybatis plus + pagehelper
  3. spring security + jwt
  4. openfeign
  5. kafka
  6. nacos
  7. sleuth
  8. springdoc-openapi
  9. redisson
  10. websocket

初始化sql： resource/sql/init.sql

目录：

mp-demo
├── app 主体
└── cover 存放覆盖源码的类

启动项目时错误：

java.nio.charset.MalformedInputException: Input length = 1

解决：IDEA -> Settings -> Editor -> File Encodings -> 编码改UTF-8 ，并Rebuild Project

2024.9.24

  1. 引入Grovvy执行器，封装工具类GroovyEngineUtils
package com.honyee.app.utils.grovvy;

import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

import javax.script.CompiledScript;
import java.util.HashMap;

@Slf4j
public class GroovyScriptTest {

    @SneakyThrows
    public static void main(String[] args) {
        String script = "def a = 123\n" +
                "def list = [1,2,3,4,5] \n" +
                "list.add(a)\n" +
                "println(list)";

        {
            // 方式1
            CompiledScript compile = GroovyEngineUtils.compile(script);
            Object result = GroovyEngineUtils.eval(compile, new HashMap<>());
            log.info("/// 脚本执行结果1：{}", result);
        }
        {
            // 方式2
            CompiledScript compile = GroovyEngineUtils.compile(script);
            Object result = compile.eval();
            log.info("/// 脚本执行结果2：{}", result);
        }
        {
            // 方式3
            Object result = GroovyEngineUtils.eval(script, new HashMap<>());
            log.info("/// 脚本执行结果3：{}", result);
        }
    }
}

  1. RequestWrapperFilter的body重复读取包装类更换为ContentCachingRequestWrapper

  2. Mybatis处理字段示例ListStringTypeHandler

实现org.apache.ibatis.type.BaseTypeHandler对字段处理

@Data
@TableName(value = "person")
public class Person{
    @TableId(type = IdType.AUTO)
    private Long id;

    // db中roleIds是varchar类型
    @TableField("roleIds")
    List<String> roleIds;
}
<resultMap id="test_map" type="com.honyee.app.model.test.Person">
  <id property="id" column="id"/>
  <result property="roleIds" column="roleIds" typeHandler="com.honyee.app.config.mybatis.handler.ListStringTypeHandler"/>
</resultMap>
  1. Mybatis处理字段示例bind

bind能定义变量，对参数进行加工

// Mapper接口
List<Person> findLike(@Param("name") String name);
 <select id="findLike" resultType="com.honyee.app.model.test.Person">
     <bind name="nameLike" value="'%' + name + '%'"/>
     select * from person where nickname like #{nameLike}
 </select>

2024.9.5

增加依赖JDFrame，支持像处理SQL一样处理数组

参考文档

// 待处理数据
List<Student> studentList = new ArrayList<>(); 

// 数据处理
List<FI2<String, BigDecimal>> sdf2 = SDFrame.read(studentList) // 转换成DataFrame模型
                .whereNotNull(Student::getAge)    // 过滤年龄不为null的
                .whereBetween(Student::getAge,9,16)   // 获取年龄在9到16岁之间的
                .groupBySum(Student::getSchool, Student::getScore) // 按照学校分组求和计算合计分数
                .whereGe(FI2::getC2,new BigDecimal(1000)) // 过滤合计分数大于等于1000的数据
                .sortDesc(FI2::getC2) // 按照分组后的合计分数降序排序
                .cutFirst(10)    // 截取前10名
                .toLists();     // 转换成List拿到结果

SDFrame

SDFrame就是我们的DataFrame模型了， 可通过read方法将集合、Map等数据转换为该模型进行复杂的数据处理. 具体有哪些可使用的API见下文.

FI是什么

FI类就是用于描述动态表格的列头类， 其实在各种API的结果列表我们可以经常看到FI2、FI3、FI4等对象. 这些对象就是我们的FI类。 区别就是如果矩阵有两列就会用FI2存储, 有三列就用FI3存储，FI4类比同理。 FI类里面有c1、c2、c3等字段分别表示第几列的结果, c1就表示第一列的结果, c2就表示第2列的结果, c3，c4同理

2024.6.20

增加依赖Tika

Apache Tika是一个基于Java的内容检测和分析工具包，主要用于从各种类型的文档中提取内容和元数据。它的主要功能包括：

  • 文档类型检测：Tika能够自动识别文件的类型，例如Word、Excel、PDF、PPT等。
  • 内容提取：它可以从支持的文件类型中提取结构化的文本内容。
  • 元数据提取：Tika可以提取文件的元数据信息，如作者、标题、创建日期等。
  • 语言检测：Tika能够检测文件中的语言
import org.apache.tika.Tika;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;

public class TestService{
   public static void main(String[] args) {
      File file = new File("图片路径");
      try (FileInputStream fis = new FileInputStream(file)) {
         Tika tika = new Tika();
         String detectedType = tika.detect(fis);
         System.out.println("图片类型： " + detectedType);
      } catch (IOException e) {
         e.printStackTrace();
      }
   }
}

2023.10.30

日志工具类LogUtil增加方法日志存储到redis

public class TestService{
   public void test(HttpServletResponse response){
      LogUtil.logToRedis("key", "日志内容:{}", "占位内容填充");
   }
}

2023.8.8

OSS：支持阿里云OSS和腾讯COS

通过application.oss.enable控制，值为alipay或者tencent

对应controller： FileController

2023.5.12

使用Easy-Excel封装工具类

com.honyee.app.utils.ExcelUtil

  • 针对常用的情况（仅需要输出一个sheet的情况）
public class TestService{
    public void test(HttpServletResponse response){
       // 省略list的数据填充 
       List<MyDataDTO> excelDTOList = new ArrayList<>();
       String fileName = ExcelUtil.buildFileName("我新建的Excel");
       // 输出excel
       ExcelUtil.write(response, fileName, excelDTOList, MyDataDTO.class);
    }
}
  • 针对分页查询
import java.util.ArrayList;

public class TestService {
   public void test(HttpServletResponse response) {
      String fileName = ExcelUtil.buildFileName("我新建的Excel");
      // 输出excel
      ExcelUtil.write(response, fileName, MyDataDTO.class,
              (page, pageSize) -> {
                 // 根据分页参数返回数据List，数据为空则终止
                 // 如果DTO实现ExcelUtil.ColumnIndex接口，会自动填充index
                 return new ArrayList<>();
              });
   }
}

2023.5.10

Mybatis的AbstractJsonTypeHandler的实现类

  1. MybatisJsonTypeEntityHandler用于处理对象字段，可以直接使用
  2. 如需处理List之类的结构，需要继承MybatisJsonTypeEntityHandler并传入泛型
public class ListRoleHandler extends MybatisJsonTypeEntityHandler<List<Role>> {

    public ListRoleHandler(Class<List<Role>> type) {
        super(type, new TypeReference<>() {});
    }
}
  1. 输出的json默认携带@class标注对象类型，也可以如下自定义子类
/**
 * 父类
 */
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, visible = true)
@JsonSubTypes({
        @JsonSubTypes.Type(value = RoleChild.class, name = "role-child"),
})
public class Role{
    
}
/**
 * 子类
 */
public class RoleChild extends Role{
}
/**
 * 指定处理List<Role>
 */
public class ListRoleHandler extends MybatisJsonTypeListHandler<Role>{
    
}
/**
 * 设置autoResultMap = true
 */
@TableName(value = "person", autoResultMap = true)
public class Person {
   /**
    * 字段类型为 varchar
    */
   @TableField(value = "role_list", typeHandler = ListRoleHandler.class)
   private List<Role> roleList;

   /**
    * 字段类型为 varchar
    */
   @TableField(value = "role", typeHandler = MybatisJsonTypeEntityHandler.class)
   private Role role;
}

role示例：

{"@type":"human-child","name":"ccc"}

role_list示例：

["java.util.ArrayList",[{"@type":"human-child","name":"ccc"}]]

2023.5.9

调整日期类序列化格式

  1. Request入参，支持ISO 8601（2023-05-09T12:15:30.00Z），yyyy-MM-dd HH:mm:ss，1683613823128（13位），1683613823（10位）
  2. ObjectMapper转json，格式yyyy-MM-dd HH:mm:ss
  3. @Cacheable序列化和反序列化，格式yyyy-MM-dd HH:mm:ss

2023.5.8

新增限流注解@RateLimit

限流模式：

  1. 强力模式：成功锁定后不解锁，等待时间自动解锁
  2. 通用限流：使用漏桶模式
  3. ip限流：使用漏桶模式
@RestController
@RequestMapping("/api/test")
public class TestController {
    
    @RateLimit
    @PostMapping
    public ResponseEntity<?> test() {
        return ResponseEntity.ok(new HashMap<>());
    }

}

2023.5.5

通过Nacos增强飞书日志通知功能

Nacos中增加如下配置，可用于过滤（String.contains）不需要的日志通知

例如有日志：

  1. 校验错误：身份证格式不正确
  2. 校验错误：手机号格式不正确
  3. ...

在nacos配置文件（对应配置类NacosCustomProperties）中：

feishu-log-filter:
  - 校验错误

2023.4.24

新增json工具类JsonUtil.merge用于合并json对象

参考JsonTests

2023.4.23

新增日志异步输出到飞书功能FeiShuAlertAppender

application:
  feishu:
    # 飞书机器人使能
    enable:
      log-notify: true
    # 飞书机器人hook
    group:
      log-notify: 飞书机器人的hook

通知示例：

异常告警-ERROR
告警环境： dev,exclude,kafka-single,websocket
应用名称： honyee
出现时间： 2023-04-23 13:42:13
traceId： dca8a04bfdc376e4
spanId ： dca8a04bfdc376e4
Request URI： /api/test/evict
Request Method： GET
Request Param： {"ids":[1, 2, 3]}
Request Body：
错误信息： IndexOutOfBoundsException：测试错误
    at com.honyee.app.web.TestController.evictTest(83)

2023.4.21

新增线程装饰器TaskContextDecorator，用于线程中获取上下文

public class TestService{
    public void test(){
       Runnable runnable = new TaskContextDecorator().decorate(() -> {
          RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
          if (requestAttributes != null) {
             ServletRequestAttributes attributes = (ServletRequestAttributes) requestAttributes;
             HttpServletRequest request = attributes.getRequest();
             TraceContext traceContext = (TraceContext) request.getAttribute(TraceContext.class.getName());
             String traceId = traceContext.traceId();
          }
       });
       new Thread(runnable).start();
    }
}

2023.4.14

@CacheEvict支持模糊删除指定前缀的缓存（重写了CacheAspectSupport和RedisCache）

public class CacheService {
   // 清理前缀为prefix的所有缓存（根据key，支持SPEL）
   @CacheEvict(value = "cache-test", key = "#prefix", allEntries = true)
   public void evictTest(String prefix) {
   }    
}

2023.4.1

整合WebSocket STOMP，需在maven启用websocket选项，以及在authentication.yml配置权限

执行顺序：

  1. WebsocketHandshakeInterceptor 握手拦截
  2. WebsocketHandshakeHandler 鉴权拦截
  3. WebsocketAuthChannelInterceptor 消息到达前拦截
  4. WebsocketController Controller

示例： WebsocketController 和 /resource/html/websocket.html

2023.3.31

整合Naocs

spring:
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
        username: nacos
        password: nacos
        namespace:
        enabled: true
/**
 * Nacos配置
 */
public class NacosConfiguration implements InitializingBean {
   @Override
   public void afterPropertiesSet() throws Exception {
       // 配置变动监听
      nacosConfigManager.getConfigService().addListener(getDataId(), nacosConfigProperties.getGroup(), new NacosListener());
      
      // 订阅
      NotifyCenter.registerSubscriber(new NacosInstancesChangeNotifier());
   }
   
   @EventListener
   public void onApplicationEvent(HeartbeatEvent event) {
      // 实例心跳监听
   }
}
/**
 * 配置变动监听
 */
public class NacosListener implements Listener {

     @Override
     public Executor getExecutor() {
         return null;
     }

     @Override
     public void receiveConfigInfo(String configInfo) {
         boolean result = analysisConfig(configInfo);
     }
 }
/**
 * 实例变动事件
 */
public class NacosInstancesChangeNotifier extends Subscriber<InstancesChangeEvent> {
   @Override
   public void onEvent(InstancesChangeEvent event) {
      // do something
   }

   @Override
   public Class<? extends Event> subscribeType() {
      return InstancesChangeEvent.class;
   }
}

2023.3.30

  1. 接入飞书机器人消息
application:
  feishu:
    group:
      common: 飞书机器人的hook
@Service
public class TestService {

    @Resource
    FeishuService feishuService;

    public String feishu() {
      FeishuMessageRequeset feishuMessageRequeset = new FeishuMessageRequeset();
      feishuMessageRequeset.setTitle("测试消息");
      feishuMessageRequeset.addMsg("请说", "hello honyee");
      feishuService.send(feishuMessageRequeset);
    }

}
  1. 新增延时任务实现DelayTaskListener<T>，可以指定由线程或Kafka执行任务
application:
  delay-task:
    # 通过kafka实际调用任务，前提是先启用kafka
    kafka-execute: true
/**
 * 1. 必须实现Serializable
 * 2. 交由kafka执行时注解 @JsonTypeInfo(use = JsonTypeInfo.Id.CLASS)
 */
@JsonTypeInfo(use = JsonTypeInfo.Id.CLASS)
public class MyDelayParam implements Serializable {
    private long id;
    private String title;
    // 省略get&set
}

实现监听

@Component
public class MyDelayTaskListener implements DelayTaskListener<MyDelayParam> {

    @Override
    public void run(MyDelayParam myDelayParam) {
        System.out.println("MyDelayTaskListener");
    }
}

提交延时任务

@Service
public class TestService {

    public void delay() {
        MyDelayParam myDelayParam = new MyDelayParam();
        myDelayParam.setId(System.currentTimeMillis());
        myDelayParam.setTitle("延时任务");
        // 延时
        DelayTaskConfiguration.submit(myDelayParam, 5, TimeUnit.SECONDS);
        // 指定时间
        DelayTaskConfiguration.submit(myDelayParam, Instant.now().plusSeconds(5));
    }

}

2023.3.28

  1. 整合kafka，默认单个实例，对应配置文件：application-kafka-singlel.yml

    maven开启kafka-mul可配置多个实例，对应配置文件：application-kafka-mul.yml、KafkaMulConfiguration

    maven开启exclude支持排除Kafka，对应配置文件：application-exclude.yml

  2. 新增@RedisLock注解，在Method上加锁，使用方式类似@Cacheable，支持SpEl

@Service
public class TestService {

    @RedisLock(value = "test", key = "#query")
    public String lockTest(String query) {
        return "complete";
    }
}

2023.3.27

优化mybatis sql日志打印，并拆分模块app、cover

2023.3.24

  1. 日志打印工具封装LogUtil

  2. 优化feign日志打印，使request和response日志分别一次性输出。

    可通过配置application.yml或者注解@DisableFeignLog来开启/关闭日志

# feign日志级别
feign:
  client:
    config:
      default:
        loggerLevel: FULL

2023.3.23

整合springdoc-openapi-ui，通过http://localhost:1222/v3/api-docs 导入接口到apifox

2023.3.22

新增一些工具类

public class MyTest {
    public void test() {
        String url = "https://www.honyee.com/html/honyee.html?id=123&id=456&type=abc&data.name=honyee";
        ParamDTO paramDTO = HttpUtil.readQuery(url, ParamDTO.class);
    }
}
public class ParamDTO {
    List<String> id;
    String type;
    Data data;
    public static class Data{
        String name;
        // 省略 get&set
    }
    
    // 省略 get&set
}

2023.3.19

@Cacheable新增缓存配置redisCacheManager和cacheManagerTwice

redisCacheManager缓存到redis，可自定义每个value的缓存时长

cacheManagerTwice缓存到内存，固定时长

@Service
public class CacheService {
    /**
     * value后面#60表示缓存60秒，不配置cacheManager时默认使用redisCacheManager
     * 缓存时长：
     * 1. 如果没有"#"则默认不设置过期时间
     * 2. 拼接的第一个"#"后面为过期时间，第二个"#"后面为时间单位
     * 3. 时间单位的表示使用: d(天)、h(小时)、m(分钟)、s(秒), 默认为s(秒)
     */
    @Cacheable(value = "cache-redis#60", key = "#key")
    public void cacheRedis(String key) {
        System.out.println("cache-redis");
    }

    @Cacheable(value = "cache-memory", key = "#key", cacheManager = "memoryCacheManager")
    public void cacheMemory(String key) {
        System.out.println("cache-memory");
    }
}

2023.3.16

新增url权限配置和菜单权限配置，存储于authentication.yml

authenticate-matchers:
  # 测试
  - path-matchers:
      - /api/test/**
    authenticated: false
  # api-docs
  - path-matchers:
      - /v3/api-docs
    authenticated: false
  # 登录授权
  - path-matchers:
      - /api/authenticate
    authenticated: false
  # 通用接口
  - path-matchers:
      - /api/user-menu
      - /api/all-role
  # 管理员接口
  - path-matchers:
      - /api/admin/**
    has-any-role:
      - admin

# 菜单权限
menu-matchers:
  - path-matchers:
      - /index
  - path-matchers:
      - /user/index
    authenticated: true
    has-any-role:
      - admin

2023.3.15

接入springdoc

apifox导入地址：http://localhost:1222/v3/api-docs

# 禁用文档
springdoc:
  api-docs:
    enabled: false

2023.2.27

  1. 获取租户ID TenantHelper.getTenantId()

  2. 补充@InterceptorIgnore的支持范围

  3. 开关租户注入TenantHelper.disableTenant()、TenantHelper.enableTenant()

/**
 * 支持Entity
 */
@TableName("city")
@InterceptorIgnore(tenantLine = "true")
public class City {
    
}
/**
 * 支持Class
 */
@SpringBootTest
@InterceptorIgnore(tenantLine = "true")
class MpApplicationTests {
    
}
/**
 * 支持Method
 */
@SpringBootTest
class MpApplicationTests {
    @Test
    @InterceptorIgnore(tenantLine = "true")
    public void emptyInit() {
        log.info(() -> "emptyInit");
    }
}

About

spring boot + mybatis plus 多租户 以及各种框架整合

Topics

java spring-boot mybatis-plugin spring-boot-2-7

Resources

Readme
Activity

Stars

1 star

Watchers

1 watching

Forks

0 forks
Report repository

Releases

No releases published

Languages