当前位置：首页 > 文章列表 > 文章 > java教程 > MyBatisPlus多租户实现详解

MyBatisPlus多租户实现详解

2025-07-16 16:52:45 0浏览收藏

**MyBatisPlus多租户实现全攻略：数据隔离与架构优化** 本文深入探讨MyBatisPlus多租户架构的核心实现，旨在帮助开发者构建安全可靠的多租户系统。该架构通过数据隔离，确保各租户数据互不干扰。文章详细讲解了租户标识传递、MyBatisPlus拦截器配置、数据表改造等关键步骤，并提供代码示例。同时，针对公共数据处理、性能优化（如索引、缓存、读写分离）以及测试验证等方面提供实用建议。无论你是初学者还是有经验的开发者，都能从本文中获得MyBatisPlus多租户架构的全面指导，从而构建高效、安全的多租户应用。

MyBatisPlus多租户架构通过数据隔离实现租户间互不干扰，核心步骤包括：1. 使用ThreadLocal传递租户标识；2. 配置MyBatisPlus拦截器动态修改SQL加入租户过滤条件；3. 数据表增加租户ID字段；4. 从ThreadLocal获取租户ID；5. 拦截器判断是否需加入AND tenant_id = #{tenantId}条件；6. 利用自动填充功能插入更新时填充租户ID；7. 提供开关忽略多租户过滤以支持管理员查询全局数据。租户ID传递可选ThreadLocal或RequestContextHolder，微服务下可结合分布式追踪系统。拦截器需实现Interceptor接口，在intercept方法中检查忽略策略、获取租户ID、拼接SQL。公共数据可通过独立无租户字段的表管理，并使用缓存优化性能。架构优化还包括索引、读写分离、分库分表等策略。验证正确性需编写单元和集成测试，模拟多租户请求并验证数据隔离与性能表现。

MyBatisPlus多租户架构的完整实现方案

MyBatisPlus多租户架构，核心在于数据隔离。实现方案围绕着如何识别租户、隔离数据展开，目标是让每个租户只能访问自己的数据，互不干扰。

解决方案

实现MyBatisPlus多租户架构，主要分为以下几个步骤：

租户标识的传递： 需要一个机制来传递当前请求的租户ID。常见的做法是使用ThreadLocal，在请求进入时将租户ID放入ThreadLocal，在请求结束时清除。
MyBatisPlus拦截器的配置： MyBatisPlus提供了自定义拦截器的接口，可以编写一个拦截器，在SQL执行前动态修改SQL，加入租户ID的过滤条件。
数据表的改造： 需要在需要隔离的数据表中增加一个租户ID字段。
租户ID的获取： 在拦截器中，需要从ThreadLocal中获取租户ID。
SQL的动态修改： 拦截器需要判断当前执行的SQL是否需要进行多租户过滤，如果需要，则在SQL中加入AND tenant_id = #{tenantId}这样的条件。
公共字段自动填充： 利用MyBatisPlus的自动填充功能，在插入和更新数据时，自动填充租户ID。
忽略多租户的场景处理： 某些场景下，可能需要查询所有租户的数据，例如系统管理员。可以提供一个开关，控制是否启用多租户过滤。

如何选择合适的租户ID传递方式？

ThreadLocal是一种常见的选择，但需要注意内存泄漏问题，确保在请求结束后及时清除。另外，也可以考虑使用RequestContextHolder，将租户ID放在请求头或者Session中传递。选择哪种方式取决于具体的应用场景和技术架构。如果使用微服务架构，可能需要考虑使用分布式追踪系统来传递租户ID。

MyBatisPlus拦截器如何编写？

编写MyBatisPlus拦截器，需要实现Interceptor接口，并重写intercept方法。在intercept方法中，可以获取到当前执行的SQL语句，并进行修改。以下是一个简单的示例：

import com.baomidou.mybatisplus.core.plugins.InterceptorIgnore;
import com.baomidou.mybatisplus.core.plugins.InterceptorIgnoreHelper;
import org.apache.ibatis.executor.statement.StatementHandler;
import org.apache.ibatis.plugin.*;
import org.springframework.stereotype.Component;

import java.sql.Connection;
import java.util.Properties;

@Intercepts({@Signature(type = StatementHandler.class, method = "prepare", args = {Connection.class, Integer.class})})
@Component
public class TenantInterceptor implements Interceptor {

    private final String tenantIdFieldName = "tenant_id";

    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        // 1. 检查是否忽略多租户
        if (InterceptorIgnoreHelper.willIgnoreTenantLine(InterceptorIgnore::tenantLine)) {
            return invocation.proceed();
        }

        // 2. 获取当前租户ID
        Long tenantId = TenantContext.getTenantId(); // 假设TenantContext使用ThreadLocal存储租户ID

        // 3. 如果没有租户ID，则抛出异常
        if (tenantId == null) {
            throw new RuntimeException("TenantId is null");
        }

        // 4. 获取SQL语句
        StatementHandler statementHandler = (StatementHandler) invocation.getTarget();
        String sql = statementHandler.getBoundSql().getSql();

        // 5. 修改SQL语句，加入租户ID过滤条件
        String modifiedSql = addTenantIdCondition(sql, tenantId);
        statementHandler.getBoundSql().setSql(modifiedSql);

        return invocation.proceed();
    }

    private String addTenantIdCondition(String sql, Long tenantId) {
        // 这里需要根据具体的SQL语句进行判断，是否需要加入租户ID过滤条件
        // 可以使用正则表达式或者字符串匹配等方式
        // 这里只是一个简单的示例
        if (sql.toLowerCase().contains("where")) {
            return sql + " AND " + tenantIdFieldName + " = " + tenantId;
        } else {
            return sql + " WHERE " + tenantIdFieldName + " = " + tenantId;
        }
    }

    @Override
    public Object plugin(Object target) {
        return Plugin.wrap(target, this);
    }

    @Override
    public void setProperties(Properties properties) {
        // 可以设置一些属性，例如租户ID字段名
    }
}

如何处理公共数据？

某些数据可能需要在所有租户之间共享，例如字典数据、系统配置等。可以创建一个公共表，不包含租户ID字段。在查询这些数据时，不需要进行多租户过滤。另外，也可以考虑使用缓存来提高查询效率。

多租户架构的性能优化有哪些策略？