使用请求上下文并行调用上游服务

Question

我是SpringWebFlux的新手。

我有一个不支持批处理调用的上游服务，因此我必须为数组中的每个对象多次调用它。我还需要请求参数的实例，因为服务在响应中不返回这些属性。

例如，这是我将发送给客户的回复

class Person {
  int id;
  String name;
  int phoneNo;
}

我只有身份证清单

列表

对于每个人，api响应也是

{
   "name": "name",
   "phoneNo": 2222222222
}

注意，响应中没有id字段，因此，我需要请求参数来映射请求和响应。

我有一个名为createRequestFromIdWillReturnMono（int-id）的方法，它接受整数id并返回web客户端Mono作为响应。

到目前为止我所尝试的

List<Person> response = new ArrayList<Person>();
List<Integer> lstInt = IntStream.rangeClosed(0, 10).boxed().collect(Collectors.toList());
Flux
     .fromIterable(lstInt)
     .flatMap(i -> createRequestFromIdWillReturnMono(i)
                       .map(personResponse -> response.add(new Person(i, personResponse))));
return response; 

但这段代码只运行响应。添加调用一次，即使它调用createRequestFromIdWillReturnMono 10次。

我该怎么解决这个问题？




Answer 1

你不需要这个列表，你可以使用CollectList返回一个列表。或者返回Flux

Mono<List<Persons>> personsMono = Flux.fromIterable(lstInt)
     .flatMap(i -> createRequestFromIdWillReturnMono(i))
     .map(personResponse -> new Person(i,personResponse))
     .collectList();

像这样的事情，我现在不在电脑前，所以不能保证它能编译，但你应该明白。