• springBoot配置多数据源

    通过在mapper接口上添加自定数据源注解@DataSource来制定数据源

    1.添加切面aspectjweaver依赖

    1.             <dependency>
    2.                 <groupId>org.aspectj</groupId>
    3.                 <artifactId>aspectjweaver</artifactId>
    4.                 <version>1.9.7</version>
    5.             </dependency>
    6.             <dependency>
    7.                 <groupId>org.springframework.boot</groupId>
    8.                 <artifactId>spring-boot-starter-aop</artifactId>
    9.                 <version>1.5.9.RELEASE</version>
    10.             </dependency>

    2.启动类添加切面支持注解@EnableAspectJAutoProxy(proxyTargetClass = true)

    @Import({DynamicDataSourceConfig.class})

    exclude = {DataSourceAutoConfiguration.class} 不加这个会报错,循环依赖问题(查了好久才解决)

    1. import org.linlinjava.litemall.db.datasources.DynamicDataSourceConfig;
    2. import org.mybatis.spring.annotation.MapperScan;
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
    6. import org.springframework.context.annotation.EnableAspectJAutoProxy;
    7. import org.springframework.context.annotation.Import;
    8. import org.springframework.scheduling.annotation.EnableScheduling;
    9. import org.springframework.transaction.annotation.EnableTransactionManagement;
    10.  
    11. @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
    12. @MapperScan("org.linlinjava.litemall.db.dao")
    13. @EnableTransactionManagement
    14. @EnableAspectJAutoProxy(proxyTargetClass = true)
    15. @EnableScheduling
    16. @Import({DynamicDataSourceConfig.class})
    17. public class Application {
    18.  
    19.     public static void main(String[] args) {
    20.         SpringApplication.run(Application.class, args);
    21.     }
    22.  
    23. }

    3自定义注解DataSource.java

    1.  
    2. import java.lang.annotation.*;
    3.  
    4. /**
    5.  * 多数据源注解
    6.  *
    7.  */
    8. @Target({ElementType.METHOD, ElementType.TYPE})
    9. @Retention(RetentionPolicy.RUNTIME)
    10. @Documented
    11. public @interface DataSource {
    12.     String name() default "";
    13. }

    数据源名称枚举

    1. /**
    2.  * 增加多数据源，在此配置
    3.  *
    4.  */
    5. public interface DataSourceNames {
    6.     String LITEMALL = "mall";
    7.  
    8.     String ZOOM = "zoom";
    9.  
    10. }

    动态数据源配置类

    1.  
    2. import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
    3.  
    4. import javax.sql.DataSource;
    5. import java.util.HashMap;
    6. import java.util.Map;
    7.  
    8. /**
    9.  * 动态数据源
    10.  *
    11.  */
    12. public class DynamicDataSource extends AbstractRoutingDataSource {
    13.     private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
    14.  
    15.     public DynamicDataSource(DataSource defaultTargetDataSource, Map<String, DataSource> targetDataSources) {
    16.         super.setDefaultTargetDataSource(defaultTargetDataSource);
    17.         super.setTargetDataSources(new HashMap<>(targetDataSources));
    18.         super.afterPropertiesSet();
    19.     }
    20.  
    21.     @Override
    22.     protected Object determineCurrentLookupKey() {
    23.         return getDataSource();
    24.     }
    25.  
    26.     public static void setDataSource(String dataSource) {
    27.         contextHolder.set(dataSource);
    28.     }
    29.  
    30.     public static String getDataSource() {
    31.         return contextHolder.get();
    32.     }
    33.  
    34.     public static void clearDataSource() {
    35.         contextHolder.remove();
    36.     }
    37.  
    38. }

    配置多数据源

    1.  
    2. import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
    3. import org.aspectj.lang.ProceedingJoinPoint;
    4. import org.aspectj.lang.annotation.Around;
    5. import org.aspectj.lang.annotation.Aspect;
    6. import org.aspectj.lang.annotation.Pointcut;
    7. import org.aspectj.lang.reflect.MethodSignature;
    8. import org.slf4j.Logger;
    9. import org.slf4j.LoggerFactory;
    10. import org.springframework.boot.context.properties.ConfigurationProperties;
    11. import org.springframework.context.annotation.Bean;
    12. import org.springframework.context.annotation.Configuration;
    13. import org.springframework.context.annotation.Primary;
    14. import org.springframework.core.Ordered;
    15. import org.springframework.stereotype.Component;
    16.  
    17.  
    18. import javax.sql.DataSource;
    19. import java.lang.reflect.Method;
    20. import java.util.HashMap;
    21. import java.util.Map;
    22.  
    23. /**
    24.  * 配置多数据源
    25.  *
    26.  */
    27. @Configuration
    28. public class DynamicDataSourceConfig {
    29.  
    30.     @Bean
    31.     @ConfigurationProperties("spring.datasource.druid.mall")
    32.     public DataSource liteMallDataSource() {
    33.         return DruidDataSourceBuilder.create().build();
    34.     }
    35.  
    36.     @Bean
    37.     @ConfigurationProperties("spring.datasource.druid.zoom")
    38.     public DataSource zoomDataSource() {
    39.         return DruidDataSourceBuilder.create().build();
    40.     }
    41.  
    42.     @Bean
    43.     @Primary
    44.     public DynamicDataSource dataSource(DataSource liteMallDataSource, DataSource zoomDataSource) {
    45.         Map<String, DataSource> targetDataSources = new HashMap<>();
    46.         targetDataSources.put(DataSourceNames.LITEMALL, liteMallDataSource);
    47.         targetDataSources.put(DataSourceNames.ZOOM, zoomDataSource);
    48.         return new DynamicDataSource(liteMallDataSource, targetDataSources);
    49.     }
    50.  
    51.     @Aspect
    52.     @Component
    53.     class DataSourceAspect implements Ordered {
    54.         protected Logger logger = LoggerFactory.getLogger(getClass());
    55.  
    56.         public DataSourceAspect() {
    57.             System.out.println(0);
    58.         }
    59.  
    60.         @Pointcut("@within(org.linlinjava.litemall.db.datasources.annotation.DataSource)")
    61.         public void dataSourcePointCut() {
    62.             System.out.println(0);
    63.         }
    64.  
    65.         @Around("dataSourcePointCut()")
    66.         public Object around(ProceedingJoinPoint point) throws Throwable {
    67.  
    68.             org.linlinjava.litemall.db.datasources.annotation.DataSource ds = null;
    69.  
    70.             Class clazz = point.getTarget().getClass();
    71.             ds = (org.linlinjava.litemall.db.datasources.annotation.DataSource) clazz.getAnnotation(org.linlinjava.litemall.db.datasources.annotation.DataSource.class);
    72.  
    73.             if (ds == null) {
    74.                 MethodSignature signature = (MethodSignature) point.getSignature();
    75.                 Method method = signature.getMethod();
    76.                 ds = method.getAnnotation(org.linlinjava.litemall.db.datasources.annotation.DataSource.class);
    77.             }
    78.  
    79.             if (ds == null) {
    80.                 DynamicDataSource.setDataSource(DataSourceNames.LITEMALL);
    81.                 logger.debug("set datasource is " + DataSourceNames.LITEMALL);
    82.             } else {
    83.                 DynamicDataSource.setDataSource(ds.name());
    84.                 logger.debug("set datasource is " + ds.name());
    85.             }
    86.  
    87.             try {
    88.                 return point.proceed();
    89.             } finally {
    90.                 DynamicDataSource.clearDataSource();
    91.                 logger.debug("clean datasource");
    92.             }
    93.         }
    94.  
    95.         @Override
    96.         public int getOrder() {
    97.             return 1;
    98.         }
    99.     }
    100.  
    101. }

    4.Yaml配置

    1. spring:
    2.   datasource:
    3.     type: com.alibaba.druid.pool.DruidDataSource
    4.     druid:
    5.       zoom:  #数据源2
    6.         url: xxxxxx/zoom?useUnicode=true&characterEncoding=utf8&useSSL=false
    7.         driver-class-name:  com.mysql.cj.jdbc.Driver
    8.         username: 0000
    9.         password: 00000
    10.         filter:
    11.           slf4j:
    12.             enabled: true
    13.       mall:
    14.         url:  jdbc:xxxxxx/litemall?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&verifyServerCertificate=false&useSSL=false
    15.         driver-class-name:  com.mysql.cj.jdbc.Driver
    16.         username:  00000
    17.         password:  00000
    18.         initial-size:  10
    19.         max-active:  50
    20.         min-idle:  10
    21.         max-wait:  60000
    22.         pool-prepared-statements:  true
    23.         max-pool-prepared-statement-per-connection-size:  20
    24.         validation-query:  SELECT 1 FROM DUAL
    25.         test-on-borrow:  false
    26.         test-on-return:  false
    27.         test-while-idle:  true
    28.         time-between-eviction-runs-millis:  60000
    29.         webStatFilter:
    30.           enabled: true
    31.         statViewServlet:
    32.           enabled: false
    33.         filter:
    34.           stat:
    35.             enabled: false

    5.测试

    1.  
    2. import org.junit.Test;
    3. import org.junit.runner.RunWith;
    4. import org.linlinjava.litemall.db.dao.StatMapper;
    5. import org.linlinjava.litemall.db.dao.ZoomMapper;
    6. import org.linlinjava.litemall.db.datasources.DynamicDataSourceConfig;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
    9. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
    10. import org.springframework.boot.test.context.SpringBootTest;
    11. import org.springframework.context.annotation.Import;
    12. import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    13. import org.springframework.test.context.junit4.SpringRunner;
    14. import org.springframework.test.context.web.WebAppConfiguration;
    15.  
    16. import javax.annotation.Resource;
    17.  
    18. @WebAppConfiguration
    19. @EnableAutoConfiguration(exclude = {DataSourceAutoConfiguration.class})
    20. @RunWith(SpringRunner.class)
    21. @SpringBootTest
    22. @Import({DynamicDataSourceConfig.class})
    23. public class DbTest {
    24.  
    25.     @Autowired
    26.     private ZoomMapper zoomMapper;
    27.  
    28.     @Test
    29.     public void test() {
    30.         System.out.println(zoomMapper.queryName());
    31.     }
    32.  
    33. }

    6,可能出现的异常

    ***************************
    APPLICATION FAILED TO START
    ***************************

    Description:

    The dependencies of some of the beans in the application context form a cycle:

    zoomMapperService (field org.linlinjava.litemall.db.dao.ZoomMapper org.linlinjava.litemall.db.dao.impl.ZoomMapperService.zoomMapper)
    ↓
    zoomMapper defined in file [F:\workcode\litemall\litemall-db\target\classes\org\linlinjava\litemall\db\dao\ZoomMapper.class]
    ↓
    sqlSessionFactory defined in class path resource [org/mybatis/spring/boot/autoconfigure/MybatisAutoConfiguration.class]
    ┌─────┐
    | dataSource defined in class path resource [org/linlinjava/litemall/db/datasources/DynamicDataSourceConfig.class]
    ↑ ↓
    | firstDataSource defined in class path resource [org/linlinjava/litemall/db/datasources/DynamicDataSourceConfig.class]
    ↑ ↓
    | org.springframework.boot.autoconfigure.jdbc.DataSourceInitializerInvoker

    循环依赖问题

    2yaml配置问题

    Caused by: org.yaml.snakeyaml.parser.ParserException: while parsing a block mapping
     in 'reader', line 9, column 5:
            type: com.alibaba.druid.pool.Dru ... 
            ^
    expected <block end>, but found '<block mapping start>'
     in 'reader', line 19, column 7:
              mall:
              ^

        at org.yaml.snakeyaml.parser.ParserImpl$ParseBlockMappingKey.produce(ParserImpl.java:572)
        at org.yaml.snakeyaml.parser.ParserImpl.peekEvent(ParserImpl.java:158)
        at org.yaml.snakeyaml.parser.ParserImpl.checkEvent(ParserImpl.java:148)
        at org.yaml.snakeyaml.composer.Composer.composeMappingNode(Composer.java:214)
        at org.yaml.snakeyaml.composer.Composer.composeNode(Composer.java:144)
        at org.yaml.snakeyaml.composer.Composer.composeValueNode(Composer.java:236)
        at org.yaml.snakeyaml.composer.Composer.composeMappingChildren(Composer.java:227)
        at org.yaml.snakeyaml.composer.Composer.composeMappingNode(Composer.java:215)
        at org.yaml.snakeyaml.composer.Composer.composeNode(Composer.java:144)
        at org.yaml.snakeyaml.composer.Composer.composeValueNode(Composer.java:236)
        at org.yaml.snakeyaml.composer.Composer.composeMappingChildren(Composer.java:227)
        at org.yaml.snakeyaml.composer.Composer.composeMappingNode(Composer.java:215)
        at org.yaml.snakeyaml.composer.Composer.composeNode(Composer.java:144)
        at org.yaml.snakeyaml.composer.Composer.getNode(Composer.java:85)
        at org.yaml.snakeyaml.constructor.BaseConstructor.getData(BaseConstructor.java:123)
        at org.yaml.snakeyaml.Yaml$1.next(Yaml.java:547)
        at org.springframework.beans.factory.config.YamlProcessor.process(YamlProcessor.java:160)
        at org.springframework.beans.factory.config.YamlProcessor.process(YamlProcessor.java:134)
        at org.springframework.boot.env.OriginTrackedYamlLoader.load(OriginTrackedYamlLoader.java:75)
        at org.springframework.boot.env.YamlPropertySourceLoader.load(YamlPropertySourceLoader.java:50)
        at org.springframework.boot.context.config.ConfigFileApplicationListener$Loader.loadDocuments(ConfigFileApplicationListener.java:574)
        at org.springframework.boot.context.config.ConfigFileApplicationListener$Loader.load(ConfigFileApplicationListener.java:528)
        ... 48 common frames omitted

  • 相关阅读:
    在vue-cli项目中打包的 dist 静态文件不能直接双击打开访问解决方法-直接打开访问是空白的解决方法
    机器学习 分类、回归、聚类、特征工程区别
    与git相关错误的究极解决方案
    Oracle 数据库的锁排查方法
    使用XShell、XFTP 连接 win7 虚拟机（windows、Linux无法远程登录问题）
    phpcms v9.任意文件上传漏洞复现
    用python解决这个问题
    人脸解锁设备时出现相机报错
    使用kubeadm方式搭建Kubernetes集群
    人脸识别9-FastDeploy人脸检测、识别、部署
  • 原文地址：https://blog.csdn.net/BIG_PEI/article/details/125487810