SpringBoot+MyBatis+Nacos配置多数据源，MySQL和Redis多数据源怎么配置

配置多数据源，由于不常用就进行了百度，百度了很久（有很多都不能用），加上自己修修改改，终于能用了。那么就废话不多说，直接上代码。

1. SpringBoot应用启动类注解：

@MapperScan("com.xxx.mapper")
@SpringBootApplication(scanBasePackages = "com.xxx")

MapperScan是配置到了DAO层的包上。不过这里的MapperScan应该不起作用。配上了也就没必要删掉。

2. bootstrap-env.yaml配置Nacos：

spring:cloud:nacos:config:server-addr: nacos-ip:nacos-portnamespace: my_namespacegroup: MY_GROUPfile-extension: yaml

3. Nacos配置：

server:port: 8060spring:datasource:one:jdbc-url: jdbc:mysql://mysql-host-1:3306/database?useSSL=false&Unicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&zeroDateTimeBehavior=CONVERT_TO_NULL&useAffectedRows=trueusername: usernamepassword: passworddriver-class-name: com.mysql.cj.jdbc.Drivertwo:jdbc-url: jdbc:mysql://mysql-host-2:3306/database?useSSL=false&Unicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&zeroDateTimeBehavior=CONVERT_TO_NULL&useAffectedRows=trueusername: usernamepassword: passworddriver-class-name: com.mysql.cj.jdbc.Driverredis:one: database: 0host: redis-host-1port: 6379password: passwordtwo: database: 1host: redis-host-2port: 6379password: password

这里要注意Nacos配置文件的命名：应用名.yaml，要加yaml哦，否则可能读不到配置。
4. 数据库Bean的配置：

/*** 第一个数据源*/
@Configuration
@MapperScan(basePackages = "com.xxx.mapper.one", sqlSessionFactoryRef = "oneSqlSessionFactory")
public class OneDataSourceConfig {@Primary	// 这个注解意思是主库，只有一个配置类可以加@Bean("oneDataSource")@ConfigurationProperties(prefix = "spring.datasource.one")public DataSource getOneDataSource(){return DataSourceBuilder.create().build();}@Primary@Bean("oneSqlSessionFactory")public SqlSessionFactory oneSqlSessionFactory(@Qualifier("oneDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/one/*.xml"));	//xml的包和DAO层的包，多个数据库建议分开，更清晰。return bean.getObject();}@Primary@Bean("oneSqlSessionTemplate")public SqlSessionTemplate oneSqlSessionTemplate(@Qualifier("oneSqlSessionFactory") SqlSessionFactory sqlSessionFactory){return new SqlSessionTemplate(sqlSessionFactory);}
}

/*** 第二个数据源*/
@Configuration
@MapperScan(basePackages = "com.nucarf.rebate.calculate.mapper.two", sqlSessionFactoryRef = "twoSqlSessionFactory")
public class TwoDataSourceConfig {@Bean("twoDataSource")@ConfigurationProperties(prefix = "spring.datasource.two")public DataSource getTwoDataSource(){return DataSourceBuilder.create().build();}@Bean("twoSqlSessionFactory")public SqlSessionFactory twoSqlSessionFactory(@Qualifier("twoDataSource") DataSource dataSource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/two/*.xml"));return bean.getObject();}@Bean("twoSqlSessionTemplate")public SqlSessionTemplate twoSqlSessionTemplate(@Qualifier("twoSqlSessionFactory") SqlSessionFactory sqlSessionFactory){return new SqlSessionTemplate(sqlSessionFactory);}
}

5. Redis Bean的配置：

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {/*** 第一个数据源*/@Value("${spring.redis.one.host}")private String oneHost;@Value("${spring.redis.one.password}")private String onePassword;@Value("${spring.redis.one.port}")private String onePort;@Value("${spring.redis.one.database}")private int oneDatabase;/*** 第二个数据源*/@Value("${spring.redis.two.host}")private String twoHost;@Value("${spring.redis.two.password}")private String twoPassword;@Value("${spring.redis.two.port}")private String twoPort;@Value("${spring.redis.two.database}")private int twoDatabase;//最大空闲连接数private static final int MAX_IDLE = 8;//最大连接数private static final int MAX_TOTAL = 8;//建立连接最长等待时间private static final long MAX_WAIT_MILLIS = 10000;/*** 配置工厂*/public RedisConnectionFactory connectionFactory(String host, int port, String password, int maxIdle,int maxTotal, long maxWaitMillis, int index) {JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();jedisConnectionFactory.setHostName(host);jedisConnectionFactory.setPort(port);if (StringUtils.isNotEmpty(password)) {jedisConnectionFactory.setPassword(password);}if (index != 0) {jedisConnectionFactory.setDatabase(index);}jedisConnectionFactory.setPoolConfig(poolConfig(maxIdle, maxTotal, maxWaitMillis, false));jedisConnectionFactory.afterPropertiesSet();return jedisConnectionFactory;}/*** 连接池配置*/public JedisPoolConfig poolConfig(int maxIdle, int maxTotal, long maxWaitMillis, boolean testOnBorrow) {JedisPoolConfig poolConfig = new JedisPoolConfig();poolConfig.setMaxIdle(maxIdle);poolConfig.setMaxTotal(maxTotal);poolConfig.setMaxWaitMillis(maxWaitMillis);poolConfig.setTestOnBorrow(testOnBorrow);return poolConfig;}/*** 第一个数据源初始化*/@Bean(name = "redisTemplateOne")public RedisTemplate<String, Object> redisTemplateOne(RedisConnectionFactory factory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(connectionFactory(oneHost, Integer.parseInt(onePort), onePassword, MAX_IDLE, MAX_TOTAL, MAX_WAIT_MILLIS, oneDatabase));Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();// key采用String的序列化方式template.setKeySerializer(stringRedisSerializer);// hash的key也采用String的序列化方式template.setHashKeySerializer(stringRedisSerializer);// value序列化方式采用jacksontemplate.setValueSerializer(jackson2JsonRedisSerializer);// hash的value序列化方式采用jacksontemplate.setHashValueSerializer(jackson2JsonRedisSerializer);template.afterPropertiesSet();return template;}/*** 第二个数据源初始化*/@Bean(name = "redisTemplateTwo")public RedisTemplate<String, Object> redisTemplateTwo(RedisConnectionFactory factory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(connectionFactory(twoHost, Integer.parseInt(twoPort), twoPassword, MAX_IDLE, MAX_TOTAL, MAX_WAIT_MILLIS, twoDatabase));Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();// key采用String的序列化方式template.setKeySerializer(stringRedisSerializer);// hash的key也采用String的序列化方式template.setHashKeySerializer(stringRedisSerializer);// value序列化方式采用jacksontemplate.setValueSerializer(jackson2JsonRedisSerializer);// hash的value序列化方式采用jacksontemplate.setHashValueSerializer(jackson2JsonRedisSerializer);template.afterPropertiesSet();return template;}
}

6. 使用
   数据库使用没啥说的，直接@Autowired或者@Resource注入就可以了。
   Redis使用注入的时候把name写上：

@Resource(name = "redisTemplateOne")
private RedisTemplate<String, Object> redisTemplateOne;

喜欢本文的朋友不要忘记点一个免费的赞哦，你的赞将是我最大的动力。

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！