AI 助理
备案控制台
开发者社区 数据库 文章 正文

Spring分布式事务在service中动态切换数据源

2018-02-28 2357
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

Spring分布式事务在service中动态切换数据源

项目采用的是struts2的+弹簧+ ibatis的架构，下面是关键部分代码：

applicationContext.xml中：

[html] 查看纯文本

  1. <？xml version = “1.0” encoding = “UTF-8” ？>
  2. < beans xmlns = “http://www.springframework.org/schema/beans”
  3.        xmlns：xsi = “http://www.w3.org/2001/XMLSchema-instance”
  4.        xmlns：context = “http://www.springframework.org/schema/context”
  5.        xmlns：aop = “http://www.springframework.org/schema/aop”
  6.        xmlns：tx = “http://www.springframework.org/schema/tx”
  7.        xsi：schemaLocation =“http://www.springframework.org/schema/beans
  8.            http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
  9.            http://www.springframework.org/schema/context
  10.            http://www.springframework.org/schema/context/spring-context-2.5.xsd
  11.            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
  12.            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd“
  13.            default-autowire = “byName” default-lazy-init = “false” >
  15.     < context：component-scan base-package = “com.ssi。*” />
  16.     <！ - 属性文件读入 - >
  17.     < bean id = “propertyConfigurer” class = “org.springframework.beans.factory.config.PropertyPlaceholderConfigurer” >>
  18.         < property name = “locations” >
  19.             < list >
  20.                 < value > classpath *：jdbc.properties </ value >
  21.             </ list >
  22.         </ property >
  23.     </ bean >
  26.     <！ - 配置sqlMapclient - >
  27.     < bean id = “sqlMapClient” class = “org.springframework.orm.ibatis.SqlMapClientFactoryBean” >
  28.         < property name = “configLocation” value = “classpath：ibatis-sqlmap-config.xml” />
  29.         < property name = “dataSource” ref = “dataSource” />
  30.     </ bean >
  32.     < bean id = “sqlMapClient1” class = “org.springframework.orm.ibatis.SqlMapClientFactoryBean” >
  33.         < property name = “configLocation” value = “classpath：ibatis-sqlmap-config.xml” />
  34.         < property name = “dataSource” ref = “db1” />
  35.     </ bean >
  36.     < bean id = “sqlMapClient2” class = “org.springframework.orm.ibatis.SqlMapClientFactoryBean” >
  37.         < property name = “configLocation” value = “classpath：ibatis-sqlmap-config.xml” />
  38.         < property name = “dataSource” ref = “db2” />
  39.     </ bean >
  40.     < bean id = “sqlMapClientCenter” class = “org.springframework.orm.ibatis.SqlMapClientFactoryBean” >
  41.         < property name = “configLocation” value = “classpath：ibatis-sqlmap-config.xml” />
  42.         < property name = “dataSource” ref = “center” />
  43.     </ bean >
  45.     < bean id = “dynamicSqlMapClientDaoSupport” class = “com.ssi.dao.DynamicSqlClientDaoSupport” >>
  46.         < property name = “targetSqlMapClients” >
  47.             < map >
  48.                 < entry key = “db1” value-ref = “sqlMapClient1” />
  49.                 < entry key = “db2” value-ref = “sqlMapClient2” />
  50.                 < entry key = “center” value-ref = “sqlMapClientCenter” />
  51.             </ map >
  52.         </ property >
  53.         < property name = “defaultSqlMapClient” ref = “sqlMapClientCenter” />
  54.     </ bean >
  55.     < bean id = “ibatisDaoSupport” class = “com.ssi.dao.IbatisDaoSupport” parent = “dynamicSqlMapClientDaoSupport” > </bean >
  57.     < bean id = “userDao” class = “com.ssi.dao.impl.UserDaoImpl” parent = “ibatisDaoSupport” > </ bean >
  59.     <！ - 支持@AspectJ标记 - >
  60.     < aop：aspectj-autoproxy proxy-target-class = “true” />
  62.     <！ - 配置JTA的事务管理器 - >
  63.     < bean id = “atomikosTransactionManager” class = “com.atomikos.icatch.jta.UserTransactionManager” init-method = “init” destroy-method = “close” >
  64.         < property name = “forceShutdown” value = “true” />
  65.     </ bean >
  66.     < bean id = “atomikosUserTransaction” class = “com.atomikos.icatch.jta.UserTransactionImp” >
  67.         < property name = “transactionTimeout” value = “300” />
  68.     </ bean >
  69.     < bean id = “springTransactionManager” class = “org.springframework.transaction.jta.JtaTransactionManager”>
  70.         < property name = “transactionManager” ref = “atomikosTransactionManager” />
  71.         < property name = “userTransaction” ref = “atomikosUserTransaction” />
  72.     </ bean >
  73.     <！ - 配置通知 - >
  74.     < tx：advice id = “txAdvice” transaction-manager = “springTransactionManager” >
  75.         < tx：attributes >
  76.              < tx：method name = “*” rollback-for = “Exception，RuntimeException，com.ssi.exception.SystemException” propagation = “REQUIRED” />
  77.         </ tx：attributes >
  78.     </ tx：advice >
  82.     <！ - 以AspectJ方式定义AOP - >
  84.     < aop：config >
  85.         < aop：advisor pointcut = “execution（* com.ssi.service .. * Service *。*（..））” advice-ref = “txAdvice”/>
  86.     </ aop：config >
  89.     <！ - spring定时器任务开始 - >
  90.     < bean name = “job” class = “org.springframework.scheduling.quartz.JobDetailBean” >
  91.          < property name = “jobClass” >
  92.              < value > com.ssi.action.TimerAction </ value >
  93.          </ property >
  94.          < property name = “jobDataAsMap” >
  95.              < map >
  96.                   <！ - timeout属性设定了当服务器启动后过10秒钟首次调用你的JobAction - >
  97.                   < entry key = “timeout” >
  98.                      < value > 10 </ value >
  99.                   </ entry >
  100.              </ map >
  101.          </ property >
  102.     </ bean >
  103.     < bean id = “cronTrigger” class = “org.springframework.scheduling.quartz.CronTriggerBean” >
  104.          < property name = “jobDetail” >
  105.              < ref bean = “job” />
  106.          </ property >
  107.          < property name = “cronExpression” >
  108.              < 值> 0 53 15？* MON-FRI </ value >
  109.          </ property >
  110.     </ bean >
  111.     < bean class = “org.springframework.scheduling.quartz.SchedulerFactoryBean” autowire = “no” >
  112.          < property name = “triggers” >
  113.              < list >
  114.                  < ref local = “cronTrigger” />
  115.              </ list >
  116.          </ property >
  117.     </ bean >
  118.     <！ - spring定时器任务结束 - >
  120. </ beans >

 

