中文字幕第五页-中文字幕第页-中文字幕韩国-中文字幕最新-国产尤物二区三区在线观看-国产尤物福利视频一区二区

MybatisPlus中多租戶架構Multi-tenancy的示例分析

這篇文章給大家分享的是有關MybatisPlus中多租戶架構Multi-tenancy的示例分析的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

創新互聯是專業的襄陽網站建設公司，襄陽接單;提供成都做網站、網站制作、成都外貿網站建設,網頁設計,網站設計,建網站,PHP網站建設等專業做網站服務;采用PHP框架,可快速的進行襄陽網站開發網頁制作和功能擴展;專業做搜索引擎喜愛的網站,專業的做網站團隊,希望更多企業前來合作!

什么是多租戶

多租戶技術或稱多重租賃技術，簡稱SaaS，是一種軟件架構技術，是實現如何在多用戶環境下（此處的多用戶一般是面向企業用戶）共用相同的系統或程序組件，并且可確保各用戶間數據的隔離性。

簡單講：在一臺服務器上運行單個應用實例，它為多個租戶（客戶）提供服務。從定義中我們可以理解：多租戶是一種架構，目的是為了讓多用戶環境下使用同一套程序，且保證用戶間數據隔離。那么重點就很淺顯易懂了，多租戶的重點就是同一套程序下實現多用戶數據的隔離。

數據隔離方案

多租戶在數據存儲上存在三種主要的方案，分別是：

獨立數據庫

即一個租戶一個數據庫，這種方案的用戶數據隔離級別最高，安全性最好，但成本較高。

  • 優點：為不同的租戶提供獨立的數據庫，有助于簡化數據模型的擴展設計，滿足不同租戶的獨特需求；如果出現故障，恢復數據比較簡單。

  • 缺點：增多了數據庫的安裝數量，隨之帶來維護成本和購置成本的增加。

共享數據庫，獨立 Schema

多個或所有租戶共享Database，但是每個租戶一個Schema（也可叫做一個user）。底層庫比如是：DB2、ORACLE等，一個數據庫下可以有多個SCHEMA。

  • 優點：為安全性要求較高的租戶提供了一定程度的邏輯數據隔離，并不是完全隔離；每個數據庫可支持更多的租戶數量。

  • 缺點：如果出現故障，數據恢復比較困難，因為恢復數據庫將牽涉到其他租戶的數據；

共享數據庫，共享 Schema，共享數據表

即租戶共享同一個Database、同一個Schema，但在表中增加TenantID多租戶的數據字段。這是共享程度最高、隔離級別最低的模式。

簡單來講，即每插入一條數據時都需要有一個客戶的標識。這樣才能在同一張表中區分出不同客戶的數據，這也是我們系統目前用到的(provider_id)

  1. 優點：三種方案比較，第三種方案的維護和購置成本最低，允許每個數據庫支持的租戶數量最多。

  2. 缺點：隔離級別最低，安全性最低，需要在設計開發時加大對安全的開發量； 數據備份和恢復最困難，需要逐表逐條備份和還原。

<!--- more --->

利用MybatisPlus實現

這里我們選用了第三種方案（共享數據庫，共享 Schema，共享數據表）來實現，也就意味著，每個數據表都需要有一個租戶標識(provider_id)

現在有數據庫表(user)如下：


字段名字段類型描述
idBIGINT(20)主鍵
provider_idBIGINT(20)服務商ID
nameVARCHAR(30)姓名

將provider_id視為租戶ID，用來隔離租戶與租戶之間的數據，如果要查詢當前服務商的用戶，SQL大致如下：

SELECT * FROM user t WHERE t.name LIKE '%Tom%' AND t.provider_id = 1;

試想一下，除了一些系統共用的表以外，其他租戶相關的表，我們都需要不厭其煩的加上AND t.provider_id = ?查詢條件，稍不注意就會導致數據越界，數據安全問題讓人擔憂。

好在有了MybatisPlus這個神器，可以極為方便的實現多租戶SQL解析器，官方文檔如下：
http://mp.baomidou.com/guide/tenant.html

這里終于進入了正題，開始搭建一個極為簡單的開發環境吧!

新建SpringBoot環境

POM文件如下，主要集成了MybatisPlus以及H2數據庫(方便測試)
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <groupId>com.wuwenze</groupId>
  <artifactId>mybatis-plus-multi-tenancy</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>mybatis-plus-multi-tenancy</name>
  <description>Demo project for Spring Boot</description>

  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.0.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <scope>provided</scope>
    </dependency>
    <dependency>
      <groupId>com.google.guava</groupId>
      <artifactId>guava</artifactId>
      <version>19.0</version>
    </dependency>

    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus-boot-starter</artifactId>
      <version>3.0.5</version>
    </dependency>
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus</artifactId>
      <version>3.0.5</version>
    </dependency>
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus-generator</artifactId>
      <version>3.0.5</version>
    </dependency>

    <dependency>
      <groupId>com.h3database</groupId>
      <artifactId>h3</artifactId>
    </dependency>
  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>
