Spring启动中的两个依赖Web客户端api调用

Question

我有两个api调用，我需要根据第一个api调用结果获取第二个api调用结果，之后我需要合并两个api调用响应，让我写在这里

>

Api调用：https://localhost:8080/projects这是第一次api调用

[ {

 "projectId" : 2,
 "projectName" : "Hello",
 "projectDesc" : "Demo project"
 },
 {

 "projectId" : 3,
 "projectName" : "Hello123",
 "projectDesc" : "Demo project series"
 },
 {
    "projectId" : 4,
     "projectName" : "Hello456",
     "projectDesc" : "Demo project repeat"
     }
 ]

第二个 api 调用在 （http://localhost:8080/2） http://localhost:8080/projectId 此结果，如下所示

[

{
"teamMember" : "abc",
"teamMemberRole": "Manager"
}
]

现在我需要合并两个响应，如何使用Webclient来实现这一点

[
{

"projectId" : 2,
"projectName" : "Hello",
"projectDesc" : "Demo project",
"teamMember" : "abc",
"teamMemberRole" : "Manager"
}
]

谢谢你的帮助。提前感谢

Answer 1

我想我理解你的问题，它很常见。您想做的关键是创建一个响应流，其中每个元素都与子响应流合并。即。

• 获取项目
  • 对于每个项目
    • 通过projectId并获得团队成员

    假设您有一个服务类，它可以获取给定项目的项目和团队成员的数据。

    getAllProjects和getTeamMembers

    您可以使用它来编写名为“getProjectsSusTeam会员”的结果函数

    @Component
    @Slf4j
    public class ProjectHandler {
    
        @Autowired
        private WebClient webClient;
    
        public Flux<Project> getAllProjects() {
    
            return webClient
                .get()
                .uri("projects")
                .retrieve()
                .bodyToFlux(Project.class);
        }
    
        public Mono<List<TeamMember>> getTeamMembers(Integer id) {
             ParameterizedTypeReference<List<TeamMember>> listParameterizedTypeReference =
                new ParameterizedTypeReference<List<TeamMember>>() {
                };
            return webClient.get()
                    .uri("" + id)
                    .retrieve()
                    .onStatus(HttpStatus::is4xxClientError, clientResponse ->
                        Mono.empty()
                    )
                    .bodyToMono(listParameterizedTypeReference)
                    .log();
        }
    
        public Flux<Project> getProjectsWithTeamMembers() {
            return getAllProjects()
                    .flatMap(project ->
                            Mono.zip(Mono.just(project),
                                getTeamMembers(project.getProjectId()).defaultIfEmpty(new ArrayList<TeamMember>()))
                    .map(tuple -> {
                        log.info("data" + tuple.getT2().size());
                        return 
     Project.builder().projectId(tuple.getT1().getProjectId())
                            .projectName(tuple.getT1().getProjectName())
                            .projectDesc(tuple.getT1().getProjectDesc())
                            .teamMemberList(tuple.getT2()).build();
                }));
    
        }
    }
    

    请注意，元组是

    元

    在这里，您所做的就是使用单声道。zip并将两件事传递给它

    • 项目
    • 团队成员列表

    Mono.zip将它组合在一起，并创建项目和团队成员的 Tuple2，您可以使用它来编写映射代码以构建完整的响应。

    希望这有帮助。

    --更新--下面是更新代码

    Config for webclient

    @Configuration
    public class AppConfig {
    
        @Bean
        public WebClient webClient(WebClient.Builder webClientBuilder) {
            return webClientBuilder
                    .baseUrl("http://localhost:3000/")
                    .defaultHeader(HttpHeaders.CONTENT_TYPE,  "application/json")
                    .build();
        }
    }
    

    模型类

     @Data
     @AllArgsConstructor
     @NoArgsConstructor
     @Builder
     public class Project {
        private Integer projectId;
        private String projectName;
        private String projectDesc;
        private List<TeamMember> teamMemberList;
    
     }
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    @Builder
    public class TeamMember {
        private String teamMember;
        private String teamMemberRole;
    }
    

    最后是其余控制器

    @RestController
    @Slf4j
    public class ProjectController {
    
        @Autowired
        private ProjectHandler projectHandler;
    
        @GetMapping(PROJECT_ENDPOINT_V1)
        public Flux<Project> getAllProjects() {
            return projectHandler.getProjectsWithTeamMembers();
        }
    
    }