創建一個GitHub用戶信息查找服務，這個服務是通過GitHub的API獲取數據的。

接口是http的，如下：

這里創建一個model去接收對象：

@Data @JsonIgnoreProperties(ignoreUnknown = true) public class User {private String name;private String blog; }

@JsonIngnore告訴spring忽略其他json屬性。

下面是創建GitHub檢索服務，代碼如下：

@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();}public CompletableFuture<User> 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);Thread.sleep(1000L);return CompletableFuture.completedFuture(results);} }

GItHubLookupService使用RestTemplate調用api.github.com/users，獲取User對象。

AppRunner.java

@Component public class AppRunner implements CommandLineRunner {private static final Logger logger = LoggerFactory.getLogger(AppRunner.class);private final GitHubLookupService gitHubLookupService;public AppRunner(GitHubLookupService gitHubLookupService){this.gitHubLookupService = gitHubLookupService;}@Overridepublic void run(String... args) throws Exception {long start = System.currentTimeMillis();CompletableFuture<User> pivotalSoftware = gitHubLookupService.findUser("PivotalSoftware");CompletableFuture<User> cloudFoundry = gitHubLookupService.findUser("CloudFoundry");CompletableFuture<User> user = gitHubLookupService.findUser("Spring-Projects");CompletableFuture.allOf(pivotalSoftware, cloudFoundry, user).join();logger.info("Elapsed time: " + (System.currentTimeMillis() - start));logger.info("-->" + pivotalSoftware.get());logger.info("-->" + cloudFoundry.get());logger.info("-->" + user.get());logger.info("---------- over ----------");} }

DemoApplication.java

@SpringBootApplication @EnableAsync public class DemoApplication {@Beanpublic Executor taskExecutor(){ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(2);executor.setMaxPoolSize(2);executor.setQueueCapacity(500);executor.setThreadNamePrefix("GithubLookup-");executor.initialize();return executor;}public static void main(String[] args) {SpringApplication.run(DemoApplication.class, args);}}

?

總結

以上是生活随笔為你收集整理的Spring Boot文档阅读笔记-Creating Asynchronous Methods解析的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。