</project>
數據源配置(application.yml)
spring:
 datasource:
  driver-class-name: org.h3.Driver
  schema: classpath:db/schema.sql
  data: classpath:db/data.sql
  url: jdbc:h3:mem:test
  username: root
  password: test

logging:
 level:
  com.wuwenze.mybatisplusmultitenancy: debug
對應的H2數據庫初始化schema文件
#schema.sql
DROP TABLE IF EXISTS user;
CREATE TABLE user
(
  id BIGINT(20) NOT NULL COMMENT '主鍵',
  provider_id BIGINT(20) NOT NULL COMMENT '服務商ID',
  name VARCHAR(30) NULL DEFAULT NULL COMMENT '姓名',
  PRIMARY KEY (id)
);


#data.sql
INSERT INTO user (id, provider_id, name) VALUES (1, 1, 'Tony老師');
INSERT INTO user (id, provider_id, name) VALUES (2, 1, 'William老師');
INSERT INTO user (id, provider_id, name) VALUES (3, 2, '路人甲');
INSERT INTO user (id, provider_id, name) VALUES (4, 2, '路人乙');
INSERT INTO user (id, provider_id, name) VALUES (5, 2, '路人丙');
INSERT INTO user (id, provider_id, name) VALUES (6, 2, '路人丁');

MybatisPlus Config

基礎環境搭建完成，現在開始配置MybatisPlus多租戶相關的實現。

1) 核心配置：TenantSqlParser

@Configuration
@MapperScan("com.wuwenze.mybatisplusmultitenancy.mapper")
public class MybatisPlusConfig {

  private static final String SYSTEM_TENANT_ID = "provider_id";
  private static final List<String> IGNORE_TENANT_TABLES = Lists.newArrayList("provider");

  @Autowired
  private ApiContext apiContext;

  @Bean
  public PaginationInterceptor paginationInterceptor() {
    PaginationInterceptor paginationInterceptor = new PaginationInterceptor();

    // SQL解析處理攔截：增加租戶處理回調。
    TenantSqlParser tenantSqlParser = new TenantSqlParser()
        .setTenantHandler(new TenantHandler() {

          @Override
          public Expression getTenantId() {
            // 從當前系統上下文中取出當前請求的服務商ID，通過解析器注入到SQL中。
            Long currentProviderId = apiContext.getCurrentProviderId();
            if (null == currentProviderId) {
              throw new RuntimeException("#1129 getCurrentProviderId error.");
            }
            return new LongValue(currentProviderId);
          }

          @Override
          public String getTenantIdColumn() {
            return SYSTEM_TENANT_ID;
          }

          @Override
          public boolean doTableFilter(String tableName) {
            // 忽略掉一些表：如租戶表（provider）本身不需要執行這樣的處理。
            return IGNORE_TENANT_TABLES.stream().anyMatch((e) -> e.equalsIgnoreCase(tableName));
          }
        });
    paginationInterceptor.setSqlParserList(Lists.newArrayList(tenantSqlParser));
    return paginationInterceptor;
  }

  @Bean(name = "performanceInterceptor")
  public PerformanceInterceptor performanceInterceptor() {
    return new PerformanceInterceptor();
  }
}

2) ApiContext

@Component
public class ApiContext {
  private static final String KEY_CURRENT_PROVIDER_ID = "KEY_CURRENT_PROVIDER_ID";
  private static final Map<String, Object> mContext = Maps.newConcurrentMap();

  public void setCurrentProviderId(Long providerId) {
    mContext.put(KEY_CURRENT_PROVIDER_ID, providerId);
  }

  public Long getCurrentProviderId() {
    return (Long) mContext.get(KEY_CURRENT_PROVIDER_ID);
  }
}

3) Entity、Mapper

@Data
@ToString
@Accessors(chain = true)
public class User {
  private Long id;
  private Long providerId;
  private String name;
}

public interface UserMapper extends BaseMapper<User> {

}

MybatisPlus中多租戶架構Multi-tenancy的示例分析

單元測試

com.wuwenze.mybatisplusmultitenancy.MybatisPlusMultiTenancyApplicationTests
@Slf4j
@RunWith(SpringRunner.class)
@FixMethodOrder(MethodSorters.JVM)
@SpringBootTest(classes = MybatisPlusMultiTenancyApplication.class)
public class MybatisPlusMultiTenancyApplicationTests {


  @Autowired
  private ApiContext apiContext;

  @Autowired
  private UserMapper userMapper;

  @Before
  public void before() {
    // 在上下文中設置當前服務商的ID
    apiContext.setCurrentProviderId(1L);
  }

  @Test
  public void insert() {
    User user = new User().setName("新來的Tom老師");
    Assert.assertTrue(userMapper.insert(user) > 0);

    user = userMapper.selectById(user.getId());
    log.info("#insert user={}", user);

    // 檢查插入的數據是否自動填充了租戶ID
    Assert.assertEquals(apiContext.getCurrentProviderId(), user.getProviderId());
  }

