日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當(dāng)前位置:首頁 > 科技  > 軟件

SpringBoot多租戶三種架構(gòu)實現(xiàn)方案詳解

來源: 責(zé)編: 時間:2024-05-29 08:58:35 173觀看
導(dǎo)讀環(huán)境:SpringBoot3.3.01. 簡介多租戶表示應(yīng)用程序的單個運行實例同時為多個客戶機(租戶)服務(wù)的體系結(jié)構(gòu)。這在SaaS解決方案中非常常見。在這些系統(tǒng)中,隔離與各種租戶相關(guān)的信息(數(shù)據(jù)、定制等)是一個特殊的挑戰(zhàn)。這包括存儲在

環(huán)境:SpringBoot3.3.0i7H28資訊網(wǎng)——每日最新資訊28at.com

1. 簡介

多租戶表示應(yīng)用程序的單個運行實例同時為多個客戶機(租戶)服務(wù)的體系結(jié)構(gòu)。這在SaaS解決方案中非常常見。在這些系統(tǒng)中,隔離與各種租戶相關(guān)的信息(數(shù)據(jù)、定制等)是一個特殊的挑戰(zhàn)。這包括存儲在數(shù)據(jù)庫中的每個租戶擁有的數(shù)據(jù)。以下是三種常用的多租戶架構(gòu)實現(xiàn)方案:i7H28資訊網(wǎng)——每日最新資訊28at.com

1.1 獨立數(shù)據(jù)庫(Separate database)

圖片圖片i7H28資訊網(wǎng)——每日最新資訊28at.com

每個租戶的數(shù)據(jù)都保存在一個物理上獨立的數(shù)據(jù)庫實例中。JDBC連接將專門指向每個數(shù)據(jù)庫,因此任何池都將按租戶進行。這里,一種通用的應(yīng)用程序方法是為每個租戶定義JDBC連接池,并根據(jù)與當(dāng)前登錄用戶相關(guān)聯(lián)的租戶標(biāo)識符來選擇要使用的池。i7H28資訊網(wǎng)——每日最新資訊28at.com

優(yōu)點:i7H28資訊網(wǎng)——每日最新資訊28at.com

  • 數(shù)據(jù)隔離級別高,安全性好
  • 可以根據(jù)租戶的需求進行數(shù)據(jù)庫優(yōu)化和擴展
  • 備份和恢復(fù)操作相對簡單

缺點:i7H28資訊網(wǎng)——每日最新資訊28at.com

  • 成本較高,需要為每個租戶購買和維護獨立的數(shù)據(jù)庫實例
  • 可能存在硬件資源浪費,因為每個租戶可能只使用了數(shù)據(jù)庫的一部分功能

1.2 獨立Schema(Separate schema)

圖片i7H28資訊網(wǎng)——每日最新資訊28at.com

每個租戶的數(shù)據(jù)都保存在單個數(shù)據(jù)庫實例上的不同數(shù)據(jù)庫Schema中。這里有兩種不同的定義JDBC連接的方法:i7H28資訊網(wǎng)——每日最新資訊28at.com

  • 連接可以特定地指向每個Schema,就像單獨的數(shù)據(jù)庫方法中那樣。這是一個選項,前提是驅(qū)動程序支持在連接URL中命名默認(rèn)Schema,或者池機制支持命名用于其連接的Schema。使用這種方法,我們將為每個租戶創(chuàng)建一個不同的JDBC連接池,使用的連接池將基于與當(dāng)前登錄用戶相關(guān)聯(lián)的“租戶標(biāo)識符”進行選擇。
  • 連接可以指向數(shù)據(jù)庫本身(使用某些默認(rèn)Schema),但使用SQL SET schema(或類似的)命令可以更改連接。使用這種方法,我們將有一個JDBC連接池用于為所有租戶提供服務(wù),但在使用連接之前,它將被更改為引用由與當(dāng)前登錄用戶關(guān)聯(lián)的“租戶標(biāo)識符”命名的模式。

優(yōu)點:i7H28資訊網(wǎng)——每日最新資訊28at.com

  • 降低了數(shù)據(jù)庫成本,因為多個租戶共享一個數(shù)據(jù)庫實例
  • 數(shù)據(jù)隔離級別仍然較高,因為每個租戶使用獨立的模式

缺點:i7H28資訊網(wǎng)——每日最新資訊28at.com

  • 模式之間可能存在資源競爭和性能瓶頸
  • 備份和恢復(fù)操作可能更加復(fù)雜,因為需要針對每個模式進行單獨操作

1.3 分區(qū)數(shù)據(jù)(Partitioned (discriminator) data)

圖片i7H28資訊網(wǎng)——每日最新資訊28at.com

所有數(shù)據(jù)都保存在一個數(shù)據(jù)庫Schema中。通過使用分區(qū)列對每個租戶的數(shù)據(jù)進行分區(qū)。這種方法將使用單個連接池為所有租戶提供服務(wù)。但是,在這種方法中,應(yīng)用程序需要對每個SQL語句添加分區(qū)列(查詢時where條件加入分區(qū)列作為查詢條件)。i7H28資訊網(wǎng)——每日最新資訊28at.com

