## 線程環境自定義租戶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
- 第十章 聯系我們