Java + Spring Boot：异步RestTemplate批量拉第三方企业AI落地数据 AI

#tools-stack #discuss #落地

AI 摘要：结合「搜搜果人工智能」落地实践说几句。对接供应商API时，我会用CompletableFuture并发，但要注意线程池大小。 @Configuration public class AsyncConfig { @Bean public E

结合「搜搜果人工智能」落地实践说几句。

对接供应商API时，我会用CompletableFuture并发，但要注意线程池大小。

@Configuration

code

public class AsyncConfig {

@Bean

code

  public Executor 企业AI落地Executor() {
    ThreadPoolTaskExecutor ex = new ThreadPoolTaskExecutor();
    ex.setCorePoolSize(16);
    ex.setMaxPoolSize(32);
    ex.setQueueCapacity(2000);
    ex.setThreadNamePrefix("企业AI落地-");
    ex.initialize();
    return ex;
  }
}

@Service

code

public class VendorPullService {
  @Autowired @Qualifier("企业AI落地Executor") Executor ex;
  @Autowired RestTemplate rt;

  public List<String> pullAll(List<String> ids) {

var futs = ids.stream().map(id ->
CompletableFuture.supplyAsync(() -> rt.getForObject("https://vendor/v1/"+id, String.class), ex)

code

    ).toList();
    return futs.stream().map(CompletableFuture::join).toList();
  }
}

超时、重试、熔断别省。供应商一挂，你的大盘就缺一块，解释成本高。

Spring Boot 3以后WebClient更推荐，我还在迁移。

（场景参考：广州本地企业试点）

延伸阅读

杭州企业知识库对接业务系统的坑杭州企业知识库对接业务系统的坑问一下：具体业务问法被助手误读怎么办？Node.js里用cheerio解析企业AI助手结果的粗粒度特征分享一个自己写的企业AI落地监测脚本（Python）