前言
最近公司在重構(gòu)廣告系統(tǒng)，其中核心的打包功由廣告系統(tǒng)調(diào)用，即對(duì)apk打包的調(diào)用和打包完成之后的回調(diào)，需要提供相應(yīng)的接口給廣告系統(tǒng)。因此，為了將apk打包的核心流程和對(duì)接廣告系統(tǒng)的業(yè)務(wù)解耦，利用了spring的事件監(jiān)聽特性來滿足需求。以下說明spring的事件機(jī)制的相關(guān)內(nèi)容。
首先spring事件分為事件發(fā)布者(eventpublisher)、事件監(jiān)聽者(eventlistener),還包括一個(gè)事件廣播者(這個(gè)是spring實(shí)現(xiàn)相關(guān)，這一節(jié)不討論)。使用spring事件機(jī)制，需要自定義事件發(fā)布者和監(jiān)聽者。
1.觀察者模式
spring的事件監(jiān)聽（也稱事件驅(qū)動(dòng)）是觀察者模式的一種實(shí)現(xiàn)，比較常見的有發(fā)布-訂閱模型。通常我們利用消息隊(duì)列來實(shí)現(xiàn)不同系統(tǒng)之間的解耦，如用戶注冊(cè)完成后，可以向消息隊(duì)列發(fā)布一條消息，然后訂閱了此topic的子系統(tǒng)（如郵件服務(wù)，積分服務(wù)）收到發(fā)布的消息之后，就會(huì)做相應(yīng)的處理。這樣做的好處是避免了在注冊(cè)服務(wù)里耦合其他服務(wù)的代碼，并且，執(zhí)行子系統(tǒng)的業(yè)務(wù)將會(huì)異步執(zhí)行，互不影響。下圖是一個(gè)經(jīng)典的觀察者模式的結(jié)構(gòu)。
以下為上述觀察者模式的java簡(jiǎn)單實(shí)現(xiàn)：
（1）subject.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
package observerpattern;import java.util.arraylist;import java.util.list;/** * created by jy on 2018/11/28. */public abstract class subject { //維護(hù)一個(gè)所有觀察者集合 private list<observer> list = new arraylist<>(); //新注冊(cè)一個(gè)觀察者 public void attach(observer observer){ list.add(observer); system.out.println("新注冊(cè)一個(gè)觀察者"); } //刪除一個(gè)已注冊(cè)的觀察者 public void detach(observer observer){ list.remove(observer); system.out.println("刪除一個(gè)已注冊(cè)的觀察者"); } //通知所有已經(jīng)注冊(cè)的觀察者 public void notifyobservers(string state){ for (int i = 0; i < list.size(); i++) { list.get(i).update(state); } }} |
(2)observer.java
|
1
2
3
4
5
6
7
8
9
10
|
package observerpattern;/** * created by jy on 2018/11/28. */public interface observer { // 抽象出的更新行為 public void update(string state);} |
(3)concretesubject.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
package observerpattern;/** * created by jy on 2018/11/28. */public class concretesubject extends subject{ //真實(shí)主題內(nèi)維護(hù)一個(gè)狀態(tài) private string state; public string getstate() { return state; } public void change(string state){ this.state = state; system.out.println("真實(shí)主題狀態(tài)變化為:"+state); this.notifyobservers(state); }} |
(4)concreteobserver.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
package observerpattern;/** * created by jy on 2018/11/28. */public class concreteobserver implements observer { //具體觀察者的狀態(tài) private string observerstate; @override public void update(string state) { //這里可以根據(jù)傳遞過來的主題的狀態(tài)作出相應(yīng)的業(yè)務(wù) observerstate = state; system.out.println("觀察者的狀態(tài)跟著變化為："+observerstate); }} |
(5)main.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
package observerpattern;/** * created by jy on 2018/11/28. */public class main { public static void main(string[] args) { //真實(shí)主題 concretesubject concretesubject = new concretesubject(); //真實(shí)觀察者 concreteobserver concreteobserver = new concreteobserver(); //觀察者先注冊(cè) concretesubject.attach(concreteobserver); //改變真實(shí)主題狀態(tài) concretesubject.change("2"); }} |
結(jié)果：在執(zhí)行了main方法之后，我們可以看到控制臺(tái)輸出結(jié)果，表明，真實(shí)觀察者的狀態(tài)是會(huì)根據(jù)真實(shí)主題的狀態(tài)變化而變化的：
2. spring事件監(jiān)聽
spring也對(duì)事件驅(qū)動(dòng)模型提供了支持，該模型主要由三部分組成：
（1） 事件（applicationevent）：繼承了jdk的eventobject，在spring項(xiàng)目中可以繼承applicationevent，來自定義自己的事件。
spring容器內(nèi)部對(duì)applicationevent有著下面幾個(gè)實(shí)現(xiàn)，通過名字可以很清楚事件所描述的行為。
（2）發(fā)布者（applicationeventpublisher）：實(shí)現(xiàn)這個(gè)接口，就可以使得spring組件有發(fā)布事件的能力。
可以看到，applicationcontext實(shí)現(xiàn)了此接口，因此，可以spring組件可以通過實(shí)現(xiàn)applicationcontextaware接口，注入applicationcontext，然后，通過applicationcontext的publishevent()方法來實(shí)現(xiàn)事件傳播，
當(dāng)然，也可以直接實(shí)現(xiàn)applicationeventpublisher接口，重寫publishevent()方法，同樣可以實(shí)現(xiàn)事件傳播。
通過閱讀源碼發(fā)現(xiàn)，在abstractapplicationcontext類中，定義了針對(duì)觀察者的增加，get，注冊(cè)等方法。下面代碼中的addapplicationlistener()是向applicationeventmulticaster類中維護(hù)的一個(gè)set中添加listener。這個(gè)set存儲(chǔ)了該發(fā)布者所有的觀察者（listener）。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
@override public void addapplicationlistener(applicationlistener<?> listener) { assert.notnull(listener, "applicationlistener must not be null"); //listener傳入持有的一個(gè)的applicationeventmulticaster類中 if (this.applicationeventmulticaster != null) { this.applicationeventmulticaster.addapplicationlistener(listener); } this.applicationlisteners.add(listener); }//省略部分代碼protected void registerlisteners() { // register statically specified listeners first. for (applicationlistener<?> listener : getapplicationlisteners()) { getapplicationeventmulticaster().addapplicationlistener(listener); } // do not initialize factorybeans here: we need to leave all regular beans // uninitialized to let post-processors apply to them! string[] listenerbeannames = getbeannamesfortype(applicationlistener.class, true, false); for (string listenerbeanname : listenerbeannames) { getapplicationeventmulticaster().addapplicationlistenerbean(listenerbeanname); } // publish early application events now that we finally have a multicaster... set<applicationevent> earlyeventstoprocess = this.earlyapplicationevents; this.earlyapplicationevents = null; if (earlyeventstoprocess != null) { for (applicationevent earlyevent : earlyeventstoprocess) { getapplicationeventmulticaster().multicastevent(earlyevent); } } } |
在abstractapplicationcontext中publishevent：
|
1
2
3
4
5
6
7
8
9
10
|
protected void publishevent(object event, @nullable resolvabletype eventtype) { //..... // multicast right now if possible - or lazily once the multicaster is initialized if (this.earlyapplicationevents != null) { this.earlyapplicationevents.add(applicationevent); } else { getapplicationeventmulticaster().multicastevent(applicationevent, eventtype); //事件廣播 //.... } |
具體的發(fā)布事件的方法都在上面提到的applicationeventmulticaster這個(gè)類型的類中去實(shí)現(xiàn)的，在abstractapplicationcontext中，會(huì)先嘗試從configurablelistablebeanfactory中去加載這個(gè)類，如果不存在，則會(huì)默認(rèn)new 一個(gè)simpleapplicationeventmulticaster：
|
1
2
3
4
5
6
7
8
9
10
11
12
|
protected void initapplicationeventmulticaster() { configurablelistablebeanfactory beanfactory = getbeanfactory(); if (beanfactory.containslocalbean(application_event_multicaster_bean_name)) { //嘗試加載 this.applicationeventmulticaster = beanfactory.getbean(application_event_multicaster_bean_name, applicationeventmulticaster.class); if (logger.istraceenabled()) { logger.trace("using applicationeventmulticaster [" + this.applicationeventmulticaster + "]"); } } else { this.applicationeventmulticaster = new simpleapplicationeventmulticaster(beanfactory); //不存在則默認(rèn)使用simpleapplicationeventmulticaster beanfactory.registersingleton(application_event_multicaster_bean_name, this.applicationeventmulticaster); |
看看simpleapplicationeventmulticaster 是怎么廣播事件的，由代碼可知，在線程池不為空的情況下，異步發(fā)布特定類型的事件。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
@override public void multicastevent(final applicationevent event, @nullable resolvabletype eventtype) { resolvabletype type = (eventtype != null ? eventtype : resolvedefaulteventtype(event)); for (final applicationlistener<?> listener : getapplicationlisteners(event, type)) { executor executor = gettaskexecutor(); if (executor != null) { executor.execute(() -> invokelistener(listener, event)); } else { invokelistener(listener, event); } } //.... |
將invokelistener方法點(diǎn)擊到最后，發(fā)現(xiàn)調(diào)用了listener的onapplicationevent(),實(shí)現(xiàn)了事件的發(fā)布。
|
1
2
3
4
5
6
7
8
|
private void doinvokelistener(applicationlistener listener, applicationevent event) { try { listener.onapplicationevent(event); } catch (classcastexception ex) { //.... } } |
（3）事件訂閱者（applicationlistener）：實(shí)現(xiàn)這個(gè)接口，就可以監(jiān)聽applicationlistener發(fā)布的特定的事件。
實(shí)現(xiàn)applicationlistener這個(gè)接口，重寫onapplicationevent()方法，來處理監(jiān)聽到的applicationevent，這里可以監(jiān)聽特定類型的事件。
3. 基于注解的事件監(jiān)聽
spring也為發(fā)布者和監(jiān)聽者提供了相應(yīng)的注解支持，只需要在對(duì)應(yīng)的觀察者類的對(duì)應(yīng)方法上加上@eventlistener：
對(duì)于發(fā)布者，可以直接在service通過@autowired注入applicationeventpublisher。
4.小結(jié)
文章主要介紹了spring中事件驅(qū)動(dòng)的模型。主要運(yùn)用了觀察者模式的思想，隨后介紹了spring中事件發(fā)布的機(jī)制。
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問大家可以留言交流，謝謝大家對(duì)服務(wù)器之家的支持。
原文鏈接：https://www.cnblogs.com/jy107600/p/10034857.html