優(yōu)點:i7H28資訊網(wǎng)——每日最新資訊28at.com

  • 成本最低,因為所有租戶都共享同一個數(shù)據(jù)庫實例和模式
  • 數(shù)據(jù)訪問和查詢效率可能較高,因為數(shù)據(jù)都在同一個表中

缺點:
i7H28資訊網(wǎng)——每日最新資訊28at.com

  • 數(shù)據(jù)隔離級別最低,可能存在安全風(fēng)險
  • 需要通過應(yīng)用程序邏輯來確保數(shù)據(jù)的正確隔離和訪問控制
  • 數(shù)據(jù)備份和恢復(fù)操作可能非常復(fù)雜,因為需要考慮到所有租戶的數(shù)據(jù)

接下來我會對分區(qū)數(shù)據(jù)獨立數(shù)據(jù)庫2種架構(gòu)進行詳細(xì)的介紹。獨立Schema方案其實與獨立數(shù)據(jù)庫模式挺像的,如果基于MySQL其實對應(yīng)的就是不同數(shù)據(jù)庫(可以是同一個MySQL實例,通過use xxx切換數(shù)據(jù)庫),基于Oracle就是對應(yīng)不同的用戶上(并非schema與用戶等同)。i7H28資訊網(wǎng)——每日最新資訊28at.com

2. 實戰(zhàn)案例

2.1 分區(qū)數(shù)據(jù)

注:請先確保你當(dāng)前使用的SpringBoot版本(Spring Data JPA)整合的Hibernate版本至少是6.0版本以上。i7H28資訊網(wǎng)——每日最新資訊28at.com

實體定義

@Entity@Table(name = "t_person")public class Person {  @Id  @GeneratedValue(strategy = GenerationType.IDENTITY)  private Long id ;  private String name ;  private Integer age ;  @TenantId  private String tenantId ;}

這里通過@TenantId注解標(biāo)注,該字段專門用來分區(qū)租戶的,Hibernate在查詢數(shù)據(jù)時會自動添加該查詢條件,如果你使用的本地SQL(自己編寫SQL),那么需要你自行添加該條件(租戶ID條件)。i7H28資訊網(wǎng)——每日最新資訊28at.com

編寫DAO&Service

// DAOpublic interface PersonRepository extends JpaRepository<Person, Long>, JpaSpecificationExecutor<Person> {}// Service@Servicepublic class PersonService {  private final PersonRepository personRepository ;  public PersonService(PersonRepository personRepository) {    this.personRepository = personRepository ;  }  // 查詢所有Person數(shù)據(jù)  public List<Person> persons() {    return this.personRepository.findAll() ;  }}

Controller接口

@GetMapping("")public List<Person> persons() {  return this.personService.persons() ;}

以上是開發(fā)一個業(yè)務(wù)功能的基本操作,接下來才是重點i7H28資訊網(wǎng)——每日最新資訊28at.com

租戶標(biāo)識解析處理

該的作用獲取當(dāng)前租戶ID,這里基于ThreadLocal實現(xiàn)i7H28資訊網(wǎng)——每日最新資訊28at.com