  @Test
  public void selectList() {
    userMapper.selectList(null).forEach((e) -> {
      log.info("#selectList, e={}", e);
      // 驗證查詢的數據是否超出范圍
      Assert.assertEquals(apiContext.getCurrentProviderId(), e.getProviderId());
    });
  }
}
運行結果
2018-11-29 21:07:14.262 INFO 18688 --- [      main] .MybatisPlusMultiTenancyApplicationTests : Started MybatisPlusMultiTenancyApplicationTests in 2.629 seconds (JVM running for 3.904)
2018-11-29 21:07:14.554 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.insert      : ==> Preparing: INSERT INTO user (id, name, provider_id) VALUES (?, ?, 1)
2018-11-29 21:07:14.577 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.insert      : ==> Parameters: 1068129257418178562(Long), 新來的Tom老師(String)
2018-11-29 21:07:14.577 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.insert      : <==  Updates: 1
 Time：0 ms - ID：com.wuwenze.mybatisplusmultitenancy.mapper.UserMapper.insert
Execute SQL：INSERT INTO user (id, name, provider_id) VALUES (?, ?, 1) {1: 1068129257418178562, 2: STRINGDECODE('\u65b0\u6765\u7684Tom\u8001\u5e08')}

2018-11-29 21:07:14.585 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.selectById    : ==> Preparing: SELECT id, provider_id, name FROM user WHERE user.provider_id = 1 AND id = ?
2018-11-29 21:07:14.595 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.selectById    : ==> Parameters: 1068129257418178562(Long)
2018-11-29 21:07:14.614 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.selectById    : <==   Total: 1
2018-11-29 21:07:14.615 INFO 18688 --- [      main] .MybatisPlusMultiTenancyApplicationTests : #insert user=User(id=1068129257418178562, providerId=1, name=新來的Tom老師)
 Time：19 ms - ID：com.wuwenze.mybatisplusmultitenancy.mapper.UserMapper.selectById
Execute SQL：SELECT id, provider_id, name FROM user WHERE user.provider_id = 1 AND id = ? {1: 1068129257418178562}

2018-11-29 21:07:14.626 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.selectList    : ==> Preparing: SELECT id, provider_id, name FROM user WHERE user.provider_id = 1
 Time：0 ms - ID：com.wuwenze.mybatisplusmultitenancy.mapper.UserMapper.selectList
Execute SQL：SELECT id, provider_id, name FROM user WHERE user.provider_id = 1

2018-11-29 21:07:14.629 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.selectList    : ==> Parameters:
2018-11-29 21:07:14.630 DEBUG 18688 --- [      main] c.w.m.mapper.UserMapper.selectList    : <==   Total: 3
2018-11-29 21:07:14.632 INFO 18688 --- [      main] .MybatisPlusMultiTenancyApplicationTests : #selectList, e=User(id=1, providerId=1, name=Tony老師)
2018-11-29 21:07:14.632 INFO 18688 --- [      main] .MybatisPlusMultiTenancyApplicationTests : #selectList, e=User(id=2, providerId=1, name=William老師)
2018-11-29 21:07:14.632 INFO 18688 --- [      main] .MybatisPlusMultiTenancyApplicationTests : #selectList, e=User(id=1068129257418178562, providerId=1, name=新來的Tom老師)

MybatisPlus中多租戶架構Multi-tenancy的示例分析

從打印的日志不難看出，這個方案相當完美，僅需簡單的配置，讓開發者完全忽略了(provider_id)字段的存在，同時又最大程度的保證了數據的安全性，可謂是一舉兩得！

感謝各位的閱讀！關于“MybatisPlus中多租戶架構Multi-tenancy的示例分析”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！

網頁題目：MybatisPlus中多租戶架構Multi-tenancy的示例分析
路徑分享：http://m.2m8n56k.cn/article8/pdieop.html

成都網站建設公司_創新互聯，為您提供品牌網站建設、云服務器、網站策劃、服務器托管、電子商務、網站維護

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：[email protected]。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯

微信小程序開發
主站蜘蛛池模板： 国产精品极品美女自在线看免费一区二区 | 亚洲自拍成人 | 久久99国产亚洲精品 | 99视频有精品视频免费观看 | 亚洲人成a在线网站 | 91精品国产乱码久久久久久 | 欧美成在线 | a级片在线免费看 | 国产精品成aⅴ人片在线观看 | 在线视频免费国产成人 | 特级片视频 | 免费公开视频人人人人人人人 | 一级一片免费播放 | 欧美一级亚洲一级 | 欧美成人免费一级人片 | 九九视频在线免费观看 | 怡红院在线a男人的天堂 | 精品成人免费一区二区在线播放 | 三级视频中文字幕 | 久久九九色 | 成人黄色免费观看 | 国产精彩视频在线观看 | 亚洲在线不卡 | 成人丁香乱小说 | 成人性一级视频在线观看 | 欧美日韩一区二区不卡三区 | 俄罗斯a级毛片 | 亚洲第一网站在线观看 | 久久草在线观看 | 91精品欧美成人 | 欧美成人免费sss | 欧美大狠狠大臿蕉香蕉大视频 | 99国产欧美久久精品 | f性欧美 | 国产精品久久久久久影院 | 欧美激情免费观看一区 | 国产高清精品在线 | japanese日本舒服丰满 | 久久精品操 | 国产91香蕉在线精品 | 一本到不卡 |