[html] 查看纯文本

的applicationContext-datasource.xml

[html] 查看纯文本

  1. <？xml version = “1.0” encoding = “UTF-8” ？>
  2. < beans xmlns = “http://www.springframework.org/schema/beans”
  3.     xmlns：xsi = “http://www.w3.org/2001/XMLSchema-instance”
  4.     xmlns：aop = “http://www.springframework.org/schema/aop”
  5.     xmlns：tx = “http://www.springframework.org/schema/tx”
  6.     xsi：schemaLocation =“
  7.     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  8.     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
  9.     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd“ >
  11.     <！ - 指定春天配置中用到的属性文件 - >
  12.     < bean id = “propertyConfig” class = “org.springframework.beans.factory.config.PropertyPlaceholderConfigurer”>>
  13.         < property name = “locations” >
  14.             < list >
  15.                 < value > classpath：jdbc.properties </ value >
  16.             </ list >
  17.         </ property >
  18.     </ bean >
  19.     <！ - JTA数据源配置 - >
  20.     < bean id = “center” class = “com.atomikos.jdbc.AtomikosDataSourceBean” init-method = “init” destroy-method = “close” >
  21.         < property name = “uniqueResourceName” >
  22.             < 值> mysql / center </ value >
  23.         </ property >
  24.         < property name = “xaDataSourceClassName” >
  25.             < value > $ {jta.driver.className} </ value >
  26.         </ property >
  27.         < property name = “xaProperties” >
  28.             < 道具>
  29.                 < prop key = “url” > $ {center.jdbc.driver.url} </ prop >
  30.                 < prop key = “user” > $ {center.sql.user.name} </ prop >
  31.                 < prop key = “password” > $ {center.sql.user.password} </ prop >
  32.             </ 道具>
  33.         </ property >
  34.         < property name = “testQuery” value = “select 1” />
  35.         < property name = “poolSize” >
  36.             < value > $ {poolsize} </ value >
  37.         </ property >
  38.         < property name = “maxPoolSize” >
  39.             < value > $ {maxPoolSize} </ value >
  40.         </ property >
  41.         < property name = “borrowConnectionTimeout” > < value > $ {borrowConnectionTimeout} </ value > </ property >
  42.     </ bean >
  44.     < bean id = “db1” class = “com.atomikos.jdbc.AtomikosDataSourceBean” init-method = “init” destroy-method = “close”>
  45.         < property name = “uniqueResourceName” >
  46.             < value > mysql / db1 </ value >
  47.         </ property >
  48.         < property name = “xaDataSourceClassName” >
  49.             < value > $ {jta.driver.className} </ value >
  50.         </ property >
  51.         < property name = “xaProperties” >
  52.             < 道具>
  53.                 < prop key = “url” > $ {db1.jdbc.driver.url} </ prop >
  54.                 < prop key = “user” > $ {company.sql.user.name} </ prop >
  55.                 < prop key = “password” > $ {company.sql.user.password} </ prop >
  56.             </ 道具>
  57.         </ property >
  58.         < property name = “testQuery” value = “select 1” />
  59.         < property name = “poolSize” >
  60.             < value > $ {poolsize} </ value >
  61.         </ property >
  62.         < property name = “maxPoolSize” >
  63.             < value > $ {maxPoolSize} </ value >
  64.         </ property >
  65.         < property name = “borrowConnectionTimeout” > < value > $ {borrowConnectionTimeout} </ value > </ property >
  66.     </ bean >
  67.     < bean id = “db2” class = “com.atomikos.jdbc.AtomikosDataSourceBean” init-method = “init” destroy-method = “close”>
  68.         < property name = “uniqueResourceName” >
  69.             < value > mysql / db2 </ value >
  70.         </ property >
  71.         < property name = “xaDataSourceClassName” >
  72.             < value > $ {jta.driver.className} </ value >
  73.         </ property >
  74.         < property name = “xaProperties” >
  75.             < 道具>
  76.                 < prop key = “url” > $ {db2.jdbc.driver.url} </ prop >
  77.                 < prop key = “user” > $ {company.sql.user.name} </ prop >
  78.                 < prop key = “password” > $ {company.sql.user.password} </ prop >
  79.             </ 道具>
  80.         </ property >
  81.         < property name = “testQuery” value = “select 1” />
  82.         < property name = “poolSize” >
  83.             < value > $ {poolsize} </ value >
  84.         </ property >
  85.         < property name = “maxPoolSize” >
  86.             < value > $ {maxPoolSize} </ value >
  87.         </ property >
  88.         < property name = “borrowConnectionTimeout” > < value > $ {borrowConnectionTimeout} </ value > </ property >
  89.     </ bean >
  91.     < bean id = “dataSource” class = “com.ssi.datasource.DynamicDataSource” >
  92.         < property name = “targetDataSources” >
  93.             < map key-type = “java.lang.String” >
  94.                 < entry key = “db1” value-ref = “db1” />
  95.                 < entry key = “db2” value-ref = “db2” />
  96.                 < entry key = “center” value-ref = “center” />
  97.             </ map >
  98.         </ property >
  99.         < property name = “defaultTargetDataSource” ref = “center” />
  100.     </ bean >
  101. </ beans >

 

