來源 | 沉默王二

教妹子學 Spring，沒見過這么放肆的標題吧？

作者我有一個漂亮如花的妹妹（見封面圖，別問我怎么又變了？還不能一天做個夢了？），她叫什么呢？我想聰明的讀者能猜得出：沉默王三，沒錯，年方三六。父母正考慮讓她向我學習，做一名正兒八經的 Java 程序員。我一開始是反對的，因為程序員這行業容易掉頭發，女生可不適合掉頭發。但家命難為啊，與其反對，不如做點更積極的事情，比如說寫點有趣的文章教教她。

“二哥，聽說今天要學習 Spring 的 Aware、異步編程、計劃任務，真的是翹首以盼啊?！?/p>

Spring Aware

“二哥，據說 Aware 的目的是讓 Bean 獲取 Spring 容器的服務，你能給我具體說說嗎？”

“沒問題啊?！?/p>

Bean 一般不需要了解容器的狀態和直接使用容器，但是在某些情況下，需要在 Bean 中直接對容器進行操作，這時候，就可以通過特定的 Aware 接口來完成。常見的 Spring Aware 接口有下面這些：

1）BeanNameAware

新建一個 MyBeanName 類，內容如下：

public?class?MyBeanName?implements?BeanNameAware?{@Overridepublic?void?setBeanName(String?beanName)?{System.out.println(beanName);} }

MyBeanName 實現了 BeanNameAware 接口，并重寫了?setBeanName()?方法。beanName 參數表示 Bean 在 Spring 容器中注冊的 name。

新建一個 Config 類，內容如下：

@Configuration public?class?Config?{@Bean(name?=?"myCustomBeanName")public?MyBeanName?getMyBeanName()?{return?new?MyBeanName();} }

@Bean?注解用在?getMyBeanName()?方法上，表明當前方法返回一個 Bean 對象（MyBeanName），并通過 name 屬性指定 Bean 的名字為“myCustomBeanName”。

新建 BeanNameMain 類，代碼如下：

public?class?BeanNameMain?{public?static?void?main(String[]?args)?{AnnotationConfigApplicationContext?context?=?new?AnnotationConfigApplicationContext(BeanNameConfig.class);MyBeanName?myBeanName?=?context.getBean(MyBeanName.class);context.close();} }程序輸出的結果如下所示： myCustomBeanName

