Spring Integration Service Activator处理器业务逻辑

Question

我目前刚接触Spring integration。
基本上尝试使用Java Spring integration DSL异步轮询多个文件位置。我需要获取文件名，并使用文件名执行一些操作，最后将文件推送到S3，我的问题是这些使用文件执行操作的任务是否可以在任务执行器或服务激活器处理程序中执行。我不确定哪个地方是对的。

@Autowired
private AWSFileManager awsFileManager;

@Bean
public IntegrationFlow inboundChannelFlow(@Value("${file.poller.delay}") long delay,
@Value("${file.poller.messages}") int maxMsgsPerPoll,
TaskExecutor taskExecutor, MessageSource<File> fileSource) 
{
    return IntegrationFlows.from(fileSource,
            c -> c.poller(Pollers.fixedDelay(delay)
                    .taskExecutor(taskExecutor)
                    .maxMessagesPerPoll(maxMsgsPerPoll)))
            .handle("AWSFileManager", "fileUpload")
            .channel(ApplicationConfiguration.inboundChannel)
            .get();
}

@Bean
TaskExecutor taskExecutor(@Value("${file.poller.thread.pool.size}") int poolSize) {
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    //Runnable task1 = () -> {this.methodsamp();};
    taskExecutor.setCorePoolSize(poolSize);

    //taskExecutor.execute(task1);
    return taskExecutor;
}
@Async
public void methodsamp()
{
    try
    {
        awsFileManager.fileUpload();
        System.out.println("test");
    }
    catch(Exception ex)
    {

    }

我在这里附上了示例代码。
还有一种方法可以检索通道中文件的文件名，因为我需要将它作为参数传递给fileUpload方法。请指教。

Answer 1

你的问题不清楚。TaskExecutor用于流中的线程上下文。服务激活器(.handle())完全适用于业务逻辑方法。这可以在执行器的线程上执行。并且在integrationflow中确实正确地使用了它们。

FileReadingMessageSource以java.io.file作为有效负载生成消息。所以，这就是获取文件名的方法--只需从file.getname()！