DynamicSqlClientDaoSupport.java

[java] 查看纯文本

  1. 包 com.ssi.dao;
  3. import  java.util.Map;
  5. import  javax.sql.DataSource;
  7. import  org.springframework.beans.factory.InitializingBean;
  8. import  org.springframework.dao.support.DaoSupport;
  9. import  org.springframework.orm.ibatis.SqlMapClientTemplate;
  10. import  org.springframework.util.Assert;
  12. import  com.ibatis.sqlmap.client.SqlMapClient;
  13. import  com.ssi.datasource.DbContextHolder;
  15. 公共类 DynamicSqlClientDaoSupport  扩展 DaoSupport  实现 InitializingBean {
  17.     私人 SqlMapClientTemplate sqlMapClientTemplate =  新的 SqlMapClientTemplate（）;
  18.     私人 地图<String，SqlMapClient> targetSqlMapClients;
  19.     私人 SqlMapClient的defaultSqlMapClient;
  20.     private boolean  externalTemplate =  false ;
  23.     / **
  24.      *设置此DAO使用的JDBC数据源。
  25.      *不需要：SqlMapClient可能携带共享数据源。
  26.      * @see #setSqlMapClient
  27.      * /
  28.     public final void  setDataSource（DataSource dataSource）{
  29.         如果 （！this .externalTemplate）{
  30.         这个.sqlMapClientTemplate.setDataSource（dataSource）;
  31.         }
  32.     }
  34.     / **
  35.      *返回此DAO使用的JDBC数据源。
  36.      * /
  37.     public final  DataSource getDataSource（）{
  38.         返回这个.sqlMapClientTemplate.getDataSource（）;
  39.     }
  41.     / **
  42.      *设置iBATIS数据库层SqlMapClient使用。
  43.      *这个或者“sqlMapClientTemplate”是必需的。
  44.      * @see #setSqlMapClientTemplate
  45.      * /
  46.     public final void  setSqlMapClient（SqlMapClient sqlMapClient）{
  47.         如果 （！this .externalTemplate）{
  48.             这个.sqlMapClientTemplate.setSqlMapClient（sqlMapClient）;
  49.         }
  50.     }
  52.     / **
  53.      *返回该模板使用的iBATIS数据库层SqlMapClient。
  54.      * /
  55.     public final  SqlMapClient getSqlMapClient（）{
  56.         返回这个.sqlMapClientTemplate.getSqlMapClient（）;
  57.     }
  59.     / **
  60.      *明确地为此DAO设置SqlMapClientTemplate，
  61.      *作为指定SqlMapClient的替代方法。
  62.      * @see #setSqlMapClient
  63.      * /
  64.     public final void  setSqlMapClientTemplate（SqlMapClientTemplate sqlMapClientTemplate）{
  65.         Assert.notNull（sqlMapClientTemplate，  “SqlMapClientTemplate不能为空” ）;
  66.         这个.sqlMapClientTemplate = sqlMapClientTemplate;
  67.         这个.externalTemplate =  true ;
  68.     }
  70.     / **
  71.      *返回此DAO的SqlMapClientTemplate，
  72.      *用SqlMapClient预先初始化或明确设置。
  73.      * /
  74.     public final  SqlMapClientTemplate getSqlMapClientTemplate（）{
  75.       字符串dbtype = DbContextHolder.getDbType（）;
  76.       if （targetSqlMapClients！= null && targetSqlMapClients.containsKey（dbtype））{
  77.           SqlMapClient sqlMapClient = targetSqlMapClients.get（dbtype）;
  78.           sqlMapClientTemplate =  新的 SqlMapClientTemplate（sqlMapClient）;
  79.       }
  80.       返回这个.sqlMapClientTemplate;
  81.     }
  83.     @覆盖
  84.     protected final void  checkDaoConfig（）{
  85.         如果 （！this .externalTemplate）{
  86.             这个.sqlMapClientTemplate.afterPropertiesSet（）;
  87.         }
  88.     }
  90.     public  Map <String，SqlMapClient> getTargetSqlMapClients（）{
  91.         返回 targetSqlMapClients;
  92.     }
  94.     public void  setTargetSqlMapClients（Map <String，SqlMapClient> targetSqlMapClients）{
  95.         这个.targetSqlMapClients = targetSqlMapClients;
  96.     }
  98.     public  SqlMapClient getDefaultSqlMapClient（）{
  99.         返回 defaultSqlMapClient;
  100.     }
  102.     public void  setDefaultSqlMapClient（SqlMapClient defaultSqlMapClient）{
  103.         这个.defaultSqlMapClient = defaultSqlMapClient;
  104.     }
  105. }

