Spring Cloud stream-应用程序初始化后发送消息

Question

我正在尝试使用“spring cloud stream”向rabbitmq发送一条简单的消息。基本上代码如下所示：

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

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

    @Autowired Source source;

    @PostConstruct
    public void init() {
        source.send(MessageBuilder.withPayload("payload").build());
    }
}

然后，我收到以下错误消息：

org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'unknown.channel.name'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers, failedMessage=GenericMessage [payload=******, headers={id=c60dd5be-6576-99d5-fd1b-b1cb94c191c1, timestamp=1488651422892}]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:93)
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:423)
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:373)

然而，如果我在发送消息之前添加一些延迟（仅几秒钟），它就可以正常工作。我的问题是：如何在spring完全初始化消息通道然后发送消息之前等待？

Answer 1

您可以研究Spring的任务执行和调度特性。

特别是，听起来你想要第34.4节所涵盖的东西。

此外，我发现了一个类似问题的答案。

Answer 2

@PostConstruct触发得太早（在创建配置bean时，但在启动上下文和进行绑定之前）。您想要的是在上下文完全初始化后，或者至少在输出通道绑定后触发消息的发送。

您有几个选项，都依赖于创建一个额外的bean：

>

要使用来自Spring的SmartLifesycle支持（确保isAutoStartup默认返回true并且相位为零-默认-以便在输出绑定后启动bean）。

将Application ationListener用于ContextReFreshedEvent。

由于这是一个Spring Boot应用程序，您可以使用ApplicationRunner bean（在创建上下文后调用）。