Spring Boot中的主/辅助故障转移数据源

Question

我知道如何使2个数据源，但哪里是最好的地方，以处理逻辑什么时候它将使用哪一个。逻辑需要这样运行：

1. 连接到主
2. 如果存在连接问题，或者资源不可用，或者连接超时，请尝试重新连接到主服务器。
3. 如果主服务器无法连接，请尝试连接到辅助服务器
4. 如果辅助设备无法连接，请继续重试步骤2和步骤3，持续X分钟。

在Spring服务中处理这个问题是最好的/可能的吗？我应该有一个不同的服务来处理这个逻辑，而我的其他服务使用这个逻辑吗？不连接到DB的“Spring方式”而使用“普通的旧java方式”会更好吗？

package com.helloworld.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import oracle.jdbc.pool.OracleDataSource;
import org.springframework.jdbc.core.JdbcTemplate;

import javax.sql.DataSource;
import java.sql.SQLException;

@Configuration
public class DatasourcesConfig {

    @Primary
    @Bean(name = "primaryDataSource")
    DataSource primaryDataSource() throws SQLException {

        OracleDataSource dataSource = new OracleDataSource();

        dataSource.setUser("user");
        dataSource.setPassword("pass");
        dataSource.setURL("jdbc:oracle:thin:@(...primary connection...)");

        return dataSource;
    }

      @Bean(name = "secondaryDataSource")
      DataSource secondaryDataSource() throws SQLException {

          OracleDataSource dataSource = new OracleDataSource();

          dataSource.setUser("user");
          dataSource.setPassword("pass");
          dataSource.setURL("jdbc:oracle:thin:@(...secondary connection...)");

          return dataSource;
      }

    @Bean(name = "jdbcPrimary")
    @Autowired
    public JdbcTemplate primaryJdbcTemplate(@Qualifier("primaryDataSource") DataSource ds) {
        return new JdbcTemplate(ds);
    }

    @Bean(name = "jdbcSecondary")
    @Autowired
    public JdbcTemplate secondaryJdbcTemplate(@Qualifier("secondaryDataSource") DataSource ds) {
        return new JdbcTemplate(ds);
    }

}

package com.helloworld.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;

@Service
public class ExampleService {

    @Autowired
    @Qualifier("jdbcPrimary")
    private JdbcTemplate jdbcTemplatePrimary;

    @Autowired
    @Qualifier("jdbcSecondary")
    private JdbcTemplate jdbcTemplateSecondary;

    public SampleDTO getData(String a, String b){

        final String sql = "select a, b from TABLE_A where a=? and b=?";

        // Only checking Primary
        return jdbcTemplatePrimary.queryForObject(sql,
                new Object[]{a,b},
                new SampleRowMapper());

        // Is this the best place to catch exceptions and connect to Secondary?

    }

}

Answer 1

我能够使用dzone的本文实现这种机制：https://dzone.com/articles/using-HA-jdbc-with-spring-boot使用这里的enter link description

HA-JDBC是非常可配置的，并且有几种不同的故障转移策略。

在我们的例子中，我们设置到两个不同数据库的连接，我们的主数据库备份到辅助数据库，因此可能不是当前数据库。

null