前言

創(chuàng)新互聯(lián)建站長(zhǎng)期為上1000家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開(kāi)放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為色尼企業(yè)提供專業(yè)的成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作，色尼網(wǎng)站改版等技術(shù)服務(wù)。擁有10余年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開(kāi)發(fā)。

在Spring Boot中有一個(gè)注釋@Async，可以幫助開(kāi)發(fā)人員開(kāi)發(fā)并發(fā)應(yīng)用程序。但使用此功能非常棘手。在本博客中，我們將了解如何將此功能與CompletableFuture一起使用。我認(rèn)為你已經(jīng)知道關(guān)于CompletableFuture的基礎(chǔ)，所以我不會(huì)在這里重復(fù)這個(gè)概念。

首先，您需要使用@EnableAsync來(lái)注釋您的應(yīng)用程序類，這個(gè)注釋告訴Spring查找使用@Async注釋的方法并在單獨(dú)的執(zhí)行程序中運(yùn)行它們。

@SpringBootApplication
@EnableAsync
public class App {
 RestTemplate
 public static void main(String[] args) {
  SpringApplication.run(App.class, args);
 }
}

如果您查看有關(guān)使用CompletableFuture和@Async的Spring Boot示例，您會(huì)注意到他們使用此功能的方式基于REST請(qǐng)求，在我看來(lái)，我相信，它有點(diǎn)受限，它不會(huì)給你在其他情況下如何使用此功能的線索。例如，如果你有一個(gè)長(zhǎng)期運(yùn)行的任務(wù)，你會(huì)怎么做？

// Source : https://spring.io/guides/gs/async-method/
package hello;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.concurrent.CompletableFuture;

@Service
public class GitHubLookupService {

  private static final Logger logger = LoggerFactory.getLogger(GitHubLookupService.class);

  private final RestTemplate restTemplate;

  public GitHubLookupService(RestTemplateBuilder restTemplateBuilder) {
    this.restTemplate = restTemplateBuilder.build();
  }

  @Async
  public CompletableFuture findUser(String user) throws InterruptedException {
    logger.info("Looking up " + user);
    String url = String.format("https://api.github.com/users/%s", user);
    User results = restTemplate.getForObject(url, User.class);
    // Artificial delay of 1s for demonstration purposes
    Thread.sleep(1000L);
    return CompletableFuture.completedFuture(results);
  }

}

在FindUser（String user）中，它在主線程中使用CompletableFuture，此方法的主要任務(wù)是使用RestTemplate從github獲取數(shù)據(jù)，功能是“執(zhí)行HTTP請(qǐng)求的同步客戶端”。如何使用長(zhǎng)時(shí)間運(yùn)行的任務(wù)，如調(diào)用網(wǎng)絡(luò)功能，如從REST端點(diǎn)ping服務(wù)器？在這種情況下，您需要定制CompletableFuture。你不能簡(jiǎn)單地調(diào)用：

return CompletableFuture.completedFuture(results);

如何使用CompletableFuture

要在代碼中使用@Async，您的方法必須返回Future或CompletableFuture，看一下下面的例子：

@Async
  public CompletableFuture isServerAlive(String ip) {
    CompletableFuture future = new CompletableFuture(){
      @Override
      public Boolean get() throws InterruptedException, ExecutionException {
        InetAddress address = null;
        try {
          address = InetAddress.getByName(ip);
          return address.isReachable(1000);
        } catch (UnknownHostException e) {
          e.printStackTrace();
          return false;
        } catch (IOException e) {
          e.printStackTrace();
          return false;
        }
      }
    };
    return future;
}

在這個(gè)例子中，我重寫(xiě)了get（）方法并返回CompletableFuture而沒(méi)有任何線程執(zhí)行器，事實(shí)上我們要求Spring在不同的線程中執(zhí)行@Async方法，但是我們不提供任何線程執(zhí)行器，只有后臺(tái)工作者中運(yùn)行就足夠了。

download source code from github （本地下載）

注意：在這個(gè)例子中，我決定在Spring Boot中使用一個(gè)網(wǎng)絡(luò)函數(shù)，僅僅是為了一個(gè)參數(shù)。但最好不要在REST端點(diǎn)中直接使用網(wǎng)絡(luò)功能，特別是當(dāng)您希望立即獲得結(jié)果時(shí)。原因是：網(wǎng)絡(luò)功能是阻塞的，這意味著，如果你調(diào)用這個(gè)REST端點(diǎn)，您必須在端點(diǎn)等待獲取結(jié)果。強(qiáng)烈建議使用其他方法（如queue或push方法）（例如websocket）來(lái)調(diào)用阻塞函數(shù)。

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)創(chuàng)新互聯(lián)的支持。