這篇文章給大家分享的是有關(guān)MybatisPlus中多租戶架構(gòu)Multi-tenancy的示例分析的內(nèi)容。小編覺得挺實(shí)用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。
創(chuàng)新互聯(lián)是專業(yè)的襄陽網(wǎng)站建設(shè)公司,襄陽接單;提供成都做網(wǎng)站、網(wǎng)站制作、成都外貿(mào)網(wǎng)站建設(shè),網(wǎng)頁設(shè)計(jì),網(wǎng)站設(shè)計(jì),建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行襄陽網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來合作!
什么是多租戶
多租戶技術(shù)或稱多重租賃技術(shù),簡稱SaaS
,是一種軟件架構(gòu)技術(shù),是實(shí)現(xiàn)如何在多用戶環(huán)境下(此處的多用戶一般是面向企業(yè)用戶)共用相同的系統(tǒng)或程序組件,并且可確保各用戶間數(shù)據(jù)的隔離性。
簡單講:在一臺服務(wù)器上運(yùn)行單個應(yīng)用實(shí)例,它為多個租戶(客戶)提供服務(wù)。從定義中我們可以理解:多租戶是一種架構(gòu),目的是為了讓多用戶環(huán)境下使用同一套程序,且保證用戶間數(shù)據(jù)隔離。那么重點(diǎn)就很淺顯易懂了,多租戶的重點(diǎn)就是同一套程序下實(shí)現(xiàn)多用戶數(shù)據(jù)的隔離。
數(shù)據(jù)隔離方案
多租戶在數(shù)據(jù)存儲上存在三種主要的方案,分別是:
獨(dú)立數(shù)據(jù)庫
即一個租戶一個數(shù)據(jù)庫,這種方案的用戶數(shù)據(jù)隔離級別最高,安全性最好,但成本較高。
優(yōu)點(diǎn):為不同的租戶提供獨(dú)立的數(shù)據(jù)庫,有助于簡化數(shù)據(jù)模型的擴(kuò)展設(shè)計(jì),滿足不同租戶的獨(dú)特需求;如果出現(xiàn)故障,恢復(fù)數(shù)據(jù)比較簡單。
缺點(diǎn):增多了數(shù)據(jù)庫的安裝數(shù)量,隨之帶來維護(hù)成本和購置成本的增加。
共享數(shù)據(jù)庫,獨(dú)立 Schema
多個或所有租戶共享Database,但是每個租戶一個Schema(也可叫做一個user)。底層庫比如是:DB2、ORACLE等,一個數(shù)據(jù)庫下可以有多個SCHEMA。
優(yōu)點(diǎn):為安全性要求較高的租戶提供了一定程度的邏輯數(shù)據(jù)隔離,并不是完全隔離;每個數(shù)據(jù)庫可支持更多的租戶數(shù)量。
缺點(diǎn):如果出現(xiàn)故障,數(shù)據(jù)恢復(fù)比較困難,因?yàn)榛謴?fù)數(shù)據(jù)庫將牽涉到其他租戶的數(shù)據(jù);
共享數(shù)據(jù)庫,共享 Schema,共享數(shù)據(jù)表
即租戶共享同一個Database、同一個Schema,但在表中增加TenantID多租戶的數(shù)據(jù)字段。這是共享程度最高、隔離級別最低的模式。
簡單來講,即每插入一條數(shù)據(jù)時都需要有一個客戶的標(biāo)識。這樣才能在同一張表中區(qū)分出不同客戶的數(shù)據(jù),這也是我們系統(tǒng)目前用到的(provider_id)
優(yōu)點(diǎn):三種方案比較,第三種方案的維護(hù)和購置成本最低,允許每個數(shù)據(jù)庫支持的租戶數(shù)量最多。
缺點(diǎn):隔離級別最低,安全性最低,需要在設(shè)計(jì)開發(fā)時加大對安全的開發(fā)量; 數(shù)據(jù)備份和恢復(fù)最困難,需要逐表逐條備份和還原。
<!--- more --->
利用MybatisPlus實(shí)現(xiàn)
這里我們選用了第三種方案(共享數(shù)據(jù)庫,共享 Schema,共享數(shù)據(jù)表)
來實(shí)現(xiàn),也就意味著,每個數(shù)據(jù)表都需要有一個租戶標(biāo)識(provider_id)
現(xiàn)在有數(shù)據(jù)庫表(user)
如下:
字段名 | 字段類型 | 描述 |
---|---|---|
id | BIGINT(20) | 主鍵 |
provider_id | BIGINT(20) | 服務(wù)商ID |
name | VARCHAR(30) | 姓名 |
將provider_id
視為租戶ID,用來隔離租戶與租戶之間的數(shù)據(jù),如果要查詢當(dāng)前服務(wù)商的用戶,SQL大致如下:
SELECT * FROM user t WHERE t.name LIKE '%Tom%' AND t.provider_id = 1;
試想一下,除了一些系統(tǒng)共用的表以外,其他租戶相關(guān)的表,我們都需要不厭其煩的加上AND t.provider_id = ?
查詢條件,稍不注意就會導(dǎo)致數(shù)據(jù)越界,數(shù)據(jù)安全問題讓人擔(dān)憂。
好在有了MybatisPlus這個神器,可以極為方便的實(shí)現(xiàn)多租戶SQL解析器
,官方文檔如下:
http://mp.baomidou.com/guide/tenant.html
這里終于進(jìn)入了正題,開始搭建一個極為簡單的開發(fā)環(huán)境吧!
新建SpringBoot環(huán)境
POM文件如下,主要集成了MybatisPlus以及H2數(shù)據(jù)庫(方便測試)
<?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>
數(shù)據(jù)源配置(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
對應(yīng)的H2數(shù)據(jù)庫初始化schema文件
#schema.sql DROP TABLE IF EXISTS user; CREATE TABLE user ( id BIGINT(20) NOT NULL COMMENT '主鍵', provider_id BIGINT(20) NOT NULL COMMENT '服務(wù)商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
基礎(chǔ)環(huán)境搭建完成,現(xiàn)在開始配置MybatisPlus多租戶相關(guān)的實(shí)現(xiàn)。
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解析處理攔截:增加租戶處理回調(diào)。 TenantSqlParser tenantSqlParser = new TenantSqlParser() .setTenantHandler(new TenantHandler() { @Override public Expression getTenantId() { // 從當(dāng)前系統(tǒng)上下文中取出當(dāng)前請求的服務(wù)商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)本身不需要執(zhí)行這樣的處理。 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> { }
單元測試
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() { // 在上下文中設(shè)置當(dāng)前服務(wù)商的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); // 檢查插入的數(shù)據(jù)是否自動填充了租戶ID Assert.assertEquals(apiContext.getCurrentProviderId(), user.getProviderId()); } @Test public void selectList() { userMapper.selectList(null).forEach((e) -> { log.info("#selectList, e={}", e); // 驗(yàn)證查詢的數(shù)據(jù)是否超出范圍 Assert.assertEquals(apiContext.getCurrentProviderId(), e.getProviderId()); }); } }
運(yùn)行結(jié)果
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老師)
從打印的日志不難看出,這個方案相當(dāng)完美,僅需簡單的配置,讓開發(fā)者完全忽略了(provider_id)字段的存在,同時又最大程度的保證了數(shù)據(jù)的安全性,可謂是一舉兩得!
感謝各位的閱讀!關(guān)于“MybatisPlus中多租戶架構(gòu)Multi-tenancy的示例分析”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學(xué)到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!
網(wǎng)頁題目:MybatisPlus中多租戶架構(gòu)Multi-tenancy的示例分析
路徑分享:http://vcdvsql.cn/article8/pdieop.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供品牌網(wǎng)站建設(shè)、云服務(wù)器、網(wǎng)站策劃、服務(wù)器托管、電子商務(wù)、網(wǎng)站維護(hù)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)