Spring + JPA实现数据库读写分离

标签: spring jpa 数据库 | 发表时间:2016-05-11 10:08 | 作者:
出处:http://shift-alt-ctrl.iteye.com

    本文展示了如何在Spring环境中使用JPA实现dataSource的读写分离(本文没有使用JTA事务),这个东西看起来简单,其实实现起来比较蹩脚,与JDBC有很大区别。

    1)使用Spring中的AbstractRoutingDataSource,辅助程序在运行时选择合适的dataSource。

    2)可以使用@Master、@Slave注释来强制dao方法调用必须使用master或者slave的数据库源。

    3)本例提供的ReadWriteDataSourceRouter可以根据当前Transaction的readOnly特性,将SQL调用按需分发给master或者slaves;可以指定多个slaves,可以简单的负载均衡。

 

1、persistence.xml

    如果我们不适用JTA事务的话,这个文件可以为空即可。

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0"
             xmlns="http://java.sun.com/xml/ns/persistence" 
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://java.sun.com/xml/ns/persistence 
             http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
    <!--
    <persistence-unit name="trial" transaction-type="RESOURCE_LOCAL">
    </persistence-unit>
    -->
</persistence>

 

2、ReadWriteDataSourceRouter.java

**
 * Created by liuguanqing on 16/5/10.
 * 全量读写分离
 */
public class ReadWriteDataSourceRouter extends AbstractRoutingDataSource {

    private Integer slaves;//slaves的个数

    private Random random = new Random();
    //如果基于JDK 7+,可以使用ThreadLocalRandom

    public void setSlaves(Integer slaves) {
        this.slaves = slaves;
    }

    @Override
    protected Object determineCurrentLookupKey() {
        boolean isReadOnly = TransactionSynchronizationManager.isCurrentTransactionReadOnly();
        if(!isReadOnly) {
            return "WRITE";
        }
        //如果是只读,可以从任意一个slave中执行
        return "READ_" + random.nextInt(slaves);
        //如果基于JDK 7+
        //ThreadLocalRandom random = ThreadLocalRandom.current();
    }
}

 

    java类中使用了一些约定的字符串,比如“WRITE”对应的为masterDataSource,所有的slaves对应的key必须为“READ_” + 数字。(参见下文配置)

 

3、spring-datasource.xml配置摘要:

<bean id="masterDataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
    <property name="url" value="jdbc:mysql://192.168.1.100:3306/test?useUnicode=true&amp;characterEncoding=UTF-8&amp;autoReconnect=false"></property>
    <property name="username" value="root"></property>
    <property name="password" value="root"></property>
    <property name="maxActive" value="128"></property>
    <property name="maxIdle" value="6"></property>
    <property name="minIdle" value="2"></property>
    <property name="maxWait" value="30000"></property>
    <property name="defaultAutoCommit" value="true"></property>
</bean>

<bean id="slaveDataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
    <property name="url" value="jdbc:mysql://192.168.1.101:3306/test?useUnicode=true&amp;characterEncoding=UTF-8&amp;autoReconnect=false"></property>
    <property name="username" value="root"></property>
    <property name="password" value="root"></property>
    <property name="maxActive" value="128"></property>
    <property name="maxIdle" value="6"></property>
    <property name="minIdle" value="2"></property>
    <property name="maxWait" value="30000"></property>
    <property name="defaultAutoCommit" value="true"></property>
</bean>

<bean id="rwDataSource" class="com.test.demo.dataSource.TypedReadWriteDataSourceRouter">
    <property name="slaves" value="2"/><!-- 允许read操作的节点个数 -->
    <property name="targetDataSources">
        <map key-type="java.lang.String">
            <entry key="WRITE" value-ref="masterDataSource"/>
            <entry key="READ_0" value-ref="slaveDataSource" />
            <entry key="READ_1" value-ref="masterDataSource" /><!-- 允许部分read到slave上 -->
        </map>
    </property>
    <property name="defaultTargetDataSource" ref="slaveDataSource"/><!-- or master -->
</bean>

<bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
    <property name="persistenceXmlLocation" value="classpath:persistence.xml" />
    <property name="dataSource" ref="rwDataSource" />
    <!-- model的package-->
    <property name="packagesToScan" value="com.test.demo.model"/>
    <property name="jpaVendorAdapter">
    	<!-- JPA的实现,有多种,请根据实际情况选择 -->
        <bean class="org.springframework.orm.jpa.vendor.EclipseLinkJpaVendorAdapter">
            <property name="showSql" value="false"/>
            <property name="generateDdl" value="false"/>
            <property name="database" value="MYSQL"/>
            <property name="databasePlatform" value="org.eclipse.persistence.platform.database.MySQLPlatform" />
        </bean>
    </property>
    <property name="jpaProperties">
        <props>
            <prop key="eclipselink.weaving">false</prop>
            <prop key="eclipselink.cache.shared.default">false</prop>
            <prop key="eclipselink.read-only">true</prop>
        </props>
    </property>
</bean>


<!-- 声明一个Spring提供的JPA事务管理器,传入的参数是Spring中的实体管理器工厂 -->
<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
    <property name="entityManagerFactory" ref="entityManagerFactory"/>
</bean>
<context:annotation-config/>
<tx:annotation-driven transaction-manager="transactionManager" />

 

4、TesUser.java(model样例) 

@Entity
@Table(name="test_user",schema = "vipkid")
public class TestUser {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private int id;

    @Column(name = "name")
    private String name;

    @Column(name = "password")
    private String password;

    // 创建时间
    @Temporal(TemporalType.DATE)
    @Column(name = "created")
    private Date created;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

 

5、TestUserRepository.java(DAO层)

@Repository
public class TestUserRepository  {

