@Configuration中@Autowired private DataSource rabbitProducerDataSource;

@Slf4j @Configuration @PropertySource({"classpath:rabbit-producer-message.properties"}) public class RabbitProducerDataSourceConfiguration {  /**赋值*/  @Value("${rabbit.producer.druid.type}")  private Class<? extends DataSource> dataSourceType;  /**给DataSource rabbitProducerDataSource 起个名字*/  @Bean(name ="rabbitProducerDataSource") 

/*<br>    Spring boot有多个数据源时, 必须有一个是primary的, 否则无法启动.<br>     一般我们设置某个bean为primary时, 是添加primary注解<br>    */<br>   @ConfigurationProperties(prefix = "rabbit.producer.druid.jdbc")<br>   public DataSource rabbitProducerDataSource() throws SQLException {<br>      DataSource rabbitProducerDataSource = DataSourceBuilder.create().type(dataSourceType).build();<br>      log.info("============= rabbitProducerDataSource : {} ================", rabbitProducerDataSource);<br>      return rabbitProducerDataSource;<br>   }<br><br>   public DataSourceProperties primaryDataSourceProperties(){<br>      return new DataSourceProperties();<br>   }<br><br>   /**用于备份*/

  public DataSource primaryDataSource(){  return primaryDataSourceProperties().initializeDataSourceBuilder().build(); } } 

@Configuration @AutoConfigureAfter(value = {RabbitProducerDataSourceConfiguration.class}) public class RabbitProducerMyBatisConfiguration {  @Resource(name= "rabbitProducerDataSource")  private DataSource rabbitProducerDataSource;  @Bean(name="rabbitProducerSqlSessionFactory")

//自动注入上面 private DataSource rabbitProducerDataSource 入参<br>   public SqlSessionFactory rabbitProducerSqlSessionFactory(DataSource rabbitProducerDataSource) {<br>      <br>      SqlSessionFactoryBean bean = new SqlSessionFactoryBean();<br>      bean.setDataSource(rabbitProducerDataSource);<br>      ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();<br>      try {<br>         bean.setMapperLocations(resolver.getResources("classpath:mapper/*.xml"));<br>         SqlSessionFactory sqlSessionFactory = bean.getObject();<br>         if (sqlSessionFactory != null) {<br>            sqlSessionFactory.getConfiguration().setCacheEnabled(Boolean.TRUE);<br>         }<br>         return sqlSessionFactory;<br>      } catch (Exception e) {<br>         throw new RuntimeException(e);<br>      }<br>   }<br>   <br>   @Bean(name="rabbitProducerSqlSessionTemplate")<br>   public SqlSessionTemplate rabbitProducerSqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {<br>      return new SqlSessionTemplate(sqlSessionFactory);<br>   }<br>   <br>}<br>

@Configuration public class BrokerMessageConfiguration {  @Autowired  private DataSource rabbitProducerDataSource;  /**sql 脚本*/  @Value("classpath:rabbit-producer-message-schema.sql")  private Resource schemaScript;  @Bean  public DataSourceInitializer initDataSourceInitializer() { System.err.println("--------------rabbitProducerDataSource-----------:" + rabbitProducerDataSource);  final DataSourceInitializer initializer = new DataSourceInitializer(); 

//set数据源 创建jdbc 连接<br>        initializer.setDataSource(rabbitProducerDataSource);<br>        //执行脚本sql语句   （填充器）<br>        initializer.setDatabasePopulator(databasePopulator());<br>        return initializer;<br>    }<br><br>    private DatabasePopulator databasePopulator() {<br>        final ResourceDatabasePopulator populator = new ResourceDatabasePopulator();<br>        populator.addScript(schemaScript);<br>        return populator;<br>    }<br>}<br>

这里有三个@Configuration修饰的类,

@Configuration @AutoConfigureAfter(value = {RabbitProducerDataSourceConfiguration.class}) public class RabbitProducerMyBatisConfiguration { 

//此类在 加载前有条件 @AutoConfigureAfter(value = {RabbitProducerDataSourceConfiguration.class})<br>要等到这个配置类先加载 然后在执行 这样能保证  @Resource(name= "rabbitProducerDataSource") 可以被注入<br><br> @Resource(name= "rabbitProducerDataSource")<br>   private DataSource rabbitProducerDataSource;<br><br>....<br>....<br>...<br><br>}<br>

@Configuration public class BrokerMessageConfiguration { 

//此类为什么不加 @AutoConfigureAfter(value = {RabbitProducerDataSourceConfiguration.class})<br>能保证@Autowired 注入的数据源是 RabbitProducerDataSourceConfiguration 这个类声明的<br> @Bean(name ="rabbitProducerDataSource")<br><br><br>    @Autowired<br>    private DataSource rabbitProducerDataSource;<br>}<br>

还请希望详细解答一下

uareRight 2021-04-04

源自：手把手带你快速搞定分布式RabbitMQ 3-13 可靠性投递落地-ESJOB定时任务讲解-1

收起

1回答

阿神 2021-04-05 11:42:42

configuration注解主要是一个陪着（类似spring的xml），小伙伴可以把问题描述清楚一些

收起回答

提问者 uareRight #1

看了源码找到了问题，简易阿神看看源码，这样能更好的在视频里给小伙伴讲明白，而不是随便一说

2021-04-08 18:39:12
提问者 uareRight #2

看了源码找到了问题，建议阿神看看源码，这样能更好的在视频里给小伙伴讲明白，而不是随便一说

2021-04-08 18:39:48