因此，问题出在路由器上。当路由器尝试向通道发送消息时，出现错误：调度程序没有通道'newTypingNotificationHandler.input'的订阅者。但是我对此频道名称具有IntegrationFlow定义。

@Bean
public IntegrationFlow routeEcmIncomeRq(AbstractMessageRouter typeNotificationRouter) {
    return IntegrationFlows.from(FROM_CHANNEL)
            .routeToRecipients(r -> r
                    .recipientFlow(p -> p instanceof TypingNotificationDto,
                            f -> f.route(typeNotificationRouter)
                    )
                    .defaultOutputChannel(DEFAULT_SERVICE_CHANNEL)
            ).get();
}

@Bean
public AbstractMessageRouter typeNotificationRouter(IncomeRepository incomeRepository) {
    return new AbstractMessageRouter() {
        @Override
        protected Collection<MessageChannel> determineTargetChannels(Message<?> message) {
            TypingNotificationDto messagePayload = (TypingNotificationDto) message.getPayload();

            if (!incomeRepository.existsById(StringUtil.ecdFileIdToUuid(messagePayload.getEcdDocumentImage().getDocumentSource()))) {
                return Collections.singleton(MessageChannels.direct("newTypingNotificationHandler.input").get());
            } else {
                return Collections.singleton(MessageChannels.direct("existsTypingNotificationHandler.input").get());
            }
        }
    };
}

@Bean
public IntegrationFlow newTypingNotificationHandler() {
    return f -> f.log("need's create new Income");
}

@Bean
public IntegrationFlow existsTypingNotificationHandler() {
    return f -> f.log("exist income process");
}

stackTrace原因：

org.springframework.integration.MessageDispatchingException：Dispatcher在org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch（UnicastingDispatcher.java:139）上没有订阅者~~ spring-integration-core-5.2.6.RELEASE.jar：5.2.6 [RELEASE]，位于org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch（UnicastingDispatcher.java:106）〜[spring-integration-core-5.2.6.RELEASE.jar：5.2.6.RELEASE]，位于org.springframework.integration .channel.AbstractSubscribableChannel.doSend（AbstractSubscribableChannel.java:73）〜[spring-integration-core-5.2.6.RELEASE.jar：5.2.6.RELEASE] at org.springframework.integration.channel.AbstractMessageChannel.send（AbstractMessageChannel。 java：461）〜[spring-integration-core-5.2.6.RELEASE.jar：5.2.6.RELEASE]，位于org.springframework.integration.channel.AbstractMessageChannel。在org.springframework.messaging.core.GenericMessagingTemplate.doSend（GenericMessagingTemplate.java:187）上发送[AbstractMessageChannel.java:403）〜[spring-integration-core-5.2.6.RELEASE.jar：5.2.6.RELEASE]〜 [spring-messaging-5.2.6.RELEASE.jar：5.2.6.RELEASE]位于org.springframework.messaging.core.GenericMessagingTemplate.doSend（GenericMessagingTemplate.java:166）〜[spring-messaging-5.2.6.RELEASE。 jar：5.2.6.RELEASE]在org.springframework.messaging.core.GenericMessagingTemplate.doSend（GenericMessagingTemplate.java:47）〜[spring-messaging-5.2.6.RELEASE.jar：5.2.6.RELEASE]在org。 springframework.messaging.core.AbstractMessageSendingTemplate.send（AbstractMessageSendingTemplate.java:109）〜[spring-messaging-5.2.6.RELEASE.jar：5.2.6.RELEASE] at org.springframework.integration.router.AbstractMessageRouter.doSend（AbstractMessageRouter .java：206）〜[spring-integration-core-5.2.6.RELEASE.jar：5.2.6.RELEASE]