基于MybatisPlus插件TenantLineInnerInterceptor实现多租户功能-eolink官网

基于MybatisPlus插件TenantLineInnerInterceptor实现多租户功能

多租户技术的基本概念：

多租户技术（英语：multi-tenancy technology）或称多重租赁技术，是一种软件架构技术，它是在探讨与实现如何于多用户的环境下共用相同的系统或程序组件，并且仍可确保各用户间数据的隔离性。

在云计算的加持之下，多租户技术被广为运用于开发云各式服务，不论是IaaS，PaaS还是SaaS，都可以看到多租户技术的影子。

前面介绍过GitEgg框架与数据库交互使用了Mybatis增强工具Mybatis-Plus，Mybatis-Plus提供了TenantLineInnerInterceptor租户处理器来实现多租户功能，其原理就是Mybatis-Plus实现了自定义Mybatis拦截器（Interceptor），在需要执行的sql后面自动添加租户的查询条件，实际和分页插件，数据权限拦截器是同样的实现方式。

简而言之多租户技术就是可以让一套系统通过配置给不同的客户提供服务，每个客户看到的数据都是属于自己的，就好像每个客户都拥有自己一套独立完善的系统。

下面是在GitEgg系统的应用配置：

1、在gitegg-platform-mybatis工程下新建多租户组件配置文件TenantProperties.java和TenantConfig.java，TenantProperties.java用于系统读取配置文件，这里会在Nacos配置中心设置多组户的具体配置信息，TenantConfig.java是插件需要读取的配置有三个配置项：

TenantId租户ID、TenantIdColumn多租户的字段名、ignoreTable不需要多租户隔离的表。

TenantProperties.java:

package com.gitegg.platform.mybatis.props;

import lombok.Data;

import org.springframework.boot.context.properties.ConfigurationProperties;

import org.springframework.context.annotation.Configuration;

import java.util.List;

