Spring WebFlux/Reactor使用@Scheduled读取数据库并执行某些任务

Question

我是spring webflux的新手，我当前的Spring Boot应用程序使用调度程序（注释为@scheduled)从DB读取数据列表，批量并发调用rest api，然后写入事件流，我想在spring webflux中实现同样的操作。

1. 我应该使用@schedule，还是从WebFlux使用scheduleperiotially？
2. 如何将DB中的项目批处理成更小的集合（例如10个项目），并并发调用rest API？
3. 目前，该应用程序在一次调度程序运行中最多获取100条记录，然后对其进行处理。我计划转移到r2dbc，如果我这样做了，我可以限制数据流像100吗？

谢谢

Answer 1

1.我应该使用@schedule，还是从WebFlux中使用scheduleperiotially？

@schedule是spring framework调度包的一部分的注释，而SchedulePeriotialy是reactor的一部分的函数，所以您不能真正比较两者。我认为使用注释没有任何问题，因为它是核心框架的一部分。

2.我如何将DB中的项目批处理成更小的集合（比如10个项目），并并发调用rest API？

通过使用flux#buffer函数，该函数将在缓冲区满时发出项列表。

Flux.just("1", "2", "3", "4")
        .buffer(2)
        .doOnNext(list -> {
            System.out.println(list.size());
        }).subscribe()

每次将打印2个。

3.目前应用程序在一次调度程序运行中最多获取100条记录，然后对其进行处理。我正在计划转移到r2dbc，如果我这样做了，我可以限制像100的数据流吗？