Java 異步回調(diào)機(jī)制實(shí)例解析
什么是回調(diào)?今天傻傻地截了張圖問了下,然后被陳大?;卮鸬?ldquo;就一個(gè)回調(diào)…”。此時(shí)千萬個(gè)草泥馬飛奔而過
哈哈,看著源碼,享受著這種回調(diào)在代碼上的作用,真是美哉。不妨總結(jié)總結(jié)。
一、什么是回調(diào)
回調(diào),回調(diào)。要先有調(diào)用,才有調(diào)用者和被調(diào)用者之間的回調(diào)。所以在百度百科中是這樣的:
軟件模塊之間總是存在著一定的接口,從調(diào)用方式上,可以把他們分為三類:同步調(diào)用、回調(diào)和異步調(diào)用。
回調(diào)是一種特殊的調(diào)用,至于三種方式也有點(diǎn)不同。
1、同步回調(diào),即阻塞,單向。
2、回調(diào),即雙向(類似自行車的兩個(gè)齒輪)。
3、異步調(diào)用,即通過異步消息進(jìn)行通知。
二、CS中的異步回調(diào)(java案例)
比如這里模擬個(gè)場(chǎng)景:客戶端發(fā)送msg給服務(wù)端,服務(wù)端處理后(5秒),回調(diào)給客戶端,告知處理成功。代碼如下:
回調(diào)接口類:
- /**
- * @author Jeff Lee
- * @since 2015-10-21 21:34:21
- * 回調(diào)模式-回調(diào)接口類
- */
- public interface CSCallBack {
- public void process(String status);
- }
模擬客戶端:
- /**
- * @author Jeff Lee
- * @since 2015-10-21 21:25:14
- * 回調(diào)模式-模擬客戶端類
- */
- public class Client implements CSCallBack {
- private Server server;
- public Client(Server server) {
- this.server = server;
- }
- public void sendMsg(final String msg){
- System.out.println("客戶端:發(fā)送的消息為:" + msg);
- new Thread(new Runnable() {
- @Override
- public void run() {
- server.getClientMsg(Client.this,msg);
- }
- }).start();
- System.out.println("客戶端:異步發(fā)送成功");
- }
- @Override
- public void process(String status) {
- System.out.println("客戶端:服務(wù)端回調(diào)狀態(tài)為:" + status);
- }
- }
模擬服務(wù)端:
- /**
- * @author Jeff Lee
- * @since 2015-10-21 21:24:15
- * 回調(diào)模式-模擬服務(wù)端類
- */
- public class Server {
- public void getClientMsg(CSCallBack csCallBack , String msg) {
- System.out.println("服務(wù)端:服務(wù)端接收到客戶端發(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è)試類:
- /**
- * @author Jeff Lee
- * @since 2015-10-21 21:24:15
- * 回調(diào)模式-測(cè)試類
- */
- 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è)試類 — 打印結(jié)果如下:
客戶端:發(fā)送的消息為:Server,Hello~
客戶端:異步發(fā)送成功
服務(wù)端:服務(wù)端接收到客戶端發(fā)送的消息為:Server,Hello~(這里模擬服務(wù)端對(duì)數(shù)據(jù)處理時(shí)間,等待5秒)
服務(wù)端:數(shù)據(jù)處理成功,返回成功狀態(tài) 200
客戶端:服務(wù)端回調(diào)狀態(tài)為:200
一步一步分析下代碼,核心總結(jié)如下
1、接口作為方法參數(shù),其實(shí)際傳入引用指向的是實(shí)現(xiàn)類
2、Client的sendMsg方法中,參數(shù)為final,因?yàn)橐粌?nèi)部類一個(gè)新的線程可以使用。這里就體現(xiàn)了異步。
3、調(diào)用server的getClientMsg(),參數(shù)傳入了Client本身(對(duì)應(yīng)第一點(diǎn))。
還有值得一提的是
— 開源代碼都在我的gitHub上哦~
三、回調(diào)的應(yīng)用場(chǎng)景
回調(diào)目前運(yùn)用在什么場(chǎng)景比較多呢?從操作系統(tǒng)到開發(fā)者調(diào)用:
1、Windows平臺(tái)的消息機(jī)制
2、異步調(diào)用微信接口,根據(jù)微信返回狀態(tài)對(duì)出業(yè)務(wù)邏輯響應(yīng)。
3、Servlet中的Filter(過濾器)是基于回調(diào)函數(shù),需容器支持。
補(bǔ)充:其中 Filter(過濾器)和Interceptor(攔截器)的區(qū)別,攔截器基于是Java的反射機(jī)制,和容器無關(guān)。但與回調(diào)機(jī)制有異曲同工之妙。
總之,這設(shè)計(jì)讓底層代碼調(diào)用高層定義(實(shí)現(xiàn)層)的子程序,增強(qiáng)了程序的靈活性。
四、模式對(duì)比
上面講了Filter和Intercepter有著異曲同工之妙。其實(shí)接口回調(diào)機(jī)制和一種設(shè)計(jì)模式—觀察者模式也有相似之處:
觀察者模式:
GOF說道 — “定義對(duì)象的一種一對(duì)多的依賴關(guān)系,當(dāng)一個(gè)對(duì)象的狀態(tài)發(fā)送改變的時(shí)候,所有對(duì)他依賴的對(duì)象都被通知到并更新。”它是一種模式,是通過接口回調(diào)的方法實(shí)現(xiàn)的,即它是一種回調(diào)的體現(xiàn)。
接口回調(diào):
與觀察者模式的區(qū)別是,它是種原理,而非具體實(shí)現(xiàn)。
五、心得
總結(jié)四步走:
機(jī)制,即是原理。
模式,即是體現(xiàn)。
記住具體場(chǎng)景,常見模式。
然后深入理解原理。