`
男人50
  • 浏览: 236437 次
  • 性别: Icon_minigender_1
  • 来自: 珠海
社区版块
存档分类
最新评论

Mycat 多租户方案 (1)

阅读更多
Mycat多租户方案

1、需求
1、1 需求图
这里写图片描述

1、2 环境说明
环境说明:
这里写图片描述

2 每租户一逻辑库方案
2.1实现思想
用户在用用户名登陆时,首先,需要根据用户名,查询到该用户所在的逻辑库,然后登陆成功后,将和会话信息存放在一起,方便在访问其他业务的时候,能够很方便的得到该逻辑库。与此同时,利用Mybatis 提供的 SQL拦截器机制与Mycat提供的注解,改写SQL语句为 sql = “/!mycat:schema=” + tenant + ” /” + sql; 这样Mycat在解析时,会自动路由到tenat逻辑库上执行SQL语句。

2.2 具体实现关键点
Mycat 模拟配置如下:
这里写图片描述

2.2.1、登陆接口申明
public Map login( String account, String password ); 根据用户名与密码登陆
返回值说明:
{
“code” : 0,
“data”: {
“userId” : 1,
“tenant” : “h_xsgjzx”
}
}
接口中的返回 tenant 参数,作为其他业务接口的第一参数。

现在有个关键点,就是根据用户名account 怎么知道用户存在哪个逻辑库呢?我给出用思路是,提供一个表来记录所有数据库中表的结合,global_user,字段基本如下:
ID account db_pos

然后提供一个接口,根据用户名查询出db_pos的值

然后再去实现该接口
实现1:查询刚才global_user表,获取tenent;也可以用redis缓存等。该处可以扩展。

2.2.2、控制层方法
通过成功登录系统后,就能得到 逻辑scheme : tenant。业务action的声明如下:
public Map findDepts( String tenant, 其他业务参数 ) ;

为了避免 tenant 参数污染业务层,DAO层的方法声明,,故在控制器层(Control)将 tenant
参数存入到 ThreadLocal 变量中。
现在提供 Tenant工具类,申明如下:

package persistent.prestige.modules.common.tenant;
public class TenantContextHolder {

    private static ThreadLocal<String> tenanThreadLocal = new ThreadLocal<String>();

    public static final void setTenant(String scheme) {
        tenanThreadLocal.set(scheme);
    }

    public static final String getTenant() {
        String scheme = tenanThreadLocal.get();
        if (scheme == null) {
            scheme = "";
        }
        return scheme;
    }

    public static final void remove() {
        tenanThreadLocal.remove();
    }

}

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23

那控制器层代码的伪代码如下:
public Map findDepts( String tenant, String businessP1 ) {
Map result = new HashMap();
try {
TenantContextHolder.setTenant(tenant);
//调用service层代码
} catch(Throw e) {
e.printStackTrace();
result.put(“msg”, “系统异常”);
result.put(“code”, 1);
} finally {
TenantContextHolder.remove();
System.out.println(“控制器层面,,移除tenant。。。”);
}

}

如果每个控制器层代码,都需要用上面的模板来做,未免有点。。。
所以为了统一处理 Tenant ,目前提供一个给予Spring AOP 的拦截器。
代码如下:

package persistent.prestige.modules.common.tenant;
import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import org.springframework.beans.factory.annotation.Autowired;
import persistent.prestige.modules.edu.service.UserSchemeService;
public class TenantControlInteceper implements MethodInterceptor {
    @Autowired
    private UserSchemeService userScemeService;
    @Override
    public Object invoke(MethodInvocation invocation) throws Throwable {
        try {
            if("login".equals(invocation.getMethod().getName())) {
                return invocation.proceed();
            }

            System.out.println("控制器层面,,计算 tenant。。。");
            Object[] args = invocation.getArguments();
            String tenant = "";
            if( args != null && args.length > 0) {
                tenant = (String)args[0];
            }
            TenantContextHolder.setTenant(tenant);
            return invocation.proceed();
        }finally {
            TenantContextHolder.remove();
            System.out.println("控制器层面,,移除tenant。。。");
        }

    }

}

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32

统一处理Tenant 的设置为移除;此处与代码中的有点差别,是因为,,根据用户登录名获取tenant的逻辑放在了上面登录接口中。
只要遵循这样一种编码规范,action方法的第一个参数的值为 tenant 就好。
配置一下拦截器【基于Spring AOP】
这里写图片描述

2.2.3、业务承载方法
业务方法无需改变;但是要利用Mybatis 拦截器改写SQL。代码和配置如下:
1)工具类

package persistent.prestige.platform.mybatis.Interceptor;

import java.lang.reflect.Field;

import org.apache.commons.lang.reflect.FieldUtils;

public class ReflectHelper {

    public static Object getFieldValue(Object obj , String fieldName ){  

        if(obj == null){  
            return null ;  
        }  

        Field targetField = getTargetField(obj.getClass(), fieldName);  

        try {  
            return FieldUtils.readField(targetField, obj, true ) ;  
        } catch (IllegalAccessException e) {  
            e.printStackTrace();  
        }   
        return null ;  
    }  

    public static Field getTargetField(Class<?> targetClass, String fieldName) {  
        Field field = null;  

        try {  
            if (targetClass == null) {  
                return field;  
            }  

            if (Object.class.equals(targetClass)) {  
                return field;  
            }  

            field = FieldUtils.getDeclaredField(targetClass, fieldName, true);  
            if (field == null) {  
                field = getTargetField(targetClass.getSuperclass(), fieldName);  
            }  
        } catch (Exception e) {  
        }  

        return field;  
    }  

    public static void setFieldValue(Object obj , String fieldName , Object value ){  
        if(null == obj){return;}  
        Field targetField = getTargetField(obj.getClass(), fieldName);    
        try {  
             FieldUtils.writeField(targetField, obj, value) ;  
        } catch (IllegalAccessException e) {  
            e.printStackTrace();  
        }   
    }   

}

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57

SQL拦截类

package persistent.prestige.platform.mybatis.Interceptor;

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

import org.apache.ibatis.executor.statement.RoutingStatementHandler;
import org.apache.ibatis.executor.statement.StatementHandler;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Plugin;
import org.apache.ibatis.plugin.Signature;
import org.apache.kahadb.page.Page;
import org.springframework.beans.factory.annotation.Autowired;

import persistent.prestige.modules.common.tenant.TenantContextHolder;
import persistent.prestige.modules.edu.dao.TeacherUserDao;

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

    @Override
    public Object intercept(Invocation invocation) throws Throwable {

        String tenant = TenantContextHolder.getTenant();

        if(tenant == null || tenant == "") {
            System.out.println("tenant 为空,不需要改写sql语句");
            return invocation.proceed();
        }

        if (invocation.getTarget() instanceof RoutingStatementHandler) {

            System.out.println("aaaaaaa");
            RoutingStatementHandler statementHandler = (RoutingStatementHandler) invocation
                    .getTarget();
            StatementHandler delegate = (StatementHandler) ReflectHelper
                    .getFieldValue(statementHandler, "delegate");
            BoundSql boundSql = delegate.getBoundSql();
            Object obj = boundSql.getParameterObject();


            // 通过反射获取delegate父类BaseStatementHandler的mappedStatement属性
            MappedStatement mappedStatement = (MappedStatement) ReflectHelper
                    .getFieldValue(delegate, "mappedStatement");
            // 拦截到的prepare方法参数是一个Connection对象
            Connection connection = (Connection) invocation.getArgs()[0];
            // 获取当前要执行的Sql语句,也就是我们直接在Mapper映射语句中写的Sql语句
            String sql = boundSql.getSql();
            // 给当前的page参数对象设置总记录数
            System.out.println("处理之前" + sql);
            //对 sql 增加 mycat 注解


            sql = "/*!mycat:schema=" + tenant + " */" + sql;

            System.out.println("加入处理后:" + sql);



            ReflectHelper.setFieldValue(boundSql, "sql", sql);

        }
        return invocation.proceed();
    }

    @Override
    public Object plugin(Object target) {
        // TODO Auto-generated method stub
        if (target instanceof StatementHandler) {
            return Plugin.wrap(target, this);
        } else {
            return target;
        }
    }

    @Override
    public void setProperties(Properties properties) {
        // TODO Auto-generated method stub

    }

}

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    73
    74
    75
    76
    77
    78
    79
    80
    81
    82
    83
    84
    85
    86

3)配置如下:

这里写图片描述

2.2.4、方案优缺点
优点:
对业务代码侵入少,开发人员无需关注数据在哪个逻辑库上,隔离性好。
缺点
如果需要对所有租户的数据进行汇聚的话,需要业务上去实现。

该方案代码:请关注如下代码:
控制层 persistent.prestige.modules.edu.action. EduControl
里面有login的模拟实现,业务方法的实现。
拦截器
persistent.prestige.modules.common.tenant. TenantControlInteceper
persistent.prestige.platform.mybatis.Interceptor. TenantInterceptor

相关代码我已上传到:
https://github.com/dingwpmz/Mycat-Demo

3 多租户同一逻辑库方案
3.1实现思想
每个分片对应一个集团,每个业务表中增加一个分片字段 db_pos,,类型为int型,比如制定如下字段:
0 h_xsgizx
20 h_xsyz
40 m_fhzx
60 m_mzzx
Mycat 提供一个逻辑库,其中每个分片代表一个集团,,由于集团数量是固定的,故可以采用 分片枚举 进行分片。
 
这种方案,不是传统意义上的多租户,而是用mycat枚举分片规则。配置分片就好。

3.2.4、方案优缺点
优点:
实现简单,不需要增加额外的拦截器等。并且多库汇聚非常方便。
缺点:
在业务开发中,需要在方法参数列表中,特别是DAO层,增加 分片字段参数。
2
0
分享到:
评论

相关推荐

    mycat多租户解决方案二

    【Mycat多租户解决方案】是针对SAAS(Software as a Service)应用设计的一种高效且资源节省的数据隔离策略。在传统的多租户模式中,每个租户通常需要单独的数据库实例,这不仅消耗大量资源,还增加了管理和运维的...

    多租户方案

    ### 多租户方案:Mycat在多租户环境中的应用 #### 一、多租户概述 在软件架构中,“多租户”是指一个单一的应用实例能够为多个不同的客户(租户)提供服务,并确保每个租户的数据隔离与安全性。这种方式可以有效地...

    mycat权威指南

    “多租户”是Mycat的另一个重要特性,它支持在一个物理数据库实例上部署多个独立的应用或客户,每个应用或客户被称为一个租户。Mycat通过租户隔离,确保了不同租户之间的数据安全性和互不影响,同时减少了硬件资源的...

    Mycat_V1.6.0

    - 多租户:Mycat能够支持多租户的数据库架构,每个租户可以使用相同的数据表结构,但数据相互隔离。 在“快速入门”章节中,提供了在短时间内快速上手Mycat的基本方法,包括服务安装、配置和服务启动等内容。这部分...

    Mycat-权威学习指南

    - 多租户:Mycat支持多租户模式,允许多个租户共享同一个Mycat实例,通过不同的逻辑库来区分。 **3. Mycat分片策略** Mycat提供分片功能,主要有垂直分片和水平分片。垂直分片是指把不同的表切分到不同的数据库中...

    mycat的全面文档

    1. 入门篇介绍了Mycat的基本概念,如数据库中间件、逻辑库、逻辑表、分片节点、节点主机、分片规则、全局序列号以及多租户等关键术语,这些都是理解Mycat的基本构建块。 2. 快速入门章节带领读者通过简短的介绍和...

    mycat-权威指南.pdf

    这节可能会介绍Mycat全局表、ER分片表、多对多关联、常用分片规则以及权限控制和多租户支持等高级概念。 ### 第11章 常见问题与解决方案 本章集中解答了Mycat用户可能遇到的问题,并提供了相应的解决方案。 ### 第...

    从单租户改进到多租户模式的简单实现.docx

    单租户模式是一种传统的软件架构,其中每个...这个文档提供了一个简单的实现方案,但它只是多租户架构设计的一个起点。实际应用中,还需要考虑性能、安全性、数据隔离、扩展性等多个方面,以确保系统的稳定性和可靠性。

    Mycat-server-1.6.7.3-release-20190927161129-win.tar.gz

    6. **多租户支持**:Mycat允许在同一实例上为不同应用或客户提供独立的数据空间,实现多租户环境下的资源隔离。 **Mycat工作流程:** 1. 应用程序发送SQL请求至Mycat服务器。 2. MyCat接收到请求后,解析SQL语句。...

    Mycat-最详细简介安装及使用说明-注意事项

    - 支持多租户解决方案。 - 支持分布式事务(弱XA),并且在1.6.5版本中引入了对XA分布式事务的支持。 - 支持全局序列号,解决了分布式环境下的主键生成问题。 - 分片规则丰富且易于扩展,支持插件化开发。 - 强大的...

    Mycat权威指南第一版_V1.5.1

    多租户支持是Mycat的重要功能之一,它允许在同一个Mycat实例中管理多个客户的数据,同时保证数据的隔离。这对于SaaS(软件即服务)提供商来说非常重要,能够在同一个数据库系统上提供多租户服务,而不需要为每个租户...

    Mycat数据库中间件技术最佳实践手册-中台

    此外,Mycat支持多租户,能为不同业务提供隔离的运行环境。 ### 3. 基本概念 3.1. **数据库中间件**:数据库中间件是位于应用和数据库之间的软件层,它处理数据访问的复杂性,提供透明的数据访问服务。 3.2. **...

    mycat基本工具书

    多租户支持是指Mycat可以在同一套硬件资源上为多个用户提供隔离的服务环境,每个租户可以有自己的逻辑库、逻辑表等。 #### 四、Mycat的配置 Mycat的配置主要包括schema.xml、server.xml等文件,它们用于定义Mycat...

    Mycat从入门到精通之案例分析和案例类型.pptx

    - **Mycat支持**:Mycat支持多租户方案,通过动态路由的方式实现不同租户之间的数据隔离。 - **优势**: - 降低了硬件成本; - 减少了运维负担; - 提高了资源利用率。 ##### 分表大数据 - **概念**:分表是指...

    Mycat权威指南第一版

    - **多租户**:多租户技术允许一个MyCAT实例承载多个租户的数据,每个租户的数据可以相互独立。 3. **快速入门** Mycat入门包括快速镜像方式体验、服务安装与配置、服务启动与启动设置、使用demo等。 4. **日志...

    MySQL MyCAT安装应用经典案例实战

    - **多租户应用**:针对不同用户提供独立的数据库服务,确保数据隔离的同时又便于集中管理。 - **报表系统**:支持复杂的查询和数据分析,适用于构建高性能的报表系统。 - **海量数据实时查询**:通过分布式架构,...

    基于MyCat分布式数据库中间件技术的研究与应用.pdf

    此外,MyCat的多租户应用开发和云平台基础设施的支持,为分布式架构的适应性和灵活性提供了有力的保障。 MyCat的技术优势表现在其能够支持读写分离机制,缓解写库的压力并提高数据库的并发查询能力,从而提高数据库...

Global site tag (gtag.js) - Google Analytics