引言

在編寫測試用例的時候遇到有異步或者隊列處理的時候經(jīng)常會用到 Thread.sleep() 等待來進行測試。例如：DLedger 測試選舉的過程。當(dāng)DLedger Leader下線。此時DLedger會重新發(fā)起選舉，這個選舉的過程是需要一定時間。很多時候在測試代碼中就會使用 Thread.sleep 。

由于選舉需要的時間多少不確定所以sleep時間就會設(shè)置為開發(fā)者經(jīng)驗的最大值。這樣會造成測試代碼會變得很慢。 當(dāng)然開發(fā)者可以通過自己輪詢來實現(xiàn)減少時間的消耗。

下面介紹一個處理這個一類問題的工具：awaitility

1. awaitility入門

Maven：

<dependency>
      <groupId>org.awaitility</groupId>
      <artifactId>awaitility</artifactId>
      <version>xxxx</version>
      <scope>test</scope>
</dependency>

文章編寫的時候版本為：4.2.0

1.1 靜態(tài)導(dǎo)入

為了有效地使用Awaitility，建議從Awaitility框架中靜態(tài)地導(dǎo)入以下方法：

org.awaitility.Awaitility.*

在使用的時候需要搭配Java的時間相關(guān)的類以及Junit相關(guān)類：

java.time.Duration.*

java.util.concurrent.TimeUnit.*

org.junit.Assert.*

1.2 簡單例子

例子1：

await().until(newUserIsAdded());

等待直到執(zhí)行newUserIsAdded()返回true. 這個是沒有返回值的。

例子2：

await().atMost(5, SECONDS).until(newUserWasAdded());

最多等待5秒，等待直到執(zhí)行newUserIsAdded()返回true. 這個是沒有返回值的。

例子3：

await().until( userRepositorySize(), equalTo(1) );

等待直到執(zhí)行userRepositorySize()返回方法對應(yīng)的值. 這個是有返回值

更多的例子可以參照官網(wǎng) 使用例子

2. awaitility在RocketMQ中的實戰(zhàn)

在RocketMQ的test cases 中有一些使用了 Thread.sleep，接下來我們看看如何使用awaitility進行優(yōu)化，減少測試用例的執(zhí)行時間。以ControllerManagerTest測試用例為例子來解決，在代碼中可以看到有這樣的代碼：

上圖框出來的代碼主要的作用是什么呢？等待Broker的Master過期，但是過期的時間我們根據(jù)設(shè)置的心跳的過期時間來預(yù)估時間。所以這里填寫的是6秒當(dāng)然你也可以填寫10秒或者更長。

解決之前的執(zhí)行時間：

使用awaitility對代碼進行改造重構(gòu)：

重構(gòu)后的代碼，如上圖的紅線框出來部分。當(dāng)然我這里還對其他的進行處理。

有興趣的可以關(guān)注一下RocketMQ的這個ISSUE:github.com/apache/rock…

使用awaitility重構(gòu)后的執(zhí)行時間：

時間有明顯的下降。相比之前的下降了5秒左右。

3. 總結(jié)

• 在測試過程中引入awaitility能夠很大程度上方便測試，無需要每次都憑經(jīng)驗去預(yù)估時間。并且很多時候這個Thread.sleep的時間不是很好估算。減少了單元測試執(zhí)行的時間。特別是像RocketMQ這樣大型的項目單元測試很多。并且很多都是去測試分布式的，如果使用Thread.sleep會導(dǎo)致整個單元測試的時間很長。
• 無需自己去實現(xiàn)輪詢來減少單元測試的時間。

以上就是Awaitility同步異步工具實戰(zhàn)示例詳解的詳細內(nèi)容，更多關(guān)于Awaitility同步異步工具實的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論