java調(diào)用回調(diào)機(jī)制詳解
調(diào)用和回調(diào)機(jī)制
在一個(gè)應(yīng)用系統(tǒng)中, 無論使用何種語言開發(fā), 必然存在模塊之間的調(diào)用, 調(diào)用的方式分為幾種:
1.同步調(diào)用
同步調(diào)用是最基本并且最簡單的一種調(diào)用方式, 類A的方法a()調(diào)用類B的方法b(), 一直等待b()方法執(zhí)行完畢, a()方法繼續(xù)往下走. 這種調(diào)用方式適用于方法b()執(zhí)行時(shí)間不長的情況, 因?yàn)閎()方法執(zhí)行時(shí)間一長或者直接阻塞的話, a()方法的余下代碼是無法執(zhí)行下去的, 這樣會(huì)造成整個(gè)流程的阻塞.
2.異步調(diào)用
異步調(diào)用是為了解決同步調(diào)用可能出現(xiàn)阻塞, 導(dǎo)致整個(gè)流程卡住而產(chǎn)生的一種調(diào)用方式. 類A的方法方法a()通過新起線程的方式調(diào)用類B的方法b(), 代碼接著直接往下執(zhí)行, 這樣無論方法b()執(zhí)行時(shí)間多久, 都不會(huì)阻塞住方法a()的執(zhí)行. 但是這種方式, 由于方法a()不等待方法b()的執(zhí)行完成, 在方法a()需要方法b()執(zhí)行結(jié)果的情況下(視具體業(yè)務(wù)而定, 有些業(yè)務(wù)比如啟異步線程發(fā)個(gè)微信通知、刷新一個(gè)緩存這種就沒必要), 必須通過一定的方式對(duì)方法b()的執(zhí)行結(jié)果進(jìn)行監(jiān)聽. 在Java中, 可以使用Future+Callable的方式做到這一點(diǎn), 具體做法可以參見文章Java多線程下的其他組件之CyclicBarrier、Callable、Future和FutureTask詳解
3.回調(diào):
如下圖所示, 回調(diào)是一種雙向的調(diào)用方式, 其實(shí)而言, 回調(diào)也有同步和異步之分, 講解中是同步回調(diào), 第二個(gè)例子使用的是異步回調(diào)
回調(diào)的思想是:
- 類A的a()方法調(diào)用類B的b()方法
- 類B的b()方法執(zhí)行完畢主動(dòng)調(diào)用類A的callback()方法
通俗而言: 就是A類中調(diào)用B類中的某個(gè)方法C, 然后B類中反過來調(diào)用A類中的方法D, D這個(gè)方法就叫回調(diào)方法, 這樣子說你是不是有點(diǎn)暈暈的, 其實(shí)我剛開始也是這樣不理解, 看了人家說比較經(jīng)典的回調(diào)方式:
- class A實(shí)現(xiàn)接口CallBack callback——背景1
- class A中包含一個(gè)class B的引用b ——背景2
- class B有一個(gè)參數(shù)為callback的方法f(CallBack callback) ——背景3
- A的對(duì)象a調(diào)用B的方法 f(CallBack callback) ——A類調(diào)用B類的某個(gè)方法 C
- 然后b就可以在f(CallBack callback)方法中調(diào)用A的方法 ——B類調(diào)用A類的某個(gè)方法D
回調(diào)的種類
回調(diào)分為同步回調(diào)和異步回調(diào), 假如以買彩票的場(chǎng)景來模擬, 我買彩票, 調(diào)用彩票網(wǎng),給我返回的結(jié)果確定是否中獎(jiǎng),同步回調(diào)就是,我買了彩票之后, 需要等待彩票網(wǎng)給我返回的結(jié)果, 這個(gè)時(shí)候我不能做其他事情, 我必須等待這個(gè)結(jié)果, 這就叫同步回調(diào), 同步, 就意味著等待, 我不能去做其他事情, 必須等待, 異步回調(diào)就是, 我買了彩票之后, 可以去做其他事情, 然后當(dāng)彩票網(wǎng)有了結(jié)果和消息, 再給我返回消息, 其中最明顯的方式就是在得到彩票結(jié)果的函數(shù)之中, 添加一個(gè)其他的方法, 如果我的其他方法可以立即執(zhí)行, 那么就是異步的(給出是否中獎(jiǎng)需要花費(fèi)很長的時(shí)間), 而在測(cè)試函數(shù)之中, 前后兩個(gè), 那是發(fā)生在測(cè)試函數(shù)的線程之中的, 肯定是一前一后按照次序的, 在這個(gè)地方不是顯示同步異步的地點(diǎn).
同步回調(diào)
同步回調(diào)和異步回調(diào), 主要體現(xiàn)在其是否需要等待. 同步調(diào)用, 如果被調(diào)用一方的APi(第三方API), 處理問題需要花很長時(shí)間, 我們需要等待, 那就是同步回調(diào), 如果調(diào)用完之后不需要理解得到結(jié)果, 我們調(diào)完就走, 去做其他事情, 那就是異步調(diào)用, 異步調(diào)用需要在我們調(diào)用第三方API處, 開啟一個(gè)新的線程即可, 而同步調(diào)用和平常的調(diào)用沒有任何區(qū)別.
例子
OrderResult接口, 其中的方法getOrderResult
public interface OrderResult { /** * 訂購貨物的狀態(tài) * * @param state * @return */ //參數(shù)可以不用, 用不用按照自己的實(shí)際需求決定 public String getOrderResult(String state); }
Store類, 商店提供會(huì)無預(yù)定消息返回的接口, 回調(diào)OrderResult接口的方法, 給其返回預(yù)訂商品的狀態(tài), 重點(diǎn)是returnOrderGoodsInfo(OrderResult order)方法, 體現(xiàn)了回調(diào)的回. Store是被調(diào)用的一方, 被調(diào)用的一方, 要回過去調(diào)用調(diào)用一方的方法, 這個(gè)方法實(shí)際上是回調(diào)接口的方法.
public class Store { @Getter @Setter private String name; Store(String name) { this.name = name; } /*回調(diào)函數(shù), 將結(jié)構(gòu)傳給那個(gè)我們不能直接調(diào)用的方法, 然后獲取結(jié)果*/ public String returnOrderGoodsInfo(OrderResult order) { String[] s = {"訂購中...", "訂購失敗", "即將發(fā)貨!", "運(yùn)輸途中...", "已在投遞"}; Random random = new Random(); int temp = random.nextInt(5); String s1 = s[temp]; return order.getOrderResult(s1); } }
SyncBuyer類, 同步顧客類, 其中獲取商品的訂購狀態(tài),orderGoods(), 調(diào)用了store返回商品調(diào)用信息的returnOrderGoodsInfo()方法, 但是在Store類的returnOrderGoodsInfo()方法之中, 以O(shè)rderResult接口為參數(shù), 反過來調(diào)用了OrderResult接口, 相當(dāng)于調(diào)用了其子類SyncBuyer本身, 以他為參數(shù), 調(diào)用了getOrderResult(String state)方法, 也就是OrderResult接口的方法, 相當(dāng)于就完成了一個(gè)調(diào)用的循環(huán), 然后取到了我們自己無法給出的結(jié)果.
這個(gè)地方的"循環(huán)", 是回調(diào)的關(guān)鍵所在, 需要正常調(diào)用其他外接提供方法來獲取結(jié)果的一方, 繼承一個(gè)回調(diào)接口, 實(shí)現(xiàn)它, 然后調(diào)用第三方的API方法, 第三方在我們調(diào)用的方法之中, 以回調(diào)結(jié)構(gòu)為參數(shù), 然后調(diào)用了接口中的方法, 其中可以返回相應(yīng)的結(jié)果給我們, 需要說明的是, 我們雖然實(shí)現(xiàn)了這個(gè)接口的方法, 但是我們自己的類之中, 或者說此類本身, 卻沒法調(diào)用這個(gè)方法, 也可以說, 此類調(diào)用這個(gè)方法是不會(huì)產(chǎn)生有效的結(jié)果的. 回調(diào)的回, 就體現(xiàn)在此處, 在Store類之中的returnOrderGoodsInfo(OrderResult order)方法之中, 得到了很好的體現(xiàn).
/*同步, 顧客在商店預(yù)訂商品, 商店通知顧客預(yù)訂情況*/ public class SyncBuyer implements OrderResult { @Getter @Setter private Store store;//商店 @Getter @Setter private String buyerName;//購物者名 @Getter @Setter private String goodsName;//所購商品名 SyncBuyer(Store store, String buyerName, String goodsName) { this.store = store; this.buyerName = buyerName; this.goodsName = goodsName; } /*調(diào)用從商店返回訂購物品的信息*/ public String orderGoods() { String goodsState = store.returnOrderGoodsInfo(this); System.out.println(goodsState); myFeeling();// 測(cè)試同步還是異步, 同步需要等待, 異步無需等待 return goodsState; } public void myFeeling() { String[] s = {"有點(diǎn)小激動(dòng)", "很期待!", "希望是個(gè)好貨!"}; Random random = new Random(); int temp = random.nextInt(3); System.out.println("我是" + this.getBuyerName() + ", 我現(xiàn)在的感覺: " + s[temp]); } /*被回調(diào)的方法, 我們自己不去調(diào)用, 這個(gè)方法給出的結(jié)果, 是其他接口或者程序給我們的, 我們自己無法產(chǎn)生*/ @Override public String getOrderResult(String state) { return "在" + this.getStore().getName() + "商店訂購的" + this.getGoodsName() + "玩具, 目前的預(yù)訂狀態(tài)是: " + state; } }
Test2Callback類, 測(cè)試同步回調(diào)的結(jié)果,
public class Test2Callback { public static void main(String[] args) { Store wallMart = new Store("沙中路沃爾瑪"); SyncBuyer syncBuyer = new SyncBuyer(wallMart, "小明", "超能鐵扇公主"); System.out.println(syncBuyer.orderGoods()); } }
異步回調(diào)
同步回調(diào)和異步回調(diào)的代碼層面的差別就是是否在我們調(diào)用第三方的API處, 為其開辟一條新的線程, 其他并無差異
例子
OrderResult接口, 其中的方法getOrderResult
public interface OrderResult { /** * 訂購貨物的狀態(tài) * * @param state * @return */ //參數(shù)可以不用, 用不用按照自己的實(shí)際需求決定 public String getOrderResult(String state); }
Store類, 商店提供會(huì)無預(yù)定消息返回的接口, 回調(diào)OrderResult接口的方法, 給其返回預(yù)訂商品的狀態(tài).
public class Store { @Getter @Setter private String name; Store(String name) { this.name = name; } /*回調(diào)函數(shù), 將結(jié)構(gòu)傳給那個(gè)我們不能直接調(diào)用的方法, 然后獲取結(jié)果*/ public String returnOrderGoodsInfo(OrderResult order) { String[] s = {"訂購中...", "訂購失敗", "即將發(fā)貨!", "運(yùn)輸途中...", "已在投遞"}; Random random = new Random(); int temp = random.nextInt(5); String s1 = s[temp]; return order.getOrderResult(s1); } }
NoSyncBuyer類, 異步調(diào)用Store類的returnOrderGoodsInfo(OrderResult order)方法, 來返回商品轉(zhuǎn)改的結(jié)果.
/*異步*/ @Slf4j public class NoSyncBuyer implements OrderResult { @Getter @Setter private Store store;//商店 @Getter @Setter private String buyerName;//購物者名 @Getter @Setter private String goodsName;//所購商品名 NoSyncBuyer(Store store, String buyerName, String goodsName) { this.store = store; this.buyerName = buyerName; this.goodsName = goodsName; } /*調(diào)用從商店返回訂購物品的信息*/ public String orderGoods() { String goodsState = "--"; MyRunnable mr = new MyRunnable(); Thread t = new Thread(mr); t.start(); System.out.println(goodsState); goodsState = mr.getResult();// 得到返回值 myFeeling();// 用來測(cè)試異步是不是還是按順序的執(zhí)行 return goodsState; } public void myFeeling() { String[] s = {"有點(diǎn)小激動(dòng)", "很期待!", "希望是個(gè)好貨!"}; Random random = new Random(); int temp = random.nextInt(3); System.out.println("我是" + this.getBuyerName() + ", 我現(xiàn)在的感覺: " + s[temp]); } /*被回調(diào)的方法, 我們自己不去調(diào)用, 這個(gè)方法給出的結(jié)果, 是其他接口或者程序給我們的, 我們自己無法產(chǎn)生*/ @Override public String getOrderResult(String state) { return "在" + this.getStore().getName() + "商店訂購的" + this.getGoodsName() + "玩具, 目前的預(yù)訂狀態(tài)是: " + state; } // 開啟另一個(gè)線程, 但是沒有返回值, 怎么回事 // 調(diào)試的時(shí)候, 等待一會(huì)兒, 還是可以取到值, 但不是立即取到, 在print顯示的時(shí)候, 卻是null, 需要注意? private class MyRunnable implements Runnable { @Getter @Setter private String result; @Override public void run() { try { Thread.sleep(10000); result = store.returnOrderGoodsInfo(NoSyncBuyer.this);// 匿名函數(shù)的時(shí)候, 無法return 返回值 } catch (InterruptedException e) { log.error("出大事了, 異步回調(diào)有問題了", e); } } } }
Test2Callback類, 測(cè)試同步回調(diào)和異步回調(diào)的結(jié)果.
public class Test2Callback { public static void main(String[] args) { Store wallMart = new Store("沙中路沃爾瑪"); SyncBuyer syncBuyer = new SyncBuyer(wallMart, "小明", "超能鐵扇公主"); System.out.println(syncBuyer.orderGoods()); System.out.println("\n"); Store lawson = new Store("沙中路羅森便利店"); NoSyncBuyer noSyncBuyer = new NoSyncBuyer(lawson, "cherry", "變形金剛"); System.out.println(noSyncBuyer.orderGoods()); } }
到此這篇關(guān)于java調(diào)用回調(diào)機(jī)制詳解的文章就介紹到這了,更多相關(guān)java調(diào)用回調(diào)機(jī)制內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- 通過簡易例子講解Java回調(diào)機(jī)制
- Java的回調(diào)機(jī)制實(shí)例詳解
- 深入了解Java接口回調(diào)機(jī)制
- 詳解java 三種調(diào)用機(jī)制(同步、回調(diào)、異步)
- java 回調(diào)機(jī)制的實(shí)例詳解
- java回調(diào)機(jī)制實(shí)例詳解
- Java回調(diào)機(jī)制解讀
- Java 異步回調(diào)機(jī)制實(shí)例分析
- Java 回調(diào)機(jī)制(CallBack) 詳解及實(shí)例代碼
- 詳解Java的回調(diào)機(jī)制
- 兩個(gè)例子了解java中的回調(diào)機(jī)制
相關(guān)文章
Elasticsearch term 查詢之精確值搜索功能實(shí)現(xiàn)
term查詢是Elasticsearch中用于精確值搜索的一種基本方式,通過了解 term 查詢的工作原理和使用方法,你可以更好地利用 Elasticsearch 進(jìn)行結(jié)構(gòu)化數(shù)據(jù)的搜索和分析,本文將詳細(xì)介紹 term 查詢的工作原理、使用場(chǎng)景以及如何在 Elasticsearch 中應(yīng)用它,感興趣的朋友一起看看吧2024-06-06Java 數(shù)據(jù)結(jié)構(gòu)算法Collection接口迭代器示例詳解
這篇文章主要為大家介紹了Java 數(shù)據(jù)結(jié)構(gòu)算法Collection接口迭代器示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-09-09idea中創(chuàng)建maven的Javaweb工程并進(jìn)行配置(圖文教程)
這篇文章主要介紹了idea中創(chuàng)建maven的Javaweb工程并進(jìn)行配置,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),文中給大家提到了tomcat的運(yùn)行方法,具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-02-02Java實(shí)現(xiàn)自定義Excel數(shù)據(jù)排序的方法詳解
通常,我們可以在Excel中對(duì)指定列數(shù)據(jù)執(zhí)行升序或者降序排序,在需要自定義排序情況下,我們也可以自行根據(jù)排序需要編輯數(shù)據(jù)排列順序。本文將通過Java應(yīng)用程序來實(shí)現(xiàn)如何自定義排序,需要的可以參考一下2022-09-09Spring Cache實(shí)現(xiàn)緩存技術(shù)
在面對(duì)公司緩存技術(shù)混亂時(shí),張三基于Spring框架自研緩存解決方案,展現(xiàn)了他的專業(yè)技術(shù)能力和積極工作態(tài)度,他通過問題診斷、技術(shù)選型、編碼測(cè)試、文檔編寫和部署監(jiān)控等一系列步驟,確保了新緩存系統(tǒng)的功能正確性和性能穩(wěn)定性2024-10-10java訪問者模式的靜態(tài)動(dòng)態(tài)及偽動(dòng)態(tài)分派徹底理解
這篇文章主要為大家介紹了java訪問者模式的靜態(tài)動(dòng)態(tài)及偽動(dòng)態(tài)分派徹底理解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-06-06關(guān)于@JsonProperty和@JSONField注解的區(qū)別及用法
這篇文章主要介紹了關(guān)于@JsonProperty和@JSONField注解的區(qū)別及用法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-08-08