## 线程环境自定义租户ID
1. 常规场景下,多租户的ID是从token获取的,而token通过request请求的header传递至后端解析。
2. 租户插件底层从request获取到tenantId进行隔离。
3. 但是如果遇到多线程、定时任务、RPC远程调用等场景是获取不到request的,原本的多租户插件也就失效了。
4. 针对这种情况我们提供了TenantUtil,可以在不同的场景自定义租户ID,包括租户的数据查询以及数据提交。
## 操作说明
1. 两种写法的对比如下,通过TenantUtil可以自定义当前线程的租户ID
~~~
// 常规写法
Notice detail = noticeService.getOne(Condition.getQueryWrapper(notice));
// 常规写法
Boolean temp = noticeService.save(notice);
// 线程自定义写法
Notice detail = TenantUtil.use("自定义租户ID", () ->
noticeService.getOne(Condition.getQueryWrapper(notice))
);
// 线程自定义写法
Boolean temp = TenantUtil.use("自定义租户ID", () ->
noticeService.save(notice)
);
~~~
2. 若某些场景需要忽略租户id,可以看到所有或者另外自定义,可以采用如下方式定义
~~~
// 常规写法
Notice detail = noticeService.list(Condition.getQueryWrapper(notice));
// 线程自定义写法
Notice detail = TenantUtil.ignore(() ->
noticeService.list(Condition.getQueryWrapper(notice))
);
~~~
3. 实现原理如下,通过本地线程设置租户id,接着在租户插件优先获取本地线程的值,若没有才从request获取租户的值。
~~~
private static final ThreadLocal<String> tl = new ThreadLocal<>();
/**
* 获取租户id
*
* @return 租户id
*/
public static String getTenantId() {
String tenantId = tl.get();
if (tenantId != null) {
return tenantId;
}
return AuthUtil.getTenantId();
}
/**
* 使用租户 id 执行函数
*
* @param tenantId tenantId
* @param runnable Runnable
*/
public static void use(String tenantId, Runnable runnable) {
Assert.hasText(tenantId, "参数 tenantId 为空");
tl.set(tenantId);
try {
runnable.run();
} finally {
tl.remove();
}
}
~~~
~~~
@Slf4j
@RequiredArgsConstructor
public class BladeTenantHandler implements TenantLineHandler, SmartInitializingSingleton {
/**
* 获取租户ID
*
* @return 租户ID
*/
@Override
public Expression getTenantId() {
return new StringValue(Func.toStr(TenantUtil.getTenantId(), BladeConstant.ADMIN_TENANT_ID));
}
}
~~~
## 说明
1. 通过TenantUtil可以自定义线程的租户ID。
2. 针对特殊应用场景不受request环境的影响,也可以实现跨租户查询的功能。
3. 注意⚠️:通过此工具可以操作访问任何租户的数据,**编码必须做好风险管理,否则会因为设计不当导致数据错乱等严重问题。**
- 第零章 序
- 序言
- 系统架构
- 视频公开课
- 开源版介绍
- 商业版介绍
- 功能对比
- 答疑流程
- 第一章 快速开始
- 升级必看
- 环境要求
- 环境准备
- 基础环境安装
- Docker安装基础服务
- Nacos安装
- Sentinel安装
- 插件安装
- 建数据库
- 工程导入
- 导入Cloud版本
- 导入Nacos配置
- 导入Boot版本
- 工程运行
- 运行Cloud版本
- 运行Boot版本
- 工程测试
- 测试Cloud版本
- 测试Boot版本
- 第二章 技术基础
- Java
- Lambda
- Lambda 受检异常处理
- Stream 简介
- Stream API 一览
- Stream API (上)
- Stream API (下)
- Optional 干掉空指针
- 函数式接口
- 新的日期 API
- Lombok
- SpringMVC
- Swagger
- Mybatis
- Mybatis-Plus
- 开发规范
- 第三章 开发初探
- 新建微服务工程
- 第一个API
- API鉴权
- API响应结果
- Redis缓存
- 第一个CRUD
- 建表
- 建Entity
- 建Service和Mapper
- 新增 API
- 修改 API
- 删除 API
- 查询 API
- 单条数据
- 多条数据
- 分页
- 微服务远程调用
- 声明式服务调用 Feign
- 熔断机制 Hystrix
- 第四章 开发进阶
- 聚合文档
- 鉴权配置
- 跨域处理
- Xss防注入
- 自定义启动器
- Secure安全框架
- Token认证简介
- Token认证配置
- PreAuth注解配置
- Token认证实战
- Token认证加密
- 日志系统
- 原理解析
- 功能调用
- Seata分布式事务
- 简介
- 编译包启动
- 配置nacos对接
- docker启动
- 对接微服务
- 代码生成配置
- 前言
- 数据库建表
- 代码生成
- 前端配置
- 优化效果
- 第五章 功能特性
- SaaS多租户
- 概念
- 数据隔离配置
- 线程环境自定义租户ID
- 多终端令牌认证
- 概念
- 系统升级
- 使用
- 第三方系统登录
- 概念说明
- 对接说明
- 对接准备
- 配置说明
- 操作流程
- 后记
- UReport2报表
- 报表简介
- 对接配置
- 报表后记
- 动态数据权限
- 数据权限简介
- 数据权限开发
- 纯注解配置
- Web全自动配置
- 注解半自动配置
- 数据权限注意点
- 动态接口权限
- 乐观锁配置
- 统一服务登陆配置
- Skywalking追踪监控
- Minio分布式对象存储
- Boot版本对接至Cloud
- 第六章 生产部署
- windows部署
- linux部署
- jar部署
- docker部署
- java环境安装
- mysql安装
- docker安装
- docker-compose安装
- harbor安装
- 部署步骤
- 宝塔部署
- 准备工作
- 安装工作
- 部署准备
- 部署后端
- 部署前端
- 部署域名
- 结束工作
- k8s平台部署
- 第七章 版本控制
- Git远程分支合并
- Git地址更换
- 第八章 学习资料
- 第九章 FAQ
- 第十章 联系我们