摘要:如果去掉,你會發現,執行這三個方法都在線程中執行。耗時總結,如下耗時通過這一個小的栗子,你應該對異步任務有了一定的了解。
這篇文章主要介紹在springboot 使用異步方法,去請求github api.
創建工程在pom文件引入相關依賴:
</>復制代碼
org.springframework.boot
spring-boot-starter
org.springframework
spring-web
com.fasterxml.jackson.core
jackson-databind
創建一個接收數據的實體:
</>復制代碼
@JsonIgnoreProperties(ignoreUnknown=true)
public class User {
private String name;
private String blog;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getBlog() {
return blog;
}
public void setBlog(String blog) {
this.blog = blog;
}
@Override
public String toString() {
return "User [name=" + name + ", blog=" + blog + "]";
}
}
創建一個請求的 githib的service:
</>復制代碼
@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 Future 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 new AsyncResult<>(results);
}
}
通過,RestTemplate去請求,另外加上類@Async 表明是一個異步任務。
開啟異步任務:
</>復制代碼
@SpringBootApplication
@EnableAsync
public class Application extends AsyncConfigurerSupport {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(2);
executor.setMaxPoolSize(2);
executor.setQueueCapacity(500);
executor.setThreadNamePrefix("GithubLookup-");
executor.initialize();
return executor;
}
}
通過@EnableAsync開啟異步任務;并且配置AsyncConfigurerSupport,比如最大的線程池為2.
測試測試代碼如下:
</>復制代碼
@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;
}
@Override
public void run(String... args) throws Exception {
// Start the clock
long start = System.currentTimeMillis();
// Kick of multiple, asynchronous lookups
Future page1 = gitHubLookupService.findUser("PivotalSoftware");
Future page2 = gitHubLookupService.findUser("CloudFoundry");
Future page3 = gitHubLookupService.findUser("Spring-Projects");
// Wait until they are all done
while (!(page1.isDone() && page2.isDone() && page3.isDone())) {
Thread.sleep(10); //10-millisecond pause between each check
}
// Print results, including elapsed time
logger.info("Elapsed time: " + (System.currentTimeMillis() - start));
logger.info("--> " + page1.get());
logger.info("--> " + page2.get());
logger.info("--> " + page3.get());
}
}
啟動程序,控制臺會打印:
</>復制代碼
2017-04-30 13:11:10.351 INFO 1511 — [ GithubLookup-1] com.forezp.service.GitHubLookupService : Looking up PivotalSoftware
2017-04-30 13:11:10.351 INFO 1511 — [ GithubLookup-2] com.forezp.service.GitHubLookupService : Looking up CloudFoundry
2017-04-30 13:11:13.144 INFO 1511 — [ GithubLookup-2] com.forezp.service.GitHubLookupService : Looking up Spring-Projects
耗時:3908
分析:可以卡的前面2個方法分別在GithubLookup-1 和GithubLookup-2執行,第三個在GithubLookup-2執行,注意因為在配置線程池的時候最大線程為2.如果你把線程池的個數為3的時候,耗時減少。
如果去掉@Async,你會發現,執行這三個方法都在main線程中執行。耗時總結,如下:
</>復制代碼
2017-04-30 13:13:00.934 INFO 1527 — [ main] com.forezp.service.GitHubLookupService : Looking up PivotalSoftware
2017-04-30 13:13:03.571 INFO 1527 — [ main] com.forezp.service.GitHubLookupService : Looking up CloudFoundry
2017-04-30 13:13:04.865 INFO 1527 — [ main] com.forezp.service.GitHubLookupService : Looking up Spring-Projects
耗時:5261
通過這一個小的栗子,你應該對異步任務有了一定的了解。
參考資料https://spring.io/guides/gs/a...
源碼下載https://github.com/forezp/Spr...
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/71469.html
摘要:本文介紹如何在中使用默認的聲明式緩存定義和接口用來統一不同的緩存技術。在使用集成的時候,我們需要注冊實現的的。默認使用在我們不使用其他第三方緩存依賴的時候,自動采用作為緩存管理器。源碼下載參考資料揭秘與實戰二數據緩存篇快速入門 本文介紹如何在springboot中使用默認的spring cache 聲明式緩存 Spring 定義 CacheManager 和 Cache 接口用來統一不...
摘要:另一種就是用中的位于包下,本質是由和實現的阻塞優先級隊列。表明了一條消息可在隊列中存活的最大時間。當某條消息被設置了或者當某條消息進入了設置了的隊列時,這條消息會在時間后死亡成為。 SpringBoot 是為了簡化 Spring 應用的創建、運行、調試、部署等一系列問題而誕生的產物,自動裝配的特性讓我們可以更好的關注業務本身而不是外部的XML配置,我們只需遵循規范,引入相關的依賴就可...
這篇文章主要介紹如何在springboot中如何創建含有多個module的工程,栗子中含有兩個 module,一個作為libarary. 工程,另外一個是主工程,調用libary .其中libary jar有一個服務,main工程調用這個服務。 創建根工程 創建一個maven 工程,其pom文件為: 4.0.0 com.forezp springboot-multi-...
閱讀 1804·2021-09-03 10:50
閱讀 1335·2019-08-30 15:55
閱讀 3374·2019-08-30 15:52
閱讀 1236·2019-08-30 15:44
閱讀 947·2019-08-30 15:44
閱讀 3323·2019-08-30 14:23
閱讀 3556·2019-08-28 17:51
閱讀 2297·2019-08-26 13:52