IbatisDaoSupport.java

[java] 查看纯文本

  1. 包 com.ssi.dao;
  3. import  java.io.Serializable;
  4. import  java.sql.SQLException;
  5. import  java.util.List;
  6. import  java.util.Map;
  8. import  org.apache.commons.logging.Log;
  9. import  org.apache.commons.logging.LogFactory;
  10. import  org.springframework.orm.ibatis.SqlMapClientCallback;
  12. import  com.ibatis.sqlmap.client.SqlMapExecutor;
  13. @SuppressWarnings （“未选中” ）
  14. 公共类 IbatisDaoSupport <实体>  扩展 DynamicSqlClientDaoSupport  实现 IEntityDao <实体> {
  16.     受保护的最终 日志日志= LogFactory.getLog（getClass（））;
  19.     公共 实体get（String sqlId，Serializable id）{
  20.         return  （Entity）getSqlMapClientTemplate（）。queryForObject（sqlId，id）;
  21.     }
  22.     公共 实体getByParamMap（字符串sqlId，对象参数）{
  23.         return  （Entity）getSqlMapClientTemplate（）。queryForObject（sqlId，param）;
  24.     }
  25.     public  Object save（String sqlId，Object o）{
  26.         返回 getSqlMapClientTemplate（）。insert（sqlId，o）;
  27.     }
  28.     public  Object batchSave（final  String sqlId，final  List <Entity> entityList）  throws  Exception {
  29.         //执行回调   
  30.         返回 getSqlMapClientTemplate（）。execute（新的 SqlMapClientCallback（）{
  31.             //实现回调接口   
  32.             公共 对象doInSqlMapClient（SqlMapExecutor执行器）  throws  SQLException {
  33.                 //开始批处理   
  34.                 executor.startBatch（）;
  35.                 for  （Entity entity：entityList）{
  36.                     executor.insert（sqlId，entity）;
  37.                 }
  38.                 return  executor.executeBatch（）;
  39.             }
  41.         }）;
  43.     }
  44.     public  Integer remove（String sqlId，Object o）{
  45.         返回 getSqlMapClientTemplate（）。delete（sqlId，o）;
  47.     }
  49.     public  Integer removeById（String sqlId，Serializable id）{
  50.         返回 getSqlMapClientTemplate（）。delete（sqlId，id）;
  51.     }
  53.     public  Integer update（String sqlId，Object o）{
  54.         返回 getSqlMapClientTemplate（）。update（sqlId，o）;
  56.     }
  57.     public  long totalCount（String sqlId，Object o）{
  58.         return  （Long）getSqlMapClientTemplate（）。queryForObject（sqlId，o）;
  59.     }
  60.     public  List <Entity> pagedList（String sqlId，Map <String，Object> map，int  pageSize，  int  pageNum）{
  61.         int  start =（pageNum -  1 ）* pageSize;
  62.         map.put（“开始” ，开始）;
  63.         map.put（“pageSize” ，pageSize）;
  64.         List <Entity> list = getSqlMapClientTemplate（）。queryForList（sqlId，map）;
  65.         退货 清单;
  66.     }
  67.     public  List <Entity> list（String sqlId，Object o）{
  68.         返回 getSqlMapClientTemplate（）。queryForList（sqlId，o）;
  69.     }
  70.     public  List <Entity> list（String sqlId）{
  71.         返回 getSqlMapClientTemplate（）。queryForList（sqlId）;
  72.     }
  74. }

 

