我有一个spring webflux应用程序。

我正在将一些列表从数据库加载到 bean 中。我有两种方法可以实现此 bean 的加载。

方法1：反应方式

@Bean
  public List<Item> getItemList() throws IOException {
     List<Item> itemList = new ArrayList<>();
     itemRespository.findAll().collectList().subscribe(itemList::addAll);
     return itemList;
  }

方法二：阻塞方式

@Bean
public List<Item> getItemList() throws IOException {
     List<Item> itemList = itemRespository.findAll().collectList().block();
     return itemList;
 }

现在，由于我希望我的应用程序是被动的，所以我不想使用阻塞方式。但是我通过控制器公开的endpoint依赖于这个bean的数据。

@RestController
public class SomeController{

   @Autowired
   private List<items> getItemList;

   @GetMapping('/endpoint')
   public void process(){
     List list = getItemList; //this may not get initialzed as the bean loading is reactive

     //some more code
}
}

因此，在反应式方法的情况下，可能会发生有人可能会调用我的endpoint(因为应用程序已经启动并准备好服务请求)，而由于某种原因，可能会发生我的列表尚未从数据库中检索(可能是任何原因，例如:数据库服务器慢等)。)，为调用我的endpoint的用户产生不一致的结果(endpoint又依赖于这个bean)。

我正在寻找这种情况的解决方案。

编辑：更精确的问题是，我应该在我的应用程序中反应性地加载这些 bean，而我公开的endpoint依赖于这些 bean？