我是靠谱客的博主 酷酷超短裙,最近开发中收集的这篇文章主要介绍分库分表实践,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

1、为什么要分库分表?

数据库中的数据量不一定是可控的,在未进行分库分表的情况下,随着时间和业务的发展,表中的数据量会越来越大,相应地,数据操作,增删改查的开销也会越来越大;另外一个DB所能承载的数据量、数据处理能力都会成为瓶颈。

2、 分库分表实施策略

分库分表有垂直切分和水平切分两种

1)垂直切分即将表按照功能模块、关系密切程度划分,并部署到不同的库上。例如,商品信息和交易信息适合单独存放。

2)水平切分即当一个表中数据量过大时,可以把该表的数据按照某种规则,例如userID散列,进行划分,然后存储到多个结构相同的表,和不同的库上。


水平切分实践代码:userId为10位数字字符串,第8位表述分表位,第9位表示分库位。

public class DAORouteInterceptor implements MethodInterceptor {
    /** table index in userId */
    public static int TABLE_INDEX = 8;
    /** db index in userId */
    public static int DB_INDEX    = 9;
    @Override
    public Object invoke(MethodInvocation invocation) throws Throwable {
        Object[] args = invocation.getArguments();
        String userId = (String) args[args.length - 2];
        args[args.length - 2] = parseTableIndexByUserId(userId);
        args[args.length - 1] = parseDBIndexByUserId(userId);
        return invocation.proceed();
    }
    /**
     * parser tableIndex with userId
     * 
     * @param userId unique id of user
     * @return id of table
     */
    public static int parseTableIndexByUserId(String userId) {
        String tableIndex = StringUtil.substring(userId, TABLE_INDEX, TABLE_INDEX + 1);
        return Integer.valueOf(tableIndex);
    }
    /**
     * parser dbIndex with userId
     * 
     * @param userId unique id of user 
     * @return id of db
     */
    public static int parseDBIndexByUserId(String userId) {
        String dbIndex = StringUtil.substring(userId, DB_INDEX, DB_INDEX + 1);
        return Integer.valueOf(dbIndex);
    }
}


配置拦截器

切换所有分库分表计算逻辑放在DAO的父类BaseDAO的routeParser方法里。配置多数据源,根据表ID和库ID选择数据源的逻辑也放在BaseDAO里。子类DAO调用父类方法,拦截器拦截父类的分库分表方法。

拦截器配置如下:

	<!-- DAO sql route parser interceptor -->
	<bean id="daoRouteProxyCreator" class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">

<property name="interceptorNames">

<list>

<value>daoRouteInterceptor</value>

</list>

</property>

<property name="beanNames">

<value>BaseDAO</value>

</property>
	</bean>
	<bean id="daoRouteInterceptor" class="com.test.interceptor.DAORouteInterceptor" />

最后

以上就是酷酷超短裙为你收集整理的分库分表实践的全部内容,希望文章能够帮你解决分库分表实践所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(39)

评论列表共有 0 条评论

立即
投稿
返回
顶部