Java Rest api 需要等待才能处理

Question

我有一个 Java Rest API，物联网设备将使用它来发送数据。每个设备都有一个时间段(比如 15 秒)与 API 进行通信。在该时间段内，可以有多个具有相同数据集的消息。

我想要做的是，当 API 从设备接收到新消息时，它会等到时间段结束并收集收到的消息。并仅在时间段结束时处理消息。

我应该使用什么来收集和处理给定时间段内的消息？

谢谢。

编辑使用 Spring Boot。

Answer 1

您应该尝试使用异步端点来调用同步 REST。您可以定义达到超时后要执行的操作。

例如，在 Spring Boot 中，您可以返回 Callable 并使用 TaskExecutor:

@Controller
public class MyController {

    @RequestMapping("/endpoint") 
    public @ResponseBody WebAsyncTask<String> handleRequest (HttpServletRequest request) {

        Callable<String> callable = () -> {
            return "Callable";
        };

        ConcurrentTaskExecutor taskExecutor = new ConcurrentTaskExecutor(Executors.newFixedThreadPool(1));

        return new WebAsyncTask<>(15000L, taskExecutor, callable);

    }
}

您可能需要在 Spring 中为任务执行器线程池添加一些配置:

@SpringBootApplication
public class AsyncConfigExample {

    @Bean
    WebMvcConfigurer configurer(){
        return new WebMvcConfigurerAdapter(){
            @Override
            public void configureAsyncSupport (AsyncSupportConfigurer configurer) {
                ThreadPoolTaskExecutor t = new ThreadPoolTaskExecutor();
                t.setCorePoolSize(10);
                t.setMaxPoolSize(100);
                t.setQueueCapacity(50);
                t.setAllowCoreThreadTimeOut(true);
                t.setKeepAliveSeconds(120);
                t.initialize();
                configurer.setTaskExecutor(t);
            }
        };
    }

}

这里还有更多内容需要阅读:

• Spring MVC: Configuring Asynchronous Request Processing
• Spring Boot: Executing asynchronous method backed with a queue