进行一个异步调用，需要将ID存储到数据库而不阻塞。

huangapple
go评论103阅读模式
英文:

Make an Asynch call that needs to store ids to database without blocking

问题

我正在使用Spring的@Asynch注解。我有一个场景，需要进行两个API调用。其中一个API调用通过@Async打开了一个新线程，因为调用方不关心这个API调用，只关心第一个API调用。然而，这两个API调用都会返回我想要存储到数据库中的ID。我该如何完成这个任务？由于数据库的存储依赖于这两个ID，它将阻止我打开新线程的意图。

  1. public class SecondAPICallService {
  3.     @Async
  4.     public CompletableFuture<String> makeSecondApiCall(String firstAPICallId) {
  5.         var secondAPICallId = webClient.post(firstAPICallId, ...);
  6.         return CompletableFuture.completedFuture(secondAPICallId);
  7.     }
  8. }
  10. public class FirstAPICallService {
  12.     @Autowired
  13.     SecondAPICallService secondAPICallService;
  15.     @Autowired
  16.     DatabaseService dbService;
  18.     public Response makeApiCall(String firstAPICallId) {
  19.         Response response = webClient.post(..);
  20.         String id = response.getId();
  21.         CompletableFuture<String> secondAPICallId = secondAPICallService.makeSecondApiCall(id);
  22.         // 这里使用.get()会阻塞线程，但我不确定该怎么办，因为我需要存储到数据库中
  23.         String secondId = secondAPICallId.get();
  24.         dbService.save(id, secondId);
  25.         return response;
  26.     }
  27. }
  1. @Configuration
  2. @EnableAsync
  3. public class AsyncConfiguration {
  5.     @Bean(name = "asyncExecutor")
  6.     public Executor asyncExecutor() {
  7.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
  8.         executor.setCorePoolSize(3);
  9.         executor.setMaxPoolSize(3);
  10.         executor.setQueueCapacity(100);
  11.         executor.setThreadNamePrefix("AsyncThread-");
  12.         executor.initialize();
  13.         return executor;
  14.     }
  15. }

希望这对你有帮助。

英文:

I am using Spring @Asynch. I have a scenrio where I have to make two API calls. One API call opens a new thread via @Async since the caller doesn't care about this API call and only cares about the first API call. However, both these API calls return back ids that I want to store into the database. How will I go about accomplishing this? Since the storing of the database depends on both the ids it will block my intent of opening a new thread.

  1. public class SecondAPICallService {
  3.     @Asynch
  4.     public CompletableFuture&lt;String&gt; makeSecondApiCall(String firstAPICallId) {
  5. 	   var secondAPICallId = webClient.post(firstAPICallId, ...);
  6. 	   return  CompletableFuture.completedFuture(secondAPICallId);
  7.     }
  8. }
  10. public class FirstAPICallService {
  12.     @Autowire
  13.     SecondAPICallService secondAPICallService;
  15.     @Autowire
  16.     DatabaseService dbService;	
  18.     public Response makeApiCall(String firstAPICallId) {
  19. 	   Response response = webClient.post(..);
  20. 	   String id = response.getId();
  21. 	   CompletableFuture&lt;String&gt; secondAPICallId = secondAPICallService.makeSecondApiCall(id);
  22. 	   // This here blocks my thread with .get but not sure what to do since I need to store in db
  23.        String secondId = secondAPICallId.get();
  24. 	   dbService.save(id, secondId);		
  25. 	   return response;
  26.    }
  27. }
  1. @Configuration
  2. @EnableAsync
  3. public class AsyncConfiguration {
  5.     @Bean(name = &quot;asyncExecutor&quot;)
  6.     public Executor asyncExecutor() {
  7.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
  8.         executor.setCorePoolSize(3);
  9.         executor.setMaxPoolSize(3);
  10.         executor.setQueueCapacity(100);
  11.         executor.setThreadNamePrefix(&quot;AsynchThread-&quot;);
  12.         executor.initialize();
  13.         return executor;
  14.     }
  15. }

答案1

得分: 1

  1. public class SecondAPICallService {
  3.     @Async
  4.     public CompletableFuture<String> makeSecondApiCall(String firstAPICallId) {
  5.         // 进行第二次API调用
  6.         CompletableFuture<String> future = new CompletableFuture<>();
  7.         // 异步执行第二次API调用
  8.         // 一旦获取到第二次API调用的ID，使用该ID来完成CompletableFuture
  9.         // 例如：
  10.         String secondId = // 获取第二次API调用的ID
  11.         future.complete(secondId);
  12.         return future;
  13.     }
  14. }
  16. public class FirstAPICallService {
  18.     @Autowired
  19.     SecondAPICallService secondAPICallService;
  21.     @Autowired
  22.     DatabaseService dbService;  
  24.     public Response makeApiCall(String firstAPICallId) {
  25.         Response response = webClient.post(..);
  26.         String id = response.getId();
  27.         
  28.         // 异步执行第二次API调用
  29.         CompletableFuture<String> secondAPICallId = secondAPICallService.makeSecondApiCall(id);
  30.         
  31.         // 注册一个回调函数，以在第二次API调用完成时执行
  32.         secondAPICallId.thenAcceptAsync(secondId -> {
  33.             // 将ID保存到数据库
  34.             dbService.save(id, secondId);
  35.         });
  36.         
  37.         return response;
  38.     }
  39. }
英文: 
  2.  @Async
  3.  public CompletableFuture&lt;String&gt; makeSecondApiCall(String firstAPICallId) {
  4.      // Make the second API call
  5.      CompletableFuture&lt;String&gt; future = new CompletableFuture&lt;&gt;();
  6.      // Perform the second API call asynchronously
  7.      // Once you obtain the second API call ID, complete the CompletableFuture
  8.      // with the second API call ID value
  9.      // For example:
  10.      String secondId = // Obtain the second API call ID
  11.      future.complete(secondId);
  12.      return future;
  13.  }
  14. }
  18. public class FirstAPICallService {
  20.  @Autowired
  21.  SecondAPICallService secondAPICallService;
  23.  @Autowired
  24.  DatabaseService dbService;  
  26.  public Response makeApiCall(String firstAPICallId) {
  27.      Response response = webClient.post(..);
  28.      String id = response.getId();
  29.      
  30.      // Perform the second API call asynchronously
  31.      CompletableFuture&lt;String&gt; secondAPICallId = secondAPICallService.makeSecondApiCall(id);
  32.      
  33.      // Register a callback function to be executed when the second API call completes
  34.      secondAPICallId.thenAcceptAsync(secondId -&gt; {
  35.          // Save the IDs to the database
  36.          dbService.save(id, secondId);
  37.      });
  38.      
  39.      return response;
  40.  }
  41. }

huangapple
  • 本文由 发表于 2023年7月13日 21:53:30
  • 转载请务必保留本文链接：https://go.coder-hub.com/76680173.html
  • java
  • spring
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定