Java 異步回調(diào)機(jī)制

一、什么是回調(diào)

回調(diào)，回調(diào)。要先有調(diào)用，才有調(diào)用者和被調(diào)用者之間的回調(diào)。所以在百度百科中是這樣的：

軟件模塊之間總是存在著一定的接口，從調(diào)用方式上，可以把他們分為三類(lèi)：同步調(diào)用、回調(diào)和異步調(diào)用。

回調(diào)是一種特殊的調(diào)用，至于三種方式也有點(diǎn)不同。

1、同步回調(diào)，即阻塞，單向。

2、回調(diào)，即雙向（類(lèi)似自行車(chē)的兩個(gè)齒輪）。

3、異步調(diào)用，即通過(guò)異步消息進(jìn)行通知。

二、CS中的異步回調(diào)（Java案例）

比如這里模擬個(gè)場(chǎng)景：客戶(hù)端發(fā)送msg給服務(wù)端，服務(wù)端處理后（5秒），回調(diào)給客戶(hù)端，告知處理成功。代碼如下：

回調(diào)接口類(lèi)：

/**
 * @author Jeff Lee
 * @since 2015-10-21 21:34:21
 * 回調(diào)模式-回調(diào)接口類(lèi)
 */
public interface CSCallBack {
  public void process(String status);
}

模擬客戶(hù)端：

/**
 * @author Jeff Lee
 * @since 2015-10-21 21:25:14
 * 回調(diào)模式-模擬客戶(hù)端類(lèi)
 */
public class Client implements CSCallBack {

  private Server server;

  public Client(Server server) {
    this.server = server;
  }

  public void sendMsg(final String msg){
    System.out.println("客戶(hù)端：發(fā)送的消息為：" + msg);
    new Thread(new Runnable() {
      @Override
      public void run() {
        server.getClientMsg(Client.this,msg);
      }
    }).start();
    System.out.println("客戶(hù)端：異步發(fā)送成功");
  }

  @Override
  public void process(String status) {
    System.out.println("客戶(hù)端：服務(wù)端回調(diào)狀態(tài)為：" + status);
  }
}

模擬服務(wù)端:

/**
 * @author Jeff Lee
 * @since 2015-10-21 21:24:15
 * 回調(diào)模式-模擬服務(wù)端類(lèi)
 */
public class Server {

  public void getClientMsg(CSCallBack csCallBack , String msg) {
    System.out.println("服務(wù)端：服務(wù)端接收到客戶(hù)端發(fā)送的消息為:" + msg);

    // 模擬服務(wù)端需要對(duì)數(shù)據(jù)處理
    try {
      Thread.sleep(5 * 1000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    System.out.println("服務(wù)端:數(shù)據(jù)處理成功，返回成功狀態(tài) 200");
    String status = "200";
    csCallBack.process(status);
  }
}

測(cè)試類(lèi)：

/**
 * @author Jeff Lee
 * @since 2015-10-21 21:24:15
 * 回調(diào)模式-測(cè)試類(lèi)
 */
public class CallBackTest {
  public static void main(String[] args) {
    Server server = new Server();
    Client client = new Client(server);

    client.sendMsg("Server,Hello~");
  }
}

運(yùn)行下測(cè)試類(lèi) — 打印結(jié)果如下：

客戶(hù)端：發(fā)送的消息為：Server,Hello~
客戶(hù)端：異步發(fā)送成功
服務(wù)端：服務(wù)端接收到客戶(hù)端發(fā)送的消息為:Server,Hello~
（這里模擬服務(wù)端對(duì)數(shù)據(jù)處理時(shí)間，等待5秒）
服務(wù)端：數(shù)據(jù)處理成功，返回成功狀態(tài) 200
客戶(hù)端：服務(wù)端回調(diào)狀態(tài)為：200

一步一步分析下代碼，核心總結(jié)如下

1、接口作為方法參數(shù)，其實(shí)際傳入引用指向的是實(shí)現(xiàn)類(lèi)
2、Client的sendMsg方法中，參數(shù)為final，因?yàn)橐粌?nèi)部類(lèi)一個(gè)新的線(xiàn)程可以使用。這里就體現(xiàn)了異步。
3、調(diào)用server的getClientMsg()，參數(shù)傳入了Client本身（對(duì)應(yīng)第一點(diǎn)）。

三、回調(diào)的應(yīng)用場(chǎng)景

回調(diào)目前運(yùn)用在什么場(chǎng)景比較多呢？從操作系統(tǒng)到開(kāi)發(fā)者調(diào)用：

1、Windows平臺(tái)的消息機(jī)制
2、異步調(diào)用微信接口，根據(jù)微信返回狀態(tài)對(duì)出業(yè)務(wù)邏輯響應(yīng)。
3、Servlet中的Filter(過(guò)濾器)是基于回調(diào)函數(shù)，需容器支持。

補(bǔ)充：其中 Filter(過(guò)濾器)和Interceptor(攔截器)的區(qū)別，攔截器基于是Java的反射機(jī)制，和容器無(wú)關(guān)。但與回調(diào)機(jī)制有異曲同工之妙。

總之，這設(shè)計(jì)讓底層代碼調(diào)用高層定義（實(shí)現(xiàn)層）的子程序，增強(qiáng)了程序的靈活性。

四、模式對(duì)比

上面講了Filter和Intercepter有著異曲同工之妙。其實(shí)接口回調(diào)機(jī)制和一種設(shè)計(jì)模式—觀察者模式也有相似之處：

觀察者模式：

GOF說(shuō)道 — “定義對(duì)象的一種一對(duì)多的依賴(lài)關(guān)系，當(dāng)一個(gè)對(duì)象的狀態(tài)發(fā)送改變的時(shí)候，所有對(duì)他依賴(lài)的對(duì)象都被通知到并更新?！彼且环N模式，是通過(guò)接口回調(diào)的方法實(shí)現(xiàn)的，即它是一種回調(diào)的體現(xiàn)。

接口回調(diào)：

與觀察者模式的區(qū)別是，它是種原理，而非具體實(shí)現(xiàn)。

五、心得

總結(jié)四步走：

機(jī)制，即是原理。
模式，即是體現(xiàn)。
記住具體場(chǎng)景，常見(jiàn)模式。
然后深入理解原理。

感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！