UserDaoImpl.java：

[java] 查看纯文本

  1. 包 com.ssi.dao.impl;
  3. import  org.springframework.stereotype.Repository;
  6. import  com.ssi.dao.IUserDao;
  7. import  com.ssi.dao.IbatisDaoSupport;
  8. import  com.ssi.model.User;
  9. @Repository （“userDAO的” ）
  10. 公共类 UserDaoImpl  扩展 IbatisDaoSupport <用户>  实现 IUserDao {
  11.     公共 整数addUser（用户用户）  抛出 异常{
  12.         返回 （整数）  这个.save（“User.insert” ，用户）;
  13.     }
  14. }

 

UserServiceImpl.java

[java] 查看纯文本

  1. 包 com.ssi.service.impl;
  3. import  javax.annotation.Resource;
  5. import  org.springframework.stereotype.Service;
  7. import  com.ssi.dao.IUserDao;
  8. import  com.ssi.datasource.DbContextHolder;
  9. import  com.ssi.model.User;
  10. import  com.ssi.service.IUserService;
  13. @Service （“userService” ）
  14. 公共类 UserServiceImpl  实现 IUserService {
  15.     @Resource private  IUserDao userDao;
  16.     / **
  17.      *测试在服务中切换数据源异常是否回滚
  18.      * /
  19.     公共无效 addUser（用户用户）  抛出 异常{
  20.         DbContextHolder.setDbType（“db1” ）;
  21.         userDao.addUser（用户）;
  22.         DbContextHolder.setDbType（“db2” ）;
  23.         user.setUserName（“user2” ）;
  24.         userDao.addUser（用户）;
  25.         DbContextHolder.setDbType（“center” ）;
  26.         user.setUserName（“user3” ）;
  27.         userDao.addUser（用户）;
  28.         //System.out.println(1/0）;
  29.     }
  30. }

 