    @PersistenceContext
    private EntityManager entityManager;


    @Transactional(readOnly = true)
    //To slave
    public TestUser getFromSlave(int id) {
        String sql = "select T from TestUser T where T.id = :id";
        TypedQuery<TestUser> query = entityManager.createQuery(sql,TestUser.class);
        query.setParameter("id",id);
        return query.getSingleResult();
    }

    @Transactional(readOnly = false)
    //To master
    public TestUser getFromMaster(int id) {
        String sql = "select T from TestUser T where T.id = :id";
        TypedQuery<TestUser> query = entityManager.createQuery(sql,TestUser.class);
        query.setParameter("id",id);
        return query.getSingleResult();
    }
}

 



已有 0 人发表留言,猛击->> 这里<<-参与讨论


ITeye推荐



相关 [spring jpa 数据库] 推荐:

Spring + JPA实现数据库读写分离

- - 深入一点,你会更加快乐
    本文展示了如何在Spring环境中使用JPA实现dataSource的读写分离(本文没有使用JTA事务),这个东西看起来简单,其实实现起来比较蹩脚,与JDBC有很大区别.     1)使用Spring中的AbstractRoutingDataSource,辅助程序在运行时选择合适的dataSource.

使用 Spring Data JPA 简化 JPA 开发

- -
Spring Data JPA 让一切近乎完美. 通过前面的分析可以看出,Spring 对 JPA 的支持已经非常强大,开发者只需关心核心业务逻辑的实现代码,无需过多关注 EntityManager 的创建、事务处理等 JPA 相关的处理,这基本上也是作为一个开发框架而言所能做到的极限了. 然而,Spring 开发小组并没有止步,他们再接再厉,于最近推出了 Spring Data JPA 框架,主要针对的就是 Spring 唯一没有简化到的业务逻辑代码,至此,开发者连仅剩的实现持久层业务逻辑的工作都省了,唯一要做的,就只是声明持久层的接口,其他都交给 Spring Data JPA 来帮你完成.

Spring Data JPA 简单介绍

- tangfl - BlogJava-首页技术区
考虑到公司应用中数据库访问的多样性和复杂性,目前正在开发UDSL(统一数据访问层),开发到一半的时候,偶遇SpringData工程. 于是就花了点时间了解SpringData,可能UDSL II期会基于SpringData做扩展. 介绍:针对关系型数据库,KV数据库,Document数据库,Graph数据库,Map-Reduce等一些主流数据库,采用统一技术进行访问,并且尽可能简化访问手段.

spring data jpa简单实例

- - 编程语言 - ITeye博客
我们都知道Spring是一个非常优秀的JavaEE整合框架,它尽可能的减少我们开发的工作量和难度.   在持久层的业务逻辑方面,Spring开源组织又给我们带来了同样优秀的Spring Data JPA.   通常我们写持久层,都是先写一个接口,再写接口对应的实现类,在实现类中进行持久层的业务逻辑处理.

了解 Spring Data JPA - hungerW

- - 博客园_首页
自 JPA 伴随 Java EE 5 发布以来,受到了各大厂商及开源社区的追捧,各种商用的和开源的 JPA 框架如雨后春笋般出现,为开发者提供了丰富的选择. 它一改之前 EJB 2.x 中实体 Bean 笨重且难以使用的形象,充分吸收了在开源社区已经相对成熟的 ORM 思想. 另外,它并不依赖于 EJB 容器,可以作为一个独立的持久层技术而存在.

Spring Data JPA,基础学习笔记.

- - ITeye博客
最好先学习 JPA 方面的知识....在这里使用的是 Hibernate. 也已经使用了一段时间,看什么都不如看官方文档,我这里也只是写个笔记记录一下,如果能帮助到其他人,很开心 .算是个 demoshow 吧.这里也只写了一些我觉得比较有用的地方.其他一些使用知识,请参见官方文档:http://static.springsource.org/spring-data/data-jpa/docs/current/reference/html/.

使用Java 8 Streams和Spring Data JPA流式传输MySQL结果

- -
2015年10月19日|  KrešimirNesek. 从1.8版开始,Spring数据项目包含一个有趣的功能 - 通过一个简单的API调用,开发人员可以请求将数据库查询结果作为Java 8流返回. 在技​​术上可行并且由底层数据库技术支持的情况下,结果将逐个流式传输,并且可以使用流操作进行处理.

在Spring Data JPA中使用Update query更新实体

- -
使用诸如Hibernate之类的对象关系映射(ORM)工具,通常通过首先从数据库中获取实体,修改某些字段,然后再次持久化实体来修改实体. 在许多情况下,这是一种很好的方法,但在某些情况下,这可能并不理想. 例如,如果要更新实体集合(即数据库中的行),或者需要大量数据来构造实体对象. 在后一种情况下,例如,可能需要太多资源来组装实体对象以仅改变单个字段的值.

Spring+MyBatis实践——MyBatis访问数据库

- - 开源软件 - ITeye博客
    在http://dufengx201406163237.iteye.com/blog/2102054中描述了工程的配置,在此记录一下如何使用MyBatis访问数据库;. . .

spring实现数据库读写分离

- - 行业应用 - ITeye博客
现在大型的电子商务系统,在数据库层面大都采用读写分离技术,就是一个Master数据库,多个Slave数据库. Master库负责数据更新和 实时数据查询,Slave库当然负责非实时数据查询. 因为在实际的应用中,数据库都是读多写少(读取数据的频率高,更新数据的频率相对较少),而读取数据 通常耗时比较长,占用数据库服务器的CPU较多,从而影响用户体验.