建站
咨詢
售后
建站咨詢
新聞中心
本文轉(zhuǎn)載自微信公眾號「程序新視界」，作者二師兄。轉(zhuǎn)載本文請聯(lián)系程序新視界公眾號。
前言
先讓我們通過一個生活中的場景來還原一下回調(diào)的場景：你遇到了一個技術(shù)難題(比如，1+1等于幾?太難了!)，于是你去咨詢大牛，大牛說現(xiàn)在正在忙，待會兒告訴你結(jié)果。
此時，你可能會去刷朋友圈了，等大牛忙完之后，告訴你答案是2。
那么，這個過程中詢問問題(調(diào)用對方接口)，然后問題解決之后再告訴你(對方處理完再調(diào)用你，通知結(jié)果)，這一過程便是回調(diào)。
系統(tǒng)調(diào)用的分類
應(yīng)用系統(tǒng)模塊之間的調(diào)用，通常分為：同步調(diào)用，異步調(diào)用，回調(diào)。
同步調(diào)用
同步調(diào)用是最基本的調(diào)用方式。類A的a()方法調(diào)用類B的b()方法，類A的方法需要等到B類的方法執(zhí)行完成才會繼續(xù)執(zhí)行。如果B的方法長時間阻塞，就會導(dǎo)致A類方法無法正常執(zhí)行下去。
異步調(diào)用
如果A調(diào)用B，B的執(zhí)行時間比較長，那么就需要考慮進行異步處理，使得B的執(zhí)行不影響A。通常在A中新起一個線程用來調(diào)用B，然后A中的代碼繼續(xù)執(zhí)行。
異步通常分兩種情況：第一，不需要調(diào)用結(jié)果，直接調(diào)用即可，比如發(fā)送消息通知;第二，需要異步調(diào)用結(jié)果，在Java中可使用Future+Callable實現(xiàn)。
回調(diào)
通過上圖我們可以看到回到屬于一種雙向的調(diào)用方式?；卣{(diào)的基本上思路是：A調(diào)用B，B處理完之后再調(diào)用A提供的回調(diào)方法(通常為callbakc())通知結(jié)果。
通常回調(diào)分為：同步回調(diào)和異步回調(diào)。網(wǎng)絡(luò)上大多數(shù)的回調(diào)案例都是同步回調(diào)。
其中同步回調(diào)與同步調(diào)用類似，代碼運行到某一個位置的時候，如果遇到了需要回調(diào)的代碼，會在這里等待，等待回調(diào)結(jié)果返回后再繼續(xù)執(zhí)行。
而異步回調(diào)與異步調(diào)用類似，代碼執(zhí)行到需要回調(diào)的代碼的時候，并不會停下來，而是繼續(xù)執(zhí)行，當然可能過一會回調(diào)的結(jié)果會返回回來。
同步回調(diào)實例
下面我們以同步回調(diào)為例來講解回調(diào)的Java代碼實現(xiàn)。整個過程就模擬上面問答問題的場景。
首先，定義給一個CallBack的接口，將回調(diào)的功能進行單獨抽離：
- public interface CallBack {
- void callback(String string);
- }
CallBack接口中提供了一個callback方法，用于回調(diào)時調(diào)用。
然后定義問問題的人Person：
- public class Person implements CallBack {
- private Genius genius;
- public Person(Genius genius) {
- this.genius = genius;
- }
- @Override
- public void callback(String string) {
- System.out.println("收到答案：" + string);
- }
- public void ask() {
- genius.answer(this);
- }
- }
由于Person要提供回調(diào)方法，因此實現(xiàn)CallBack接口及其方法，方法中主要針對回調(diào)結(jié)果進行處理。
同時，由于Person要調(diào)用Genius對應(yīng)的方法，因此要持有Genius的引用，這里通過構(gòu)造方法傳入。
定義回答問題的大神Genius類：
- public class Genius {
- public void answer(CallBack callBack) {
- System.out.println("在忙其他事...");
- try {
- Thread.sleep(2000);
- System.out.println("忙完其他事，開始計算...");
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- System.out.println("天才計算出答案為：2");
- // 回調(diào)告訴你
- callBack.callback("2");
- }
- }
這模擬大神正在忙碌，線程睡眠2秒，忙碌完之后，開始幫忙計算答案，獲得答案之后，調(diào)用CallBack接口的callback方法進行回調(diào)，通知結(jié)果。
通過Main方法進行測試：
- public static void main(String[] args) {
- Genius genius = new Genius();
- Person you = new Person(genius);
- you.ask();
- }
執(zhí)行打印結(jié)果如下：
- 在忙其他事...
- 忙完其他事，開始計算...
- 天才計算出答案為：2
- 收到答案：2
上面的過程，就實現(xiàn)了一個同步回調(diào)的功能。當然，從程序設(shè)計上來說，可以對Person和Genius進一步抽象化處理，通過接口的形式呈現(xiàn)。
在上述回調(diào)機制的代碼實現(xiàn)中，最核心的是在調(diào)用answer方法時傳遞了this參數(shù)，即調(diào)用者自身。
從本質(zhì)上來說，回調(diào)是一種思想，是一種機制，至于具體如何實現(xiàn)，如何通過代碼將回調(diào)實現(xiàn)得優(yōu)雅、實現(xiàn)得可擴展性比較高，就需要八仙過海各顯神通了。
異步回調(diào)實例
上面的實例演示了同步回調(diào)，很明顯在調(diào)用的過受到Genius執(zhí)行時長的影響，需要等到Genius處理完才能繼續(xù)執(zhí)行Person方法中的后續(xù)代碼。
下面在上述示例上進行改進，Person提供一個支持異步回調(diào)的方法：
- public void askASyn() {
- System.out.println("創(chuàng)建新線程請教問題");
- new Thread(() -> genius.answer(this)).start();
- System.out.println("新線程已啟動...");
- }
在該方法內(nèi)，新建了一個線程用來處理Genius#answer方法的調(diào)用，這樣就能夠跳過Genius#answer方法的阻塞，直接執(zhí)行下面的操作(日志打印)。
在main方法中將調(diào)用的方法改為askASyn，打印結(jié)果如下：
- 創(chuàng)建新線程請教問題
- 新線程已啟動...
- 在忙其他事...
- 忙完其他事，開始計算...
- 天才計算出答案為：2
- 收到答案：2
可以看出，直接打印了“新線程已啟動...”，后續(xù)才打印出Genius#answer方法方法中處理日志和回調(diào)時callback方法接收到的信息。
基于Future的半異步
除了上述的同步，異步處理，還有一種介于同步和異步之間的基于Future的半異步處理。
在Java使用nio后無法立即拿到真實的數(shù)據(jù)，而是先得到一個"future"，可以理解為郵戳或快遞單，為了獲悉真正的數(shù)據(jù)我們需要不停的通過快遞單號"future"查詢快遞是否真正寄到。
Futures是一個抽象的概念，它表示一個值，在某一點會變得可用。一個Future要么獲得計算完的結(jié)果，要么獲得計算失敗后的異常。
通常什么時候會用到Future呢?一般來說，當執(zhí)行一個耗時的任務(wù)時，使用Future就可以讓線程暫時去處理其他的任務(wù)，等長任務(wù)執(zhí)行完畢再返回其結(jié)果。
經(jīng)常會使用到Future的場景有：1. 計算密集場景。2. 處理大數(shù)據(jù)量。3. 遠程方法調(diào)用等。
Java在java.util.concurrent包中附帶了Future接口，它使用Executor異步執(zhí)行。
例如下面的代碼，每傳遞一個Runnable對象到ExecutorService.submit()方法就會得到一個回調(diào)的Future，使用它檢測是否執(zhí)行，這種方法可以是同步等待線處理結(jié)果完成。
- public class TestFuture {
- public static void main(String[] args) {
- //實現(xiàn)一個Callable接口
- Callable
c = () -> { - //這里是業(yè)務(wù)邏輯處理
- //讓當前線程阻塞1秒看下效果
- Thread.sleep(1000);
- return new User("張三");
- };
- ExecutorService es = Executors.newFixedThreadPool(2);
- // 記得要用submit，執(zhí)行Callable對象
- Future
fn = es.submit(c); - // 一定要調(diào)用這個方法，不然executorService.isTerminated()永遠不為true
- es.shutdown();
- // 無限循環(huán)等待任務(wù)處理完畢 如果已經(jīng)處理完畢 isDone返回true
- while (!fn.isDone()) {
- try {
- //處理完畢后返回的結(jié)果
- User nt = fn.get();
- System.out.println(nt.name);
- } catch (InterruptedException | ExecutionException e) {
- e.printStackTrace();
- }
- }
- }
- static class User {
- private String name;
- private User(String name) {
- this.name = name;
- }
- }
- }
此種情況下雖然是創(chuàng)建了新線程來進行處理，但還是需要等待處理的結(jié)果。好處是可以將批量的處理，分為幾個線程同時進行處理，最后對結(jié)果進行合并，達到提升處理效率的目的。
小結(jié)
經(jīng)過這篇文章，想必大家對Java的回調(diào)機制已經(jīng)有所了解，在各類開源框架中，其實也會經(jīng)?？吹交卣{(diào)的使用，活學(xué)活用。
網(wǎng)站名稱：兩個經(jīng)典例子讓你徹底理解Java回調(diào)機制
文章分享：http://www.5511xx.com/article/cooehdo.html
