重写的RabbitSourceConfiguration（应用程序启动程序）不适用于Spring Cloud Edgware

Question

我正在测试我的Spring Cloud DataFlow服务从Spring Cloud Dalston.sr4/Spring Boot 1.5.9升级到Spring Cloud Edgware/Spring Boot 1.5.9。我的一些服务扩展了应用程序初学者的源（或接收器）组件。我发现这不适用于Spring Cloud Edgware。

例如，我已经重写了org.springframework.cloud.stream.app.rabbit.source.rabbitSourceConfiguration并将我的应用程序绑定到重写的版本。这在一年前的Spring Cloud版本中就已经起到了作用。

使用Edgware，我得到以下结果（无论应用程序是独立运行还是在数据流中运行）：

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

Description:

Field channels in org.springframework.cloud.stream.app.rabbit.source.RabbitSourceConfiguration required a bean of type 'org.springframework.cloud.stream.messaging.Source' that could not be found.


Action:

Consider defining a bean of type 'org.springframework.cloud.stream.messaging.Source' in your configuration.

spring-cloud-starter-stream-rabbit的1.3.0.release和1.2.0.release的行为与此相同。

我的子类通过@enableBinding(HeaderMapperRabbitSourceConfiguration.class)绑定到Spring Boot应用程序。我的子类的一个精简版本是：

public class HeaderMapperRabbitSourceConfiguration extends RabbitSourceConfiguration {

    public HeaderMapperRabbitSourceConfiguration(final MyHealthCheck healthCheck,
                                                 final MyAppConfig config) {
        // ...
    }

    @Bean
    @Override
    public AmqpInboundChannelAdapter adapter() {
        final AmqpInboundChannelAdapter adapter = super.adapter();
        adapter.setHeaderMapper(new NotificationHeaderMapper(config));

        return adapter;
    }

    @Bean
    @Override
    public SimpleMessageListenerContainer container() {
        if (config.performConnectivityCheckOnStartup()) {

            if (LOGGER.isInfoEnabled()) {
                LOGGER.info("Attempting connectivity with ...");
            }
            final Health health = healthCheck.health();
            if (health.getStatus() == Status.DOWN) {
                LOGGER.error("Unable to connect .....");
                throw new UnableToLoginException("Unable to connect ...");
            } else if (LOGGER.isInfoEnabled()) {
                LOGGER.info("Connectivity established with ...");
            }
        }

        return super.container();
    }
}

Answer 1

您确实不应该在@bean定义中执行healthcheck.health（）；之类的操作。应用程序上下文尚未完全烘焙或启动；它可能工作，也可能不工作，这取决于bean创建的顺序。

如果您想阻止应用程序启动，请添加一个实现SmartLifecycle的bean，将该bean置于后期阶段（高值），以便它在其他所有操作之后启动。然后将代码放在start()中。AutStartup必须为true。

在本例中，它是在流基础结构创建通道之前运行的。

我刚刚注意到您的@enablebinding是错误的；应该是source.class。我看不出这是如何工作的--这就是为source类型的channels字段创建bean的原因。

在将stream和绑定器更新到1.3.0后，这对我来说很好。发布...

@Configuration
public class MySource extends RabbitSourceConfiguration {

    @Bean
    @Override
    public AmqpInboundChannelAdapter adapter() {
        AmqpInboundChannelAdapter adapter = super.adapter();
        adapter.setHeaderMapper(new MyMapper());
        return adapter;
    }


}

和

@SpringBootApplication
@EnableBinding(Source.class)
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

}