如果把?@Bean()?注解中的?(name = "myCustomBeanName)"?去掉的話，程序輸出的內容將會是 BeanNameConfig 類的?getMyBeanName()?的方法名“getMyBeanName”。

2）BeanFactoryAware

新建一個 MyBeanFactory 類，內容如下：

public?class?MyBeanFactory?implements?BeanFactoryAware?{private?BeanFactory?beanFactory;@Overridepublic?void?setBeanFactory(BeanFactory?beanFactory)?throws?BeansException?{this.beanFactory?=?beanFactory;}public?void?getMyBeanName()?{MyBeanName?myBeanName?=?beanFactory.getBean(MyBeanName.class);System.out.println(beanFactory.isSingleton("myCustomBeanName"));System.out.println(beanFactory.isSingleton("getMyBeanFactory"));} }

借助?setBeanFactory()?方法，可以將容器中的 BeanFactory 賦值給 MyBeanFactory 類的成員變量 beanFactory，這樣就可以在?getMyBeanName()方法中使用 BeanFactory 了。

通過?getBean()?方法可以獲取 Bean 的實例；通過?isSingleton()?方法判斷 Bean 是否為一個單例。

在 Config 類中追加 MyBeanFactory 的 Bean：

@Configuration public?class?Config?{@Bean(name?=?"myCustomBeanName")public?MyBeanName?getMyBeanName()?{return?new?MyBeanName();}@Beanpublic?MyBeanFactory?getMyBeanFactory()?{return?new?MyBeanFactory();} }

新建 BeanFactoryMain 類，代碼如下：

public?class?BeanFactoryMain?{public?static?void?main(String[]?args)?{AnnotationConfigApplicationContext?context?=?new?AnnotationConfigApplicationContext(Config.class);MyBeanFactory?myBeanFactory?=?context.getBean(MyBeanFactory.class);myBeanFactory.getMyBeanName();context.close();} }

初始化 MyBeanFactory 后就可以調用?getMyBeanName()?方法了，程序輸出的結果如下所示：

myCustomBeanName true true

結果符合我們的預期：MyBeanName 的名字為“myCustomBeanName”，MyBeanName 和 MyBeanFactory 的 scope 都是 singleton。

3）其他幾個 Aware 接口就不再舉例說明了。通常情況下，不要實現 Aware 接口，因為它會使 Bean 和 Spring 框架耦合。

異步編程

“二哥，據說 Spring 可以通過 @Async 來實現異步編程，你能給我詳細說說嗎？”

“沒問題啊。”

新建一個 AsyncService 類，內容如下：

public?class?AsyncService?{@Asyncpublic?void?execute()?{System.out.println(Thread.currentThread().getName());} }

@Async?注解用在 public 方法上，表明?execute()?方法是一個異步方法。

新建一個 AsyncConfig 類，內容如下：

@Configuration @EnableAsync public?class?AsyncConfig?{@Beanpublic?AsyncService?getAsyncService()?{return?new?AsyncService();} }

在配置類上使用?@EnableAsync?注解用以開啟異步編程，否則?@Async?注解不會起作用。

新建一個 AsyncMain 類，內容如下：

public?class?AsyncMain?{public?static?void?main(String[]?args)?{AnnotationConfigApplicationContext?context?=?new?AnnotationConfigApplicationContext(AsyncConfig.class);AsyncService?service?=?context.getBean(AsyncService.class);for?(int?i?=?0;?i?<?10;?i++)?{service.execute();}}

程序輸出結果如下：

SimpleAsyncTaskExecutor-1 SimpleAsyncTaskExecutor-9 SimpleAsyncTaskExecutor-7 SimpleAsyncTaskExecutor-8 SimpleAsyncTaskExecutor-10 SimpleAsyncTaskExecutor-3 SimpleAsyncTaskExecutor-2 SimpleAsyncTaskExecutor-4 SimpleAsyncTaskExecutor-6 SimpleAsyncTaskExecutor-5

OK，結果符合我們的預期，異步編程實現了。就像你看到的那樣，Spring 提供了一個默認的 SimpleAsyncTaskExecutor 用來執行線程，我們也可以在方法級別和應用級別上對執行器進行配置。

1）方法級別

新建 AsyncConfig 類，內容如下：

@Configuration @EnableAsync public?class?AsyncConfig?{@Beanpublic?AsyncService?getAsyncService()?{return?new?AsyncService();}@Bean(name?=?"threadPoolTaskExecutor")public?Executor?threadPoolTaskExecutor()?{ThreadPoolTaskExecutor?executor?=?new?ThreadPoolTaskExecutor();executor.setCorePoolSize(5);return?executor;} }

在配置類中創建了一個返回類型為 Executor 的 Bean，其名稱定義為“threadPoolTaskExecutor”，并且重新設置了 ThreadPoolTaskExecutor 的核心線程池大小，默認為 1，現在修改為 5。

新進 AsyncService 類，內容如下：

public?class?AsyncService?{@Async("threadPoolTaskExecutor")public?void?execute()?{System.out.println(Thread.currentThread().getName());} }

@Async?注解上需要指定我們之前配置的線程池執行器“threadPoolTaskExecutor”。

新建 AsyncMain 類，內容如下：

public?class?AsyncMain?{public?static?void?main(String[]?args)?{AnnotationConfigApplicationContext?context?=?new?AnnotationConfigApplicationContext(AsyncConfig.class);AsyncService?service?=?context.getBean(AsyncService.class);for?(int?i?=?0;?i?<?10;?i++)?{service.execute();}} }

程序運行結果如下：

threadPoolTaskExecutor-1 threadPoolTaskExecutor-2 threadPoolTaskExecutor-4 threadPoolTaskExecutor-3 threadPoolTaskExecutor-5 threadPoolTaskExecutor-3 threadPoolTaskExecutor-2 threadPoolTaskExecutor-4 threadPoolTaskExecutor-1 threadPoolTaskExecutor-5

從結果中可以看得出，線程池執行器變成了“threadPoolTaskExecutor”，并且大小為 5。

2）應用級別

新建 AsyncConfig 類，內容如下：

@Configuration @EnableAsync public?class?AsyncConfig?implements?AsyncConfigurer?{@Beanpublic?AsyncService?getAsyncService()?{return?new?AsyncService();}@Overridepublic?Executor?getAsyncExecutor()?{ThreadPoolTaskExecutor?executor?=?new?ThreadPoolTaskExecutor();executor.setCorePoolSize(3);executor.initialize();return?executor;} }需要實現 AsyncConfigurer 接口，并重寫?getAsyncExecutor()?方法，這次設置線程池的大小為 3。注意執行器要執行一次?initialize()?方法。

新進 AsyncService 類，內容如下：

public?class?AsyncService?{@Asyncpublic?void?execute()?{System.out.println(Thread.currentThread().getName());} }

新建 AsyncMain 類，內容如下：

public?class?AsyncMain?{public?static?void?main(String[]?args)?{AnnotationConfigApplicationContext?context?=?new?AnnotationConfigApplicationContext(AsyncConfig.class);AsyncService?service?=?context.getBean(AsyncService.class);for?(int?i?=?0;?i?<?10;?i++)?{service.execute();}} }

程序運行結果如下：

ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-2 ThreadPoolTaskExecutor-1 ThreadPoolTaskExecutor-3

從結果中可以看得出，線程池執行器變成了“ThreadPoolTaskExecutor”，并且大小為 3。

計劃任務

“二哥，據說 Spring 可以通過 @Scheduled 來實現計劃任務，你能給我詳細說說怎么實現嗎？”

“沒問題啊。”

新建一個 ScheduledService 類，內容如下：

@Service public?class?ScheduledService?{@Scheduled(fixedDelay?=?1000)public?void?scheduleFixedDelayTask()?{System.out.println("固定時間段后執行任務?-?"?+?System.currentTimeMillis()?/?1000);}@Scheduled(fixedRate?=?1000)public?void?scheduleFixedRateTask()?{System.out.println("固定的頻率執行任務?-?"?+?System.currentTimeMillis()?/?1000);}@Scheduled(cron?=?"0/2?*?*?*?*??")public?void?scheduleTaskUsingCronExpression()?{long?now?=?System.currentTimeMillis()?/?1000;System.out.println("Cron?表達式執行任務?-?"?+?now);} }

@Service?注解用于指定 ScheduledService 類為一個業務層的 Bean。@Scheduled?注解用于指定當前方法（返回類型為 void，無參）為一個任務執行方法，常見的用法有以下 3 種：

1）fixedDelay 用于確保任務執行的完成時間與任務下一次執行的開始時間之間存在 n 毫秒的延遲，下一次任務執行前，上一次任務必須執行完。

2）fixedRate 用于確保每 n 毫秒執行一次計劃任務，即使最后一次調用可能仍在運行。

3）Cron 表達式比 fixedDelay 和 fixedRate 都要靈活，由 7 個部分組成，各部分之間用空格隔開，其完整的格式如下所示：

Seconds?Minutes?Hours?Day-of-Month?Month?Day-of-Week?Year

單詞都很簡單，就不用我翻譯了。其中 Year 是可選項。常見的范例如下所示：

*/5?*?*?*?*????每隔?5?秒執行一次 0?*/1?*?*?*????每隔?1?分鐘執行一次 0?0?23?*?*????每天?23?點執行一次 0?0?1?*?*?? ?每天凌晨 1 點執行一次： 0?0?1?1?*????每月?1?號凌晨?1?點執行一次 0?0?23?L?*????每月最后一天?23?點執行一次 0?0?1???*?L??每周星期天凌晨?1?點執行一次 0?26,29,33?*?*?*????在?26?分、29?分、33?分執行一次 0?0?0,13,18,21?*?*???每天的?0?點、13?點、18?點、21?點各執行一次

新建 ScheduledConfig 類，內容如下：

@Configuration @EnableScheduling @ComponentScan("high.scheduled") public?class?ScheduledConfig?{ }@EnableScheduling?注解用于開啟計劃任務。@ComponentScan?注解用于掃描當前包下的類，如果它使用了注解（比如?@Service），就將其注冊成為一個 Bean。

新建 ScheduledMain 類，內容如下：

public?class?ScheduledMain?{public?static?void?main(String[]?args)?{AnnotationConfigApplicationContext?context?=?new?AnnotationConfigApplicationContext(ScheduledConfig.class);} }

程序運行結果如下：

固定的頻率執行任務?-?1584666273 固定時間段后執行任務?-?1584666273 Cron?表達式執行任務?-?1584666274 固定的頻率執行任務?-?1584666274 固定時間段后執行任務?-?1584666274 固定的頻率執行任務?-?1584666275 固定時間段后執行任務?-?1584666275 Cron?表達式執行任務?-?1584666276

從結果中可以看得出，如果任務之間沒有沖突的話，fixedDelay 任務之間的間隔和 fixedRate 任務之間的間隔是相同的，都是 1 秒；Cron 表達式任務與上一次任務之間的間隔為 2 秒。

“二哥，這篇文章中的示例代碼你上傳到 GitHub 了嗎？”

“你到挺貼心啊，三妹。傳送門~”

https://github.com/qinggee/SpringDemo

“二哥，你教得真不錯，我完全學會了，一點也不枯燥。”

“那必須得啊，就是不知道看這篇文章的他們學會了沒？”

同時，歡迎所有開發者掃描下方二維碼填寫《開發者與AI大調研》，只需2分鐘，便可收獲價值299元的「AI開發者萬人大會」在線直播門票!

推薦閱讀：在容器上構建持續部署及最佳實踐初探在Kubernetes上部署一個簡單的、類PaaS的平臺，原來這么容易！全球呼吸機告急！醫療科技巨頭美敦力“開源”設計圖和源代碼互聯網之父確診新冠，一代傳奇：任谷歌副總裁、NASA 訪問科學家微軟為一人收購一公司？破解索尼程序、寫黑客小說，看他彪悍的程序人生！2020年，這20個大家都認識的加密交易所過得怎么樣？真香，朕在看了！

總結

以上是生活随笔為你收集整理的今天，我要教妹子学会Spring：Aware、异步编程、计划任务的全部內容，希望文章能夠幫你解決所遇到的問題。

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