DynamicDataSource.java：

[java] 查看纯文本

  1. public class  DynamicDataSource  extends  AbstractRoutingDataSource {
  3.     静态 记录仪日志= Logger.getLogger（DynamicDataSource。类）;
  5.     protected  Object determineCurrentLookupKey（）{
  6.         返回 DbContextHolder.getDbType（）;
  7.     }
  9. }

DbContextHolder.java：

[java] 查看纯文本

  1. 公共类 DbContextHolder {
  2.     private static final  ThreadLocal contextHolder =  new  ThreadLocal（）;
  4.     public static void  setDbType（String dbType）{
  5.         contextHolder.set（DBTYPE）;
  6.     }
  8.     public static  String getDbType（）{
  9.         return  （String）contextHolder.get（）;
  10.     }
  12.     public static void  clearDbType（）{
  13.         contextHolder.remove（）;
  14.     }
  16. }

三个数据库：dbcenter，db1，db2表结构均相同

脚本：

[sql] 查看纯文本

  1. DROP TABLE  IF EXISTS`tb_user`;
  3. CREATE TABLE  `tb_user`（
  4.   `id`  int （11）  NOT NULL  AUTO_INCREMENT，
  5.   `userName`  varchar （20）  DEFAULT NULL ，
  6.   ` 密码`  VARCHAR （60）  DEFAULT NULL ，
  7.   PRIMARY KEY  （`id`）
  8. ）ENGINE = InnoDB  DEFAULT  CHARSET = utf8;

单元测试：