public class TenantIdResolver implements CurrentTenantIdentifierResolver<String> {  private static final ThreadLocal<String> CURRENT_TENANT = new ThreadLocal<>();  public void setCurrentTenant(String currentTenant) {    CURRENT_TENANT.set(currentTenant);  }  @Override  public String resolveCurrentTenantIdentifier() {    // 注意這里不能返回null    return Optional.ofNullable(CURRENT_TENANT.get()).orElse("default") ;  }  @Override  public boolean validateExistingCurrentSessions() {    return true;  }}

上面的組件用來從當(dāng)前的ThreadLocal中獲取租戶ID,接下來就是像ThreadLocal存入租戶ID。i7H28資訊網(wǎng)——每日最新資訊28at.com

Web攔截器

該攔截器的作用用來從請求Header中獲取租戶ID,存入ThreadLocal中。i7H28資訊網(wǎng)——每日最新資訊28at.com

@Componentpublic class TenantIdInterceptor implements HandlerInterceptor {  private final TenantIdResolver tenantIdResolver;  public TenantIdInterceptor(TenantIdResolver tenantIdResolver) {    this.tenantIdResolver = tenantIdResolver;  }  @Override  public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {    String tenantId = request.getHeader("x-tenant-id");    tenantIdResolver.setCurrentTenant(tenantId);    return true ;  }}

最后一步就是配置hibernate,設(shè)置租戶ID的解析器。i7H28資訊網(wǎng)——每日最新資訊28at.com

配置租戶標(biāo)識解析器

spring:  jpa:    properties:      hibernate:        '[tenant_identifier_resolver]': 'com.pack.tenant.config.TenantIdResolver'

完成以上類及配置的編寫后就實現(xiàn)了基于列區(qū)分(分區(qū))的多租戶架構(gòu)方案。i7H28資訊網(wǎng)——每日最新資訊28at.com

測試

準(zhǔn)備數(shù)據(jù):i7H28資訊網(wǎng)——每日最新資訊28at.com

圖片圖片i7H28資訊網(wǎng)——每日最新資訊28at.com

圖片圖片i7H28資訊網(wǎng)——每日最新資訊28at.com

圖片圖片i7H28資訊網(wǎng)——每日最新資訊28at.com

SQL執(zhí)行情況:i7H28資訊網(wǎng)——每日最新資訊28at.com

圖片圖片i7H28資訊網(wǎng)——每日最新資訊28at.com

自動添加了tenant_id查詢條件。i7H28資訊網(wǎng)——每日最新資訊28at.com

2.2 獨立數(shù)據(jù)庫

每租戶對應(yīng)一個數(shù)據(jù)庫,這需要在項目中配置多個數(shù)據(jù)源,同時提供一個數(shù)據(jù)源路由的核心類。i7H28資訊網(wǎng)——每日最新資訊28at.com

定義多數(shù)據(jù)源配置

你也可以將數(shù)據(jù)源的信息專門存放在數(shù)據(jù)表中。i7H28資訊網(wǎng)——每日最新資訊28at.com

pack:  datasource:    defaultDs: ds1    config:      ds1:        driverClassName: com.mysql.cj.jdbc.Driver        url: jdbc:mysql://localhost:3306/tenant-01        username: tenant01        password: xxxooo        type: com.zaxxer.hikari.HikariDataSource      ds2:        driverClassName: com.mysql.cj.jdbc.Driver        url: jdbc:mysql://localhost:3306/tenant-02        username: tenant02        password: oooxxx        type: com.zaxxer.hikari.HikariDataSource

在Spring實現(xiàn)多數(shù)據(jù)源切換,可以通過繼承AbstractRoutingDataSource。i7H28資訊網(wǎng)——每日最新資訊28at.com

public class PackRoutingDataSource extends AbstractRoutingDataSource {  @Override  protected Object determineCurrentLookupKey() {    return DataSourceContextHolder.get() ;  }}public class DataSourceContextHolder {  private static final ThreadLocal<String> HOLDER = new InheritableThreadLocal<>() ;  public static void set(String key) {    HOLDER.set(key) ;  }  public static String get() {    return HOLDER.get() ;  }  public static void clear() {    HOLDER.remove() ;   }}

配置數(shù)據(jù)源Bean

@Configurationpublic class DataSourceConfig {  @Bean  public DataSource dataSource(MultiDataSourceProperties properties) {    PackRoutingDataSource dataSource = new PackRoutingDataSource(properties.getDefaultDs()) ;    Map<Object, Object> targetDataSources = new HashMap<>() ;    // PackDataSourceProperties類僅僅就是繼承DataSourceProperties    Map<String, PackDataSourceProperties> configs = properties.getConfig() ;    configs.forEach((key, props) -> {      targetDataSources.put(key, createDataSource(props, HikariDataSource.class)) ;    });    dataSource.setTargetDataSources(targetDataSources) ;    return dataSource ;  }  private static <T> T createDataSource(PackDataSourceProperties properties, Class<? extends DataSource> type) {    // 這里沒有考慮池的配置    return (T) properties.initializeDataSourceBuilder().type(type).build();  }}

接下來定義攔截器,設(shè)置當(dāng)前要操作的數(shù)據(jù)源。i7H28資訊網(wǎng)——每日最新資訊28at.com

Web攔截器

@Componentpublic class TenantIdInterceptor implements HandlerInterceptor {  @Override  public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {    String tenantId = request.getHeader("x-tenant-id");    DataSourceContextHolder.set(tenantId) ;    return true ;  }}

以上就完成了多數(shù)據(jù)源的所有類及配置的編寫。i7H28資訊網(wǎng)——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-91376-0.htmlSpringBoot多租戶三種架構(gòu)實現(xiàn)方案詳解

聲明:本網(wǎng)頁內(nèi)容旨在傳播知識,若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 聊聊主流消息隊列的認(rèn)證和鑒權(quán)!

下一篇: 京東二面:為什么Netty要創(chuàng)造FastThreadLocal?

標(biāo)簽:
  • 熱門焦點
Top 主站蜘蛛池模板: 青川县| 康平县| 杨浦区| 金平| 武定县| 醴陵市| 浮山县| 南岸区| 余干县| 荔波县| 奉贤区| 马山县| 衡水市| 丹东市| 长乐市| 登封市| 盐源县| 千阳县| 连山| 新巴尔虎右旗| 德庆县| 贵港市| 儋州市| 洛阳市| 吉水县| 宝应县| 新营市| 荔波县| 东乌珠穆沁旗| 双鸭山市| 区。| 潍坊市| 游戏| 铜鼓县| 罗平县| 民丰县| 建平县| 上高县| 平远县| 扶绥县| 渑池县|