整個(gè) Netty 的 API 都是異步的,異步處理不是一個(gè)新的機(jī)制,這個(gè)機(jī)制出來(lái)已經(jīng)有一些時(shí)間了碌燕。對(duì)網(wǎng)絡(luò)應(yīng)用來(lái)說(shuō),IO 一般是性能的瓶頸,使用異步 IO 可以較大程度上??高程序性能,因?yàn)楫惒阶兊脑絹?lái)越重要。但是它是如何工作的呢?以及有哪些不同的模式可用呢?
異步處理??倡更有效的使用資源,它允許你創(chuàng)建一個(gè)任務(wù),當(dāng)有事件發(fā)生時(shí)將獲得通知并等待事件完成。這樣就不會(huì)阻塞,不管事件完成與否都會(huì)及時(shí)返回,資源利用率更高,程序可以利用剩余的資源做一些其他的事情鞋囊。
本節(jié)將說(shuō)明一起工作或?qū)崿F(xiàn)異步 API 的兩個(gè)最常用的方法,并討論這些技術(shù)之間的差異
一夕晓、Callback(回調(diào))
回調(diào)是異步處理的一種技術(shù)藤肢。一個(gè)回調(diào)是被傳遞到并且執(zhí)行完該方法骇陈。
下面代碼是一個(gè)簡(jiǎn)單的回調(diào)：
public class Worker {
public void doWork() {
Fetcher fetcher = new MyFetcher(new Data(1, 0));
fetcher.fetchData(new FetcherCallback() {
@Override
public void onData(Data data) throws Exception {
System.out.println("Data received : " + data);
}
@Override
public void onError(Throwable cause) {
System.out.println("An err occured : " + cause.getMessage()); }
});
}
public static void main(String[] args) {
Worker w = new Worker();
w.doWork();
}
}
public interface Fetcher {
void fetchData(FetcherCallback callback);
}
public class MyFetcher implements Fetcher {
final Data data;
public MyFetcher(Data data) {
this.data = data;
}
@Override
public void fetchData(FetcherCallback callback) {
try {
callback.onData(data);
} catch (Exception e) {
callback.onError(e);
}
}
}
public interface FetcherCallback {
void onData(Data data) throws Exception;
void onError(Throwable cause);
}
public class Data {
private int m;
private int n;
public Data(int m, int n) {
this.m = m;
this.n = n;
}
@Override
public String toString() {
int r = n / m;
return n + "/" + m + " = " + r;
}
}
上面的例子只是一個(gè)簡(jiǎn)單的模擬回調(diào),要明白其所表達(dá)的含義托慨。Fetcher.fetchData()方法需傳遞一個(gè)FetcherCallback 類型的參數(shù),當(dāng)獲得數(shù)據(jù)或發(fā)生錯(cuò)誤時(shí)被回調(diào)葵孤。對(duì)于每種情況都??供了同意的方法:
FetcherCallback.onData(),將接收數(shù)據(jù)時(shí)被調(diào)用
FetcherCallback.onError(),發(fā)生錯(cuò)誤時(shí)被調(diào)用
因?yàn)榭梢詫⑦@些方法的執(zhí)行從"caller"線程移動(dòng)到其他的線程執(zhí)行;但也不會(huì)保證 FetcherCallback 的每個(gè)方法都會(huì)被執(zhí)行担钮。回調(diào)過(guò)程有個(gè)問(wèn)題就是當(dāng)你使用鏈?zhǔn)秸{(diào)用很多不同的方法會(huì)導(dǎo)致線性代碼;有些人認(rèn)為這種鏈?zhǔn)秸{(diào)用方法會(huì)導(dǎo)致代碼難以閱讀,但是我認(rèn)為這是一種風(fēng)格和習(xí)慣問(wèn)題尤仍。例如,基于 Javascript 的 Node.js 越來(lái)越受歡迎,它使用了大量的回調(diào),許多人都認(rèn)為它的這種方式利于閱讀和編寫(xiě)箫津。
二、Futures
第二種技術(shù)是使用 Futures宰啦。Futures 是一個(gè)抽象的概念,它表示一個(gè)值,該值可能在某一點(diǎn)變得可用苏遥。一個(gè) Future 要么獲得計(jì)算完的結(jié)果,要么獲得計(jì)算失敗后的異常。Java 在 java.util.concurrent 包中附帶了 Future 接口,它使用 Executor 異步執(zhí)行赡模。例如下面的代碼,每傳遞一個(gè) Runnable 對(duì)象到 ExecutorService.submit()方法就會(huì)得到一個(gè)回調(diào)的 Future,你能使用它檢測(cè)是否執(zhí)行完成田炭。
public class FutureExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newCachedThreadPool();
Runnable task1 = new Runnable() {
@Override
public void run() {
// do something
System.out.println("i am task1...");
}
};
Callable<Integer> task2 = new Callable<Integer>() {
@Override
public Integer call() throws Exception {
// do something
return new Integer(100);
}
};
Future<?> f1 = executor.submit(task1);
Future<Integer> f2 = executor.submit(task2);
System.out.println("task1 is done ? " + f1.isDone());
System.out.println("task2 is done ? " + f2.isDone());
// waiting task1 done
while (f1.isDone()) {
System.out.println("task1 done");
break;
}
// waiting task2 done
while (f2.isDone()) {
System.out.println("task2 done");
break;
}
}
}
有時(shí)候使用 Future 感覺(jué)很丑陋,因?yàn)槟阈枰g隔檢查 Future 是否已完成,而使用回調(diào)會(huì)直接收到返回通知±旄蹋看完這兩個(gè)常用的異步執(zhí)行技術(shù)后,你可能想知道使用哪個(gè)最好?這里沒(méi)有明確的答案教硫。事實(shí)上,Netty 兩者都使用,??供兩全其美的方案叨吮。
