Java使用RestTemplate和CompletableFuture并行调用同一个三方HTTP分页接口,并将响应报文通过MyBatis-Plus写入MySQL中

好的，我可以为您提供一些思路和代码示例。

首先，您可以使用RestTemplate发送HTTP请求，以获取分页数据。在这个过程中，您可以使用CompletableFuture并行调用多个HTTP请求，以提高效率。

以下是使用RestTemplate发送HTTP请求的示例代码：

RestTemplate restTemplate = new RestTemplate();
String url = "http://example.com/api?page={page}&size={size}";
int page = 1;
int size = 10;
while (true) {
    ResponseEntity<List<MyData>> response = restTemplate.exchange(url, HttpMethod.GET,
        null, new ParameterizedTypeReference<List<MyData>>() {}, page, size);
    List<MyData> dataList = response.getBody();
    // 处理数据
    if (dataList.isEmpty()) {
        break;
    }
    page++;
}

接下来，您可以使用CompletableFuture并行调用多个HTTP请求，以提高效率。以下是示例代码：

RestTemplate restTemplate = new RestTemplate();
String url = "http://example.com/api?page={page}&size={size}";
int pageSize = 10;
int totalPages = 10;
List<CompletableFuture<List<MyData>>> futures = new ArrayList<>();
for (int page = 1; page <= totalPages; page++) {
    CompletableFuture<List<MyData>> future = CompletableFuture.supplyAsync(() -> {
        ResponseEntity<List<MyData>> response = restTemplate.exchange(url, HttpMethod.GET,
            null, new ParameterizedTypeReference<List<MyData>>() {}, page, pageSize);
        return response.getBody();
    });
    futures.add(future);
}
List<MyData> dataList = new ArrayList<>();
for (CompletableFuture<List<MyData>> future : futures) {
    dataList.addAll(future.get());
}

最后，您可以使用MyBatis-Plus将数据写入MySQL数据库中。以下是示例代码：

MybatisSqlSessionFactoryBean factoryBean = new MybatisSqlSessionFactoryBean();
factoryBean.setDataSource(dataSource);
factoryBean.setTypeAliasesPackage("com.example.model");
factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
    .getResources("classpath:/mapper/*.xml"));
SqlSessionFactory sessionFactory = factoryBean.getObject();
try (SqlSession sqlSession = sessionFactory.openSession()) {
    MyDataMapper myDataMapper = sqlSession.getMapper(MyDataMapper.class);
    myDataMapper.batchInsert(dataList);
    sqlSession.commit();
}

上述示例代码中，MyData是数据模型类，MyDataMapper是MyBatis-Plus的Mapper接口，batchInsert是批量插入方法。

希望这些代码示例能够对您有所帮助！