将Spring batch连接到Spring集成工作流

Question

我试图在一个项目中结合Spring批处理和Spring集成。因此，我的想法是，Spring Batch使用stepbuilderFactory使用自定义方法读取文件，返回字符串，而.processor使用MessageBuilder创建新的消息 ，并将该消息发送到通道中...
所以从这里开始，Spring Integration连接到该通道，并开始工作其工作流...

知道如何实现吗？因为除了将读取的字符串输入.processor之外，我没有得到任何结果，但是我无法从那里获得Spring集成。我读过RemoteHunkingManagerStepBuilderFactory，但它不适合我的目的，因为它会自动设置特定的类型

 @Bean
    public TaskletStep managerStep() throws Exception {

        return managerStepBuilderFactory.get("managerStep")
                .<String, String>chunk(5)
                .reader(readFile())
                .processor(new MessageProcess())//write String into Message and send it to Channel
                .writer(doSomething())//not important
                .build();
    }

public class MessageProcess implements ItemProcessor<String, String> {

    @Override
    public String process(String readString) throws Exception {
        Message<String> message = MessageBuilder.withPayload(item).build();
        channel().send(message); //sending message to channel
        return "item";

    }
}

    @Bean
    public IntegrationFlow workflow() {
        return IntegrationFlows
                .from(channel())
                .handle(checkMessage()) //checkMessage reads payload from Message<?> message
                .get();
    }

    @Bean
    public DirectChannel channel() {
        return new DirectChannel();
    }

Answer 1

为了使Spring Integration与注释配置或Java DSL一起工作，您需要确保在您的@configuration类上指定了@enableIntegration。或者考虑使用Spring靴。

有关文档的更多信息：https://docs.spring.io/spring-integration/docs/5.2.3.release/reference/html/overview.html#configuration-enable-integration