春云流3.0应用多豆启动失败

Question

我是Spring云流的新手。我正在使用兔子MQ粘合剂。问题是当我在主类中使用单个 bean 启动应用程序时，它就成功启动了。但是，如果我在主类中注册了 1 个以上的 bean，则应用程序无法从以下日志启动。

2020-09-18 12:41:45.698  INFO 27416 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.integration.IntegrationAutoConfiguration$IntegrationJmxConfiguration' of type [org.springframework.boot.autoconfigure.integration.IntegrationAutoConfiguration$IntegrationJmxConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-09-18 12:41:45.706  INFO 27416 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.boot.autoconfigure.jmx.JmxAutoConfiguration' of type [org.springframework.boot.autoconfigure.jmx.JmxAutoConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-09-18 12:41:45.712  INFO 27416 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'mbeanServer' of type [com.sun.jmx.mbeanserver.JmxMBeanServer] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-09-18 12:41:45.730  INFO 27416 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'integrationChannelResolver' of type [org.springframework.integration.support.channel.BeanFactoryChannelResolver] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-09-18 12:41:45.732  INFO 27416 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'integrationDisposableAutoCreatedBeans' of type [org.springframework.integration.config.annotation.Disposables] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-09-18 12:41:46.371  INFO 27416 --- [           main] o.s.s.c.ThreadPoolTaskScheduler          : Initializing ExecutorService 'taskScheduler'
2020-09-18 12:41:46.384  INFO 27416 --- [           main] o.s.c.f.c.c.SimpleFunctionRegistry       : Looking up function '' with acceptedOutputTypes: []
2020-09-18 12:41:46.627  INFO 27416 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel errorChannel
2020-09-18 12:41:46.722  INFO 27416 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageChannel nullChannel
2020-09-18 12:41:46.756  INFO 27416 --- [           main] o.s.i.monitor.IntegrationMBeanExporter   : Registering MessageHandler errorLogger
2020-09-18 12:41:46.791  INFO 27416 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2020-09-18 12:41:46.791  INFO 27416 --- [           main] o.s.i.channel.PublishSubscribeChannel    : Channel 'application.errorChannel' has 1 subscriber(s).
2020-09-18 12:41:46.791  INFO 27416 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : started bean '_org.springframework.integration.errorLogger'
2020-09-18 12:41:46.804  INFO 27416 --- [           main] com.***.RabbitMQTest             : Started RabbitMQTest in 2.441 seconds (JVM running for 4.047)
2020-09-18 12:41:46.814  INFO 27416 --- [extShutdownHook] o.s.i.endpoint.EventDrivenConsumer       : Removing {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2020-09-18 12:41:46.815  INFO 27416 --- [extShutdownHook] o.s.i.channel.PublishSubscribeChannel    : Channel 'application.errorChannel' has 0 subscriber(s).
2020-09-18 12:41:46.815  INFO 27416 --- [extShutdownHook] o.s.i.endpoint.EventDrivenConsumer       : stopped bean '_org.springframework.integration.errorLogger'
2020-09-18 12:41:46.817  INFO 27416 --- [extShutdownHook] o.s.s.c.ThreadPoolTaskScheduler          : Shutting down ExecutorService 'taskScheduler'
2020-09-18 12:41:46.822  INFO 27416 --- [extShutdownHook] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: bean 'errorChannel'
2020-09-18 12:41:46.823  INFO 27416 --- [extShutdownHook] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: nullChannel
2020-09-18 12:41:46.823  INFO 27416 --- [extShutdownHook] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: bean '_org.springframework.integration.errorLogger.handler' for component '_org.springframework.integration.errorLogger'
`

 @SpringBootApplication
 public class RabbitMQTest {

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

    @Bean
    public Function<String, String> toUpperCase() {
        return value -> {
            return value.toUpperCase();
        };
    }

    @Bean
    public Consumer<String> reverse() {
       return value -> new StringBuilder(value).reverse().toString();
    }

 }

application.yml文件

spring:
  cloud:
    stream:
      bindings:
        toUpperCase:
          binder: rabbitTest
          destination: toUpperCase-out-0
        reverse:
            binder: rabbitTest
      binders:
        rabbitTest:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                host: localhost
                port: 5672
                virtual-host: /
                username: ***
                password: ***

Answer 1

当我们有多个bean时，需要定义定义属性。从文档

我们使用 --spring.cloud.function.definition 属性来显式声明我们希望绑定到绑定目标的函数 bean。对于只有单个此类 bean 的情况，它不是必需的，但对于所有其他情况，它是

.