[java] 查看纯文本

  1. 公共类 JunitTest {
  2.     public  ApplicationContext cxt;
  3.     @测试
  4.     公共无效的 init（）  抛出 异常{
  5.         cxt =  new  ClassPathXmlApplicationContext（new  String [] { “applicationContext.xml” ，“applicationContext-datasource.xml” }）;
  6.         testInsertUser（）;
  8.     }
  11.     私人无效 testInsertUser（）  抛出 异常{
  12.         IUserService userService =（IUserService）cxt.getBean（“userService” ）;
  13.         用户用户=  新 用户（）;
  14.         user.setUserName（“user1” ）;
  15.         user.setPassword（“0” ）;
  16.         userService.addUser（用户）;
  17.     }
  19.     私人无效 testInsertUser2（）  抛出 异常{
  21. }
文章标签：
Java
Spring
关系型数据库
MySQL
数据库
定位技术
数据安全/隐私保护
数据格式
XML
数据库连接
关键词：
Spring分布式
Spring分布式事务
Spring service
Spring动态
Spring数据源
幸运券发放
目录
相关文章
互联网课堂
|
3月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
定时任务在企业应用中至关重要，常用于异步数据处理、自动化运维等场景。在单体应用中，利用Java的`java.util.Timer`或Spring的`@Scheduled`即可轻松实现。然而，进入微服务架构后，任务可能因多节点并发执行而重复。Spring Cloud Alibaba为此发布了Scheduling模块，提供轻量级、高可用的分布式定时任务解决方案，支持防重复执行、分片运行等功能，并可通过`spring-cloud-starter-alibaba-schedulerx`快速集成。用户可选择基于阿里云SchedulerX托管服务或采用本地开源方案（如ShedLock）
互联网课堂
122 1
土木林森
|
2月前
|
消息中间件 Java 对象存储
数据一致性挑战：Spring Cloud与Netflix OSS下的分布式事务管理
数据一致性挑战：Spring Cloud与Netflix OSS下的分布式事务管理
土木林森
50 2
阿里云云原生
|
4月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
Spring Cloud Alibaba 发布了 Scheduling 任务调度模块 [#3732]提供了一套开源、轻量级、高可用的定时任务解决方案，帮助您快速开发微服务体系下的分布式定时任务。
阿里云云原生
14933 30
热爱技术的小郑
|
3月前
|
Java 微服务 Spring
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
文章介绍了如何利用Spring Cloud Alibaba快速构建大型电商系统的分布式微服务，包括服务限流降级等主要功能的实现，并通过注解和配置简化了Spring Cloud应用的接入和搭建过程。
热爱技术的小郑
229 0
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
路边两盏灯
|
3月前
|
Java Spring
【Azure Service Bus】使用Spring Cloud integration示例代码，为多个 Service Bus的连接使用 ConnectionString 方式
【Azure Service Bus】使用Spring Cloud integration示例代码，为多个 Service Bus的连接使用 ConnectionString 方式
路边两盏灯
46 0
路边两盏灯
|
3月前
|
Java Spring
【Azure 服务总线】Spring Cloud 的应用 使用Service Bus 引起 org.springframework.beans.BeanInstantiationException 异常，无法启动
【Azure 服务总线】Spring Cloud 的应用 使用Service Bus 引起 org.springframework.beans.BeanInstantiationException 异常，无法启动
路边两盏灯
29 0
路边两盏灯
|
3月前
|
Java 开发工具 Spring
【Azure Spring Cloud】使用azure-spring-boot-starter-storage来上传文件报错: java.net.UnknownHostException: xxxxxxxx.blob.core.windows.net: Name or service not known
【Azure Spring Cloud】使用azure-spring-boot-starter-storage来上传文件报错: java.net.UnknownHostException: xxxxxxxx.blob.core.windows.net: Name or service not known
路边两盏灯
38 0
路边两盏灯
|
3月前
|
前端开发 JavaScript Java
【Azure 应用服务】App Service For Windows 中如何设置代理实现前端静态文件和后端Java Spring Boot Jar包
【Azure 应用服务】App Service For Windows 中如何设置代理实现前端静态文件和后端Java Spring Boot Jar包
路边两盏灯
32 0
路边两盏灯
|
3月前
|
Java Linux C++
【Azure 应用服务】App Service For Linux 部署Java Spring Boot应用后，查看日志文件时的疑惑
【Azure 应用服务】App Service For Linux 部署Java Spring Boot应用后，查看日志文件时的疑惑
路边两盏灯
30 0
土木林森
|
3月前
|
Dubbo Java 调度
揭秘！Spring Cloud Alibaba的超级力量——如何轻松驾驭分布式定时任务调度？
【8月更文挑战第20天】在现代微服务架构中，Spring Cloud Alibaba通过集成分布式定时任务调度功能解决了一致性和可靠性挑战。它利用TimerX实现任务的分布式编排与调度，并通过`@SchedulerLock`确保任务不被重复执行。示例代码展示了如何配置定时任务及其分布式锁，以实现每5秒仅由一个节点执行任务，适合构建高可用的微服务系统。
土木林森
68 0

热门文章

最新文章

  • 1
    分布式存储的多副本纠删码简介
  • 2
    阿里开源首款自研科学计算引擎 Mars ：基于张量的统一分布式计算框架
  • 3
    AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(二)：配置WinClient分布式运行环境
  • 4
    蚂蚁架构师郭援非：分布式数据库是金融机构数字化转型的最佳路径
  • 5
    WCF分布式安全开发实践(8):消息安全模式之用户名身份验证:Message_UserName_WSHttpBinding
  • 6
    Memcache分布式部署方案
  • 7
    【SpringCloud-Alibaba系列教程】16.动态配置yml以及分布式事务
  • 8
    WCF分布式安全开发实践(5):传输安全模式之Certificate身份验证:Transport_Certificate_WSHttpBinding
  • 9
    在PyTorch中使用DistributedDataParallel进行多GPU分布式模型训练
  • 10
    服务器内部分布式图片取得
  • 1
    Spring Boot框架在java领域的优势
    76
  • 2
    Spring事务管理嵌套事务详解 : 同一个类中，一个方法调用另外一个有事务的方法
    261
  • 3
    spring 事务控制 设置手动回滚 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()；
    116
  • 4
    面试一口气说出Spring的声明式事务@Transactional注解的6种失效场景
    119
  • 5
    nested exception is org.springframework.beans.factory.BeanCurrentlyInCreationException（Spring循环依赖问题）
    102
  • 6
    【spring cloud】注解@SpringCloudApplication和@SpringBootApplication的区别
    61
  • 7
    Spring Boot 2.x 嵌入式 Servlet 容器
    62
  • 8
    Spring Cloud微服务框架：构建高可用、分布式系统的现代架构
    183
  • 9
    Java技术栈中的核心组件：Spring框架
    52
  • 10
    基于SpringBoot+Vue+uniapp的公园管理系统的详细设计和实现(源码+lw+部署文档+讲解等)
    74

    • 相关课程

    更多
  • 全面讲解Spring Cloud Alibaba技术栈（知识精讲+项目实战）第一阶段
  • 精通Spring Cloud Alibaba
  • 微服务框架 Spring Cloud 快速入门
  • Java Web开发系列课程 - Spring框架入门
  • Spring Boot 2.5.x开发实战
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 云栖社区特邀专家徐雷Java Spring Boot开发实战系列课程（第20讲）：经典面试题与阿里等名企内部招聘求职面试技巧
  • 微服务架构模式与原理Spring Cloud开发实战
  • 阿里特邀专家徐雷Java Spring Boot开发实战系列课程（第18讲）：制作Java Docker镜像与推送到DockerHub和阿里云Docker仓库

    • 相关实验场景

    更多
  • 体验PolarDB-X透明分布式
  • 基于MSE-Nacos实现服务的动态发现和配置动态管理
  • 快速玩转Dubbo生态之一致性事务篇（Seata）
  • Spring-cloud-bus-rocketmq入门与实践
  • Spring-cloud-stream-binder-rocketmq入门与实践
  • 从零搭建Spring Boot的Hello World
    • 下一篇
    阿里云OSS设置跨域访问