微服务整合mybatisplus多租户

在微服务架构中，每个服务都是独立的，需要自己管理自己的数据源。如果需要实现多租户功能，可以在每个服务中引入mybatisplus，通过配置动态数据源实现租户隔离。

1. 引入mybatisplus

在每个服务的pom.xml文件中添加如下依赖：

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.x.x</version>
</dependency>

2. 配置动态数据源

在每个服务中配置动态数据源，可以使用mybatisplus提供的DynamicDataSource类来实现。DynamicDataSource类继承AbstractRoutingDataSource，可以根据不同的租户来切换数据源。

@Configuration
public class DataSourceConfig {
    @Autowired
    private DataSourceProperties properties;
 
    @Bean
    @ConfigurationProperties("spring.datasource")
    public DataSource dataSource() {
        return properties.initializeDataSourceBuilder().build();
    }
 
    @Bean
    public DataSource dynamicDataSource(DataSource dataSource) {
        Map<Object, Object> targetDataSources = new HashMap<>();
        // 配置多个数据源
        targetDataSources.put(TenantContextHolder.getTenantId(), dataSource);
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        dynamicDataSource.setTargetDataSources(targetDataSources);
        dynamicDataSource.setDefaultTargetDataSource(dataSource);
        return dynamicDataSource;
    }
 
    @Bean
    public SqlSessionFactory sqlSessionFactory(DataSource dynamicDataSource) throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
        sqlSessionFactory.setDataSource(dynamicDataSource);
        return sqlSessionFactory.getObject();
    }
}

3. 切换数据源

在每个服务中实现租户隔离，可以通过拦截器来实现。拦截器可以拦截每个请求，并根据请求中的租户id来切换数据源。

@Component
public class DynamicDataSourceInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        String tenantId = request.getHeader("tenantId");
        if (StringUtils.isNotBlank(tenantId)) {
            TenantContextHolder.setTenantId(tenantId);
        }
        return true;
    }
 
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        TenantContextHolder.clear();
    }
}

4. 实现多租户功能

在每个服务中实现多租户功能，需要在每个实体类中添加租户id字段，并在mybatisplus中配置租户id的自动填充。

@Data
@TableName("user")
public class User {
    @TableId(type = IdType.AUTO)
    private Long id;
    private String name;
    private Integer age;
    @TableField(fill = FieldFill.INSERT)
    private Date createTime;
    @TableField(fill = FieldFill.INSERT_UPDATE)
    private Date updateTime;
    @TableLogic
    @TableField(fill = FieldFill.INSERT)
    private Integer deleted;
    @TableField(fill = FieldFill.INSERT)
    private String tenantId;
}

在mybatisplus的配置文件中添加租户id的自动填充：

@Configuration
public class MybatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        TenantLineInnerInterceptor tenantLineInnerInterceptor = new TenantLineInnerInterceptor();
        tenantLineInnerInterceptor.setTenantLineHandler(new TenantLineHandler() {
            @Override
            public Expression getTenantId() {
                return new LongValue(TenantContextHolder.getTenantId());
            }
 
            @Override
            public String getTenantIdColumn() {
                return "tenant_id";
            }
 
            @Override
            public boolean ignoreTable(String tableName) {
                return false;
            }
        });
        interceptor.addInnerInterceptor(tenantLineInnerInterceptor);
        return interceptor;
    }
}

以上就是整合mybatisplus多租户的步骤，可以根据实际需求进行调整。