天天看點

深入淺出: Java回調機制(異步)一、什麼是回調二、CS中的異步回調(java案例)三、回調的應用場景四、模式對比五、心得

回調,回調。要先有調用,才有調用者和被調用者之間的回調。是以在百度百科中是這樣的:

軟體子產品之間總是存在着一定的接口,從調用方式上,可以把他們分為三類:同步調用、回調和異步調用。

回調是一種特殊的調用,至于三種方式也有點不同。

1、同步回調,即阻塞,單向。

2、回調,即雙向(類似自行車的兩個齒輪)。

3、異步調用,即通過異步消息進行通知。

比如這裡模拟個場景:用戶端發送msg給服務端,服務端處理後(5秒),回調給用戶端,告知處理成功。代碼如下:

回調接口類:

1

2

3

4

5

6

7

8

<code>/**</code>

<code> </code><code>* @author jeff lee</code>

<code> </code><code>* @since 2015-10-21 21:34:21</code>

<code> </code><code>* 回調模式-回調接口類</code>

<code> </code><code>*/</code>

<code>public</code> <code>interface</code> <code>cscallback {</code>

<code>    </code><code>public</code> <code>void</code> <code>process(string status);</code>

<code>}</code>

模拟用戶端:

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

<code> </code><code>* @since 2015-10-21 21:25:14</code>

<code> </code><code>* 回調模式-模拟用戶端類</code>

<code>public</code> <code>class</code> <code>client </code><code>implements</code> <code>cscallback {</code>

<code>    </code><code>private</code> <code>server server;</code>

<code>    </code><code>public</code> <code>client(server server) {</code>

<code>        </code><code>this</code><code>.server = server;</code>

<code>    </code><code>}</code>

<code>    </code><code>public</code> <code>void</code> <code>sendmsg(</code><code>final</code> <code>string msg){</code>

<code>        </code><code>system.out.println(</code><code>"用戶端:發送的消息為:"</code> <code>+ msg);</code>

<code>        </code><code>new</code> <code>thread(</code><code>new</code> <code>runnable() {</code>

<code>            </code><code>@override</code>

<code>            </code><code>public</code> <code>void</code> <code>run() {</code>

<code>                </code><code>server.getclientmsg(client.</code><code>this</code><code>,msg);</code>

<code>            </code><code>}</code>

<code>        </code><code>}).start();</code>

<code>        </code><code>system.out.println(</code><code>"用戶端:異步發送成功"</code><code>);</code>

<code>    </code><code>@override</code>

<code>    </code><code>public</code> <code>void</code> <code>process(string status) {</code>

<code>        </code><code>system.out.println(</code><code>"用戶端:服務端回調狀态為:"</code> <code>+ status);</code>

模拟服務端:

<code> </code><code>* @since 2015-10-21 21:24:15</code>

<code> </code><code>* 回調模式-模拟服務端類</code>

<code>public</code> <code>class</code> <code>server {</code>

<code>    </code><code>public</code> <code>void</code> <code>getclientmsg(cscallback cscallback , string msg) {</code>

<code>        </code><code>system.out.println(</code><code>"服務端:服務端接收到用戶端發送的消息為:"</code> <code>+ msg);</code>

<code>        </code><code>// 模拟服務端需要對資料處理</code>

<code>        </code><code>try</code> <code>{</code>

<code>            </code><code>thread.sleep(</code><code>5</code> <code>* </code><code>1000</code><code>);</code>

<code>        </code><code>} </code><code>catch</code> <code>(interruptedexception e) {</code>

<code>            </code><code>e.printstacktrace();</code>

<code>        </code><code>}</code>

<code>        </code><code>system.out.println(</code><code>"服務端:資料處理成功,傳回成功狀态 200"</code><code>);</code>

<code>        </code><code>string status = </code><code>"200"</code><code>;</code>

<code>        </code><code>cscallback.process(status);</code>

測試類:

<code> </code><code>* 回調模式-測試類</code>

<code>public</code> <code>class</code> <code>callbacktest {</code>

<code>    </code><code>public</code> <code>static</code> <code>void</code> <code>main(string[] args) {</code>

<code>        </code><code>server server = </code><code>new</code> <code>server();</code>

<code>        </code><code>client client = </code><code>new</code> <code>client(server);</code>

<code>        </code><code>client.sendmsg(</code><code>"server,hello~"</code><code>);</code>

運作下測試類 — 列印結果如下:

用戶端:發送的消息為:server,hello~ 用戶端:異步發送成功 服務端:服務端接收到用戶端發送的消息為:server,hello~ (這裡模拟服務端對資料處理時間,等待5秒) 服務端:資料處理成功,傳回成功狀态 200 用戶端:服務端回調狀态為:200

一步一步分析下代碼,核心總結如下

1、接口作為方法參數,其實際傳入引用指向的是實作類 2、client的sendmsg方法中,參數為final,因為要被内部類一個新的線程可以使用。這裡就展現了異步。 3、調用server的getclientmsg(),參數傳入了client本身(對應第一點)。

還有值得一提的是(逃

回調目前運用在什麼場景比較多呢?從作業系統到開發者調用:

1、windows平台的消息機制 2、異步調用微信接口,根據微信傳回狀态對出業務邏輯響應。 3、servlet中的filter(過濾器)是基于回調函數,需容器支援。

補充:其中 filter(過濾器)和interceptor(攔截器)的差別,攔截器基于是java的反射機制,和容器無關。但與回調機制有異曲同工之妙。

總之,這設計讓底層代碼調用高層定義(實作層)的子程式,增強了程式的靈活性。

上面講了filter和intercepter有着異曲同工之妙。其實接口回調機制和一種設計模式—觀察者模式也有相似之處:

觀察者模式:

gof說道 — “定義對象的一種一對多的依賴關系,當一個對象的狀态發送改變的時候,所有對他依賴的對象都被通知到并更新。”它是一種模式,是通過接口回調的方法實作的,即它是一種回調的展現。

接口回調:

與觀察者模式的差別是,它是種原理,而非具體實作。

總結四步走:

機制,即是原理。 模式,即是展現。 記住具體場景,常見模式。 然後深入了解原理。