Spring集成-服务执行元引发文件写入操作错误

Question

implementation 'org.springframework.boot:spring-boot-starter-integration'
implementation 'org.springframework.integration:spring-integration-file'

@EnableIntegration
@IntegrationComponentScan
@SpringBootApplication
public class IntegrationApplication {

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

    @Bean
    public FileWritingMessageHandler fileWritingMessageHandler() {
        return new FileWritingMessageHandler(new File("outDir"));
    }

    @Bean
    @InboundChannelAdapter(channel = "fileInputChannel", poller = @Poller(fixedDelay = "5000"))
    public MessageSource<File> pollableFileSource() {
        FileReadingMessageSource fileReadingMessageSource = new FileReadingMessageSource();
        fileReadingMessageSource.setDirectory(new File("inputDir"));
        fileReadingMessageSource.setFilter(new SimplePatternFileListFilter("*.txt"));

        return fileReadingMessageSource;
    }

}

@Service
public class ActivatorService {
    @Autowired
    private FileWritingMessageHandler fileWritingMessageHandler;

    @ServiceActivator(inputChannel = "fileInputChannel")
    public MessageHandler fileReceiver(Message<?> message) {
        fileWritingMessageHandler.setFileExistsMode(FileExistsMode.REPLACE);
        fileWritingMessageHandler.setDeleteSourceFiles(true);
        fileWritingMessageHandler.setExpectReply(false);
        fileWritingMessageHandler.setAutoCreateDirectory(true);

        return fileWritingMessageHandler;
    }
}

O.S.I.ExpressionUtils：创建没有beanFactory的EvaluationContext

错误：

原因：

原因：org.SpringFramework.Messaging.core.DestinationResolutionException：org.SpringFramework.Integration.Handler.AbstractMessageProducingHandler.SendOutput（AbstractMessageProducingHandler.java:426)（org.SpringFramework.Integration.Handler.AbstractMessageProducingHandler.DoProduceOutput（AbstractMessageProducingHandler.284)（

Answer 1

FileWritingMessageHandler必须是@bean。

您自己调用new，因此它不是由Spring管理的。

在任何情况下，您都不希望每个消息都有一个新的处理程序。

@Bean
@ServiceActivator(inputChannel = "fileInputChannel")
public MessageHandler fileReceiver() {
    FileWritingMessageHandler handler = new FileWritingMessageHandler(new File("outDir"));
    handler.setFileExistsMode(FileExistsMode.REPLACE);
    handler.setDeleteSourceFiles(true);
    handler.setExpectReply(false);

    handler.setAutoCreateDirectory(true);
    return handler;
}