/**

* 白名单配置

@Data

@Configuration

@ConfigurationProperties(prefix = "tenant")

public class TenantProperties {

/**

* 是否开启租户模式

private Boolean enable;

/**

* 多租户字段名称

private String column;

/**

* 需要排除的多租户的表

private List exclusionTable;

}

TenantConfig.java：

package com.gitegg.platform.mybatis.config;

import com.baomidou.mybatisplus.extension.plugins.handler.TenantLineHandler;

import com.baomidou.mybatisplus.extension.plugins.inner.TenantLineInnerInterceptor;

import com.gitegg.platform.boot.util.GitEggAuthUtils;

import com.gitegg.platform.mybatis.props.TenantProperties;

import lombok.RequiredArgsConstructor;

import net.sf.jsqlparser.expression.Expression;

import net.sf.jsqlparser.expression.NullValue;

import net.sf.jsqlparser.expression.StringValue;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.autoconfigure.AutoConfigureBefore;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

/**

* 多租户配置中心

* @author GitEgg

@Configuration

@RequiredArgsConstructor(onConstructor_ = @Autowired)

@AutoConfigureBefore(MybatisPlusConfig.class)

public class TenantConfig {

private final TenantProperties tenantProperties;

/**

* 新多租户插件配置,一缓和二缓遵循mybatis的规则,

* 需要设置 MybatisConfiguration#useDeprecatedExecutor = false

* 避免缓存万一出现问题

* @retJVmQujEZurn TenantLineInnerInterceptor

@Bean

public TenantLineInnerInterceptor tenantLineInnerInterceptor() {

return new TenantLineInnerInterceptor(new TenantLineHandler() {

/**

* 获取租户ID

* @return Expression

@Override

public Expression getTenantId() {

String tenant = GitEggAuthUtils.getTenantId();

if (tenant != null) {

return new StringValue(GitEggAuthUtils.getTenantId());

}

return new NullValue();

}

/**

* 获取多租户的字段名

* @return String

@Override

public String getTenantIdColumn() {

return tenantProperties.getColumn();

}

/**

* 过滤不需要根据租户隔离的表

* 这是 default 方法,默认返回 false 表示所有表都需要拼多租户条件

* @param tableName 表名

@Override

public boolean ignoreTable(String tableName) {

return tenantProperties.getExclusionTable().stream().anyMatch(

(t) -> t.equalsIgnoreCase(tableName)

);

}

});

}

2、可在工程下新建application.yml，配置将来需要在Nacos上配置的信息：

tenant:

# 是否开启租户模式

enable: true

# 需要排除的多租户的表

exclusionTable:

- "t_sys_district"

- "oauth_client_details"

# 租户字段名称

column: tenant_id

3、修改MybatisPlusConfig.java，把多租户过滤器加载进来使其生效：

package com.gitegg.platform.mybatis.config;

import com.baomidou.mybatisplus.annotation.DbType;

import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;

import com.baomidou.mybatisplus.extension.plugins.inner.BlockAttackInnerInterceptor;

import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;

import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;

import com.baomidou.mybatisplus.extension.plugins.inner.TenantLineInnerInterceptor;

import com.gitegg.platform.mybatis.props.TenantProperties;

import lombok.RequiredArgsConstructor;

import org.mybatis.spring.annotation.MapperScan;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

@RequiredArgsConstructor(onConstructor_ = @Autowired)

@MapperScan("com.gitegg.**.mapper.**")

public class MybatisPlusConfig {

private final TenantLineInnerInterceptor tenantLineInnerInterceptor;

private final TenantProperties tenantProperties;

/**

* 新的分页插件,一缓和二缓遵循mybatis的规则,需要设置 MybatisConfiguration#useDeprecatedExecutor = false

* 避免缓存出现问题(该属性会在旧插件移除后一同移除)

@Bean

public MybatisPlusInterceptor mybatisPlusInterceptor() {

MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();

//多租户插件

if (tenantProperties.getEnable()) {

interceptor.addInnerInterceptor(tenantLineInnerInterceptor);

}

//分页插件

interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.mysql));

//防止全表更新与删除插件: BlockAttackInnerInterceptor

BlockAttackInnerInterceptor blockAttackInnerInterceptor = new BlockAttackInnerInterceptor();

interceptor.addInnerInterceptor(blockAttackInnerInterceptor);

return interceptor;

}

/**

* 乐观锁插件当要更新一条记录的时候，希望这条记录没有被别人更新

* https://mybatis.plus/guide/interceptor-optimistic-locker.html#optimisticlockerinnerinterceptor

@Bean

public OptimisticLockerInnerInterceptor optimisticLockerInterceptor() {

return new OptimisticLockerInnerInterceptor();

}

4、在GitEggAuthUtils方法中新增获取租户信息的公共方法，租户信息在Gateway进行转发时进行设置，后面会说明如何讲租户信息设置到Header中:

package com.gitegg.platform.boot.util;

import cn.hutool.json.JSONUtil;

import com.gitegg.platform.base.constant.AuthConstant;

import com.gitegg.platform.base.domain.GitEggUser;

import org.springframework.util.StringUtils;

import javax.servlet.http.HttpServletRequest;

import java.io.UnsupportedEncodingException;

import java.net.URLDecoder;

public class GitEggAuthUtils {

/**

* 获取用户信息

* @return GitEggUser

public static GitEggUser getCurrentUser() {

HttpServletRequest request = GitEggWebUtils.getRequest();

if (request == null) {

return null;

}

try {

String user = request.getHeader(AuthConstant.HEADER_USER);

if (StringUtils.isEmpty(user))

{

return null;

}

String userStr = URLDecoder.decode(user,"UTF-8");

GitEggUser gitEggUser = JSONUtil.toBean(userStr, GitEggUser.class);

return gitEggUser;

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

return null;

}

/**

* 获取租户Id

* @return tenantId

public static String getTenantId() {

HttpServletRequest request = GitEggWebUtils.getRequest();

if (request == null) {

return null;

}

try {

String tenantId = request.getHeader(AuthConstant.TENANT_ID);

String user = request.getHeader(AuthConstant.HEADER_USER);

//如果请求头中的tenantId为空，那么尝试是否能够从登陆用户中去获取租户id

if (StringUtils.isEmpty(tenantId) && !StringUtils.isEmpty(user))

{

String userStr = URLDecoder.decode(user,"UTF-8");

GitEggUser gitEggUser = JSONUtil.toBean(userStr, GitEggUser.class);

if (null != gitEggUser)

{

tenantId = gitEggUser.getTenantId();

}

return tenantId;

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

return null;

}

5、GitEgg-Cloud工程中gitegg-gateway子工程的AuthGlobalFilter增加设置TenantId的过滤方法

String tenantId = exchange.getRequest().getHeaders().getFirst(AuthConstant.TENANT_ID);

String token = exchange.getRequest().getHeaders().getFirst(AuthConstant.JWT_TOKEN_HEADER);

if (StrUtil.isEmpty(tenantId) && StrUtil.isEmpty(token)) {

return chain.filter(exchange);

}

Map addHeaders = new HashMap<>();

// 如果系统配置已开启租户模式，设置tenantId

if (enable && StrUtil.isEmpty(tenantId)) {

addHeaders.put(AuthConstant.TENANT_ID, tenantId);

}

6、以上为后台的多租户功能集成步骤，在实际项目开发过程中，我们需要考虑到前端页面在租户信息上的配置，实现思路，不用的租户拥有不同的域名，前端页面根据当前域名获取到对应的租户信息，并在公共请求方法设置TenantId参数，保证每次请求能够携带租户信息。

// request interceptor

request.interceptors.request.use(config => {

const token = storage.get(ACCESS_TOKEN)

// 如果 token 存在

// 让每个请求携带自定义 token 请根据实际情况自行修改

if (token) {

config.headers['Authorization'] = token

}

config.headers['TenantId'] = process.env.vue_APP_TENANT_ID

return config

}, errorHandler)

源码地址:

Gitee: https://gitee.com/wmz1930/GitEgg

github: https://github.com/wmz1930/GitEgg

29、OSPF配置实验之被动接口

1722 2022-09-12

基于MybatisPlus插件TenantLineInnerInterceptor实现多租户功能

java中的接口是类吗

Spring中的aware接口详情

29、OSPF配置实验之被动接口

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！