亚洲无线码一区二区三区,亚洲av无码一区二区三区网站,亚洲国产高清国产拍精品

事件驅(qū)動(dòng)模型簡(jiǎn)介

事件驅(qū)動(dòng)模型也就是我們常說(shuō)的觀察者，或者發(fā)布-訂閱模型；理解它的幾個(gè)關(guān)鍵點(diǎn)：

首先是一種對(duì)象間的一對(duì)多的關(guān)系；最簡(jiǎn)單的如交通信號(hào)燈，信號(hào)燈是目標(biāo)（一方），行人注視著信號(hào)燈（多方）；
當(dāng)目標(biāo)發(fā)送改變（發(fā)布），觀察者（訂閱者）就可以接收到改變；
觀察者如何處理（如行人如何走，是快走/慢走/不走，目標(biāo)不會(huì)管的），目標(biāo)無(wú)需干涉；所以就松散耦合了它們之間的關(guān)系。

接下來(lái)先看一個(gè)用戶注冊(cè)的例子：

用戶注冊(cè)成功后，需要做這么多事：

1、加積分

2、發(fā)確認(rèn)郵件

3、如果是游戲帳戶，可能贈(zèng)送游戲大禮包

4、索引用戶數(shù)據(jù)

…………

問(wèn)題：

UserService和其他Service耦合嚴(yán)重，增刪功能比較麻煩；
有些功能可能需要調(diào)用第三方系統(tǒng)，如增加積分/索引用戶，速度可能比較慢，此時(shí)需要異步支持；這個(gè)如果使用Spring，可以輕松解決，后邊再介紹；

從如上例子可以看出，應(yīng)該使用一個(gè)觀察者來(lái)解耦這些Service之間的依賴關(guān)系，如圖：

增加了一個(gè)Listener來(lái)解耦UserService和其他服務(wù)，即注冊(cè)成功后，只需要通知相關(guān)的監(jiān)聽(tīng)器，不需要關(guān)系它們?nèi)绾翁幚怼Ｔ鰟h功能非常容易。

這就是一個(gè)典型的事件處理模型/觀察者，解耦目標(biāo)對(duì)象和它的依賴對(duì)象，目標(biāo)只需要通知它的依賴對(duì)象，具體怎么處理，依賴對(duì)象自己決定。比如是異步還是同步，延遲還是非延遲等。

上邊其實(shí)也使用了DIP（依賴倒置原則），依賴于抽象，而不是具體。

還是就是使用了IoC思想，即以前主動(dòng)去創(chuàng)建它依賴的Service，現(xiàn)在只是被動(dòng)等待別人注冊(cè)進(jìn)來(lái)。

其他的例子還有如GUI中的按鈕和動(dòng)作的關(guān)系，按鈕和動(dòng)作本身都是一種抽象，每個(gè)不同的按鈕的動(dòng)作可能不一樣；如“文件-->新建”打開(kāi)新建窗口；點(diǎn)擊“關(guān)閉”按鈕關(guān)閉窗口等等。

主要目的是：松散耦合對(duì)象間的一對(duì)多的依賴關(guān)系，如按鈕和動(dòng)作的關(guān)系；

如何實(shí)現(xiàn)呢？面向接口編程（即面向抽象編程），而非面向?qū)崿F(xiàn)。即按鈕和動(dòng)作可以定義為接口，這樣它倆的依賴是最小的（如在Java中，沒(méi)有比接口更抽象的了）。

有朋友會(huì)問(wèn)，我剛開(kāi)始學(xué)的時(shí)候也是這樣：抽象類(lèi)不也行嗎？記住一個(gè)原則：接口目的是抽象，抽象類(lèi)目的是復(fù)用；所以如果接觸過(guò)servlet/struts2/spring等框架，大家都應(yīng)該知道：

Servlet<-----GenericServlet<-----HttpServlet<------我們自己的
Action<------ActionSupport<------我們自己的
DaoInterface<------××DaoSupport<-----我們自己的

從上邊大家應(yīng)該能體會(huì)出接口、抽象類(lèi)的主要目的了。現(xiàn)在想想其實(shí)很簡(jiǎn)單。

在Java中接口還一個(gè)非常重要的好處：接口是可以多實(shí)現(xiàn)的，類(lèi)/抽象類(lèi)只能單繼承，所以使用接口可以非常容易擴(kuò)展新功能（還可以實(shí)現(xiàn)所謂的mixin），類(lèi)/抽象類(lèi)辦不到。

Java GUI事件驅(qū)動(dòng)模型/觀察者

扯遠(yuǎn)了，再來(lái)看看Java GUI世界里的事件驅(qū)動(dòng)模型吧：

如果寫(xiě)過(guò)AWT/Swing程序，應(yīng)該知道其所有組件都繼承自java.awt.Component抽象類(lèi)，其內(nèi)部提供了addXXXListener(XXXListener l) 注冊(cè)監(jiān)聽(tīng)器的方法，即Component與實(shí)際動(dòng)作之間依賴于XXXListener抽象。

比如獲取焦點(diǎn)事件，很多組件都可以有這個(gè)事件，是我們知道組件獲取到焦點(diǎn)后需要一個(gè)處理，雖然每個(gè)組件如何處理是特定的（具體的），但我們可以抽象一個(gè)FocusListener，讓所有具體實(shí)現(xiàn)它然后提供具體動(dòng)作，這樣組件只需依賴于FocusListener抽象，而不是具體。

還有如java.awt.Button，提供了一個(gè)addActionListener(ActionListener l)，用于注冊(cè)點(diǎn)擊后觸發(fā)的ActionListener實(shí)現(xiàn)。

組件是一個(gè)抽象類(lèi)，其好處主要是復(fù)用，比如復(fù)用這些監(jiān)聽(tīng)器的觸發(fā)及管理等。

JavaBean規(guī)范的事件驅(qū)動(dòng)模型/觀察者

JavaBean規(guī)范提供了JavaBean的PropertyEditorSupport及PropertyChangeListener支持。

PropertyEditorSupport就是目標(biāo)，而PropertyChangeListener就是監(jiān)聽(tīng)器，大家可以google搜索下，具體網(wǎng)上有很多例子。

Java提供的事件驅(qū)動(dòng)模型/觀察者抽象

JDK內(nèi)部直接提供了觀察者模式的抽象：

目標(biāo)：java.util.Observable，提供了目標(biāo)需要的關(guān)鍵抽象：addObserver/deleteObserver/notifyObservers()等，具體請(qǐng)參考javadoc。

觀察者：java.util.Observer，提供了觀察者需要的主要抽象：update(Observable o, Object arg)，此處還提供了一種推模型（目標(biāo)主動(dòng)把數(shù)據(jù)通過(guò)arg推到觀察者）/拉模型（目標(biāo)需要根據(jù)o自己去拉數(shù)據(jù)，arg為null）。

因?yàn)榫W(wǎng)上介紹的非常多了，請(qǐng)google搜索了解如何使用這個(gè)抽象及推/拉模型的優(yōu)缺點(diǎn)。

接下來(lái)是我們的重點(diǎn)：spring提供的事件驅(qū)動(dòng)模型。

Spring提供的事件驅(qū)動(dòng)模型/觀察者抽象

首先看一下Spring提供的事件驅(qū)動(dòng)模型體系圖：

事件

具體代表者是：ApplicationEvent：

1、其繼承自JDK的EventObject，JDK要求所有事件將繼承它，并通過(guò)source得到事件源，比如我們的AWT事件體系也是繼承自它；

2、系統(tǒng)默認(rèn)提供了如下ApplicationEvent事件實(shí)現(xiàn)：

只有一個(gè)ApplicationContextEvent，表示ApplicationContext容器事件，且其又有如下實(shí)現(xiàn)：

ContextStartedEvent：ApplicationContext啟動(dòng)后觸發(fā)的事件；（目前版本沒(méi)有任何作用）
ContextStoppedEvent：ApplicationContext停止后觸發(fā)的事件；（目前版本沒(méi)有任何作用）
ContextRefreshedEvent：ApplicationContext初始化或刷新完成后觸發(fā)的事件；（容器初始化完成后調(diào)用）
ContextClosedEvent：ApplicationContext關(guān)閉后觸發(fā)的事件；（如web容器關(guān)閉時(shí)自動(dòng)會(huì)觸發(fā)spring容器的關(guān)閉，如果是普通java應(yīng)用，需要調(diào)用ctx.registerShutdownHook();注冊(cè)虛擬機(jī)關(guān)閉時(shí)的鉤子才行）

注：org.springframework.context.support.AbstractApplicationContext抽象類(lèi)實(shí)現(xiàn)了LifeCycle的start和stop回調(diào)并發(fā)布ContextStartedEvent和ContextStoppedEvent事件；但是無(wú)任何實(shí)現(xiàn)調(diào)用它，所以目前無(wú)任何作用。

目標(biāo)（發(fā)布事件者）

具體代表者是：ApplicationEventPublisher及ApplicationEventMulticaster，系統(tǒng)默認(rèn)提供了如下實(shí)現(xiàn)：

1、ApplicationContext接口繼承了ApplicationEventPublisher，并在AbstractApplicationContext實(shí)現(xiàn)了具體代碼，實(shí)際執(zhí)行是委托給ApplicationEventMulticaster（可以認(rèn)為是多播）：

Java代碼  
public void publishEvent(ApplicationEvent event) {  
    //省略部分代碼  
    }  
    getApplicationEventMulticaster().multicastEvent(event);  
    if (this.parent != null) {  
        this.parent.publishEvent(event);  
    }  
}  

我們常用的ApplicationContext都繼承自AbstractApplicationContext，如ClassPathXmlApplicationContext、XmlWebApplicationContext等。所以自動(dòng)擁有這個(gè)功能。

2、ApplicationContext自動(dòng)到本地容器里找一個(gè)名字為”“的ApplicationEventMulticaster實(shí)現(xiàn)，如果沒(méi)有自己new一個(gè)SimpleApplicationEventMulticaster。其中SimpleApplicationEventMulticaster發(fā)布事件的代碼如下：

Java代碼  
public void multicastEvent(final ApplicationEvent event) {  
    for (final ApplicationListener listener : getApplicationListeners(event)) {  
        Executor executor = getTaskExecutor();  
        if (executor != null) {  
            executor.execute(new Runnable() {  
                public void run() {  
                    listener.onApplicationEvent(event);  
                }  
            });  
        }  
        else {  
            listener.onApplicationEvent(event);  
        }  
    }  
}  

大家可以看到如果給它一個(gè)executor（java.util.concurrent.Executor），它就可以異步支持發(fā)布事件了。佛則就是通過(guò)發(fā)送。

所以我們發(fā)送事件只需要通過(guò)ApplicationContext.publishEvent即可，沒(méi)必要再創(chuàng)建自己的實(shí)現(xiàn)了。除非有必要。

監(jiān)聽(tīng)器

具體代表者是：ApplicationListener

1、其繼承自JDK的EventListener，JDK要求所有監(jiān)聽(tīng)器將繼承它，比如我們的AWT事件體系也是繼承自它；

2、ApplicationListener接口：

Java代碼  
public interface ApplicationListener<E extends ApplicationEvent> extends EventListener {  
    void onApplicationEvent(E event);  
}  

其只提供了onApplicationEvent方法，我們需要在該方法實(shí)現(xiàn)內(nèi)部判斷事件類(lèi)型來(lái)處理，也沒(méi)有提供按順序觸發(fā)監(jiān)聽(tīng)器的語(yǔ)義，所以Spring提供了另一個(gè)接口，SmartApplicationListener：

Java代碼  
public interface SmartApplicationListener extends ApplicationListener<ApplicationEvent>, Ordered {  
        //如果實(shí)現(xiàn)支持該事件類(lèi)型 那么返回true  
    boolean supportsEventType(Class<? extends ApplicationEvent> eventType);  
    
        //如果實(shí)現(xiàn)支持“目標(biāo)”類(lèi)型，那么返回true  
    boolean supportsSourceType(Class<?> sourceType);  
         
        //順序，即監(jiān)聽(tīng)器執(zhí)行的順序，值越小優(yōu)先級(jí)越高  
        int getOrder();  
}  

該接口可方便實(shí)現(xiàn)去判斷支持的事件類(lèi)型、目標(biāo)類(lèi)型，及執(zhí)行順序。

Spring事件機(jī)制的簡(jiǎn)單例子

本例子模擬一個(gè)給多個(gè)人發(fā)送內(nèi)容（類(lèi)似于報(bào)紙新聞）的例子。

1、定義事件

Java代碼  
package com.sishuok.hello;  
import org.springframework.context.ApplicationEvent;  
public class ContentEvent extends ApplicationEvent {  
    public ContentEvent(final String content) {  
        super(content);  
    }  
}  

非常簡(jiǎn)單，如果用戶發(fā)送內(nèi)容，只需要通過(guò)構(gòu)造器傳入內(nèi)容，然后通過(guò)getSource即可獲取。

2、定義無(wú)序監(jiān)聽(tīng)器

之所以說(shuō)無(wú)序，類(lèi)似于AOP機(jī)制，順序是無(wú)法確定的。

Java代碼  
package com.sishuok.hello;  
import org.springframework.context.ApplicationEvent;  
import org.springframework.context.ApplicationListener;  
import org.springframework.stereotype.Component;  
@Component  
public class LisiListener implements ApplicationListener<ApplicationEvent> {  
    @Override  
    public void onApplicationEvent(final ApplicationEvent event) {  
        if(event instanceof ContentEvent) {  
            System.out.println("李四收到了新的內(nèi)容：" + event.getSource());  
        }  
    }  
}  

1、使用@Compoent注冊(cè)Bean即可；

2、在實(shí)現(xiàn)中需要判斷event類(lèi)型是ContentEvent才可以處理；

更簡(jiǎn)單的辦法是通過(guò)泛型指定類(lèi)型，如下所示

Java代碼  
package com.sishuok.hello;  
import org.springframework.context.ApplicationListener;  
import org.springframework.stereotype.Component;  
@Component  
public class ZhangsanListener implements ApplicationListener<ContentEvent> {  
    @Override  
    public void onApplicationEvent(final ContentEvent event) {  
        System.out.println("張三收到了新的內(nèi)容：" + event.getSource());  
    }  
}  

3、定義有序監(jiān)聽(tīng)器

實(shí)現(xiàn)SmartApplicationListener接口即可。

Java代碼  
package com.sishuok.hello;  
import org.springframework.context.ApplicationEvent;  
import org.springframework.context.event.SmartApplicationListener;  
import org.springframework.stereotype.Component;  
  
@Component  
public class WangwuListener implements SmartApplicationListener {  
  
    @Override  
    public boolean supportsEventType(final Class<? extends ApplicationEvent> eventType) {  
        return eventType == ContentEvent.class;  
    }  
    @Override  
    public boolean supportsSourceType(final Class<?> sourceType) {  
        return sourceType == String.class;  
    }  
    @Override  
    public void onApplicationEvent(final ApplicationEvent event) {  
        System.out.println("王五在孫六之前收到新的內(nèi)容：" + event.getSource());  
    }  
    @Override  
    public int getOrder() {  
        return 1;  
    }  
}  

Java代碼  
package com.sishuok.hello;  
import org.springframework.context.ApplicationEvent;  
import org.springframework.context.event.SmartApplicationListener;  
import org.springframework.stereotype.Component;  
  
@Component  
public class SunliuListener implements SmartApplicationListener {  
  
    @Override  
    public boolean supportsEventType(final Class<? extends ApplicationEvent> eventType) {  
        return eventType == ContentEvent.class;  
    }  
  
    @Override  
    public boolean supportsSourceType(final Class<?> sourceType) {  
        return sourceType == String.class;  
    }  
  
    @Override  
    public void onApplicationEvent(final ApplicationEvent event) {  
        System.out.println("孫六在王五之后收到新的內(nèi)容：" + event.getSource());  
    }  
  
    @Override  
    public int getOrder() {  
        return 2;  
    }  
}  

supportsEventType：用于指定支持的事件類(lèi)型，只有支持的才調(diào)用onApplicationEvent；
supportsSourceType：支持的目標(biāo)類(lèi)型，只有支持的才調(diào)用onApplicationEvent；
getOrder：即順序，越小優(yōu)先級(jí)越高

4、測(cè)試

4.1、配置文件

Java代碼  
<context:component-scan base-package="com.sishuok"/>  

就一句話，自動(dòng)掃描注解Bean。

4.2、測(cè)試類(lèi)

Java代碼  
package com.sishuok;  
import com.sishuok.hello.ContentEvent;  
import org.junit.Test;  
import org.junit.runner.RunWith;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.context.ApplicationContext;  
import org.springframework.test.context.ContextConfiguration;  
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;  
  
@RunWith(SpringJUnit4ClassRunner.class)  
@ContextConfiguration(locations={"classpath:spring-config-hello.xml"})  
public class HelloIT {  
  
    @Autowired  
    private ApplicationContext applicationContext;  
    @Test  
    public void testPublishEvent() {  
        applicationContext.publishEvent(new ContentEvent("今年是龍年的博客更新了"));  
    }  
  
}  

接著會(huì)輸出：

Java代碼  
王五在孫六之前收到新的內(nèi)容：今年是龍年的博客更新了  
孫六在王五之后收到新的內(nèi)容：今年是龍年的博客更新了  
李四收到了新的內(nèi)容：今年是龍年的博客更新了  
張三收到了新的內(nèi)容：今年是龍年的博客更新了  

一個(gè)簡(jiǎn)單的測(cè)試?yán)泳脱菔就戤叄椅覀兪褂胹pring的事件機(jī)制去寫(xiě)相關(guān)代碼會(huì)非常簡(jiǎn)單。

Spring事件機(jī)制實(shí)現(xiàn)之前提到的注冊(cè)流程

具體請(qǐng)下載源代碼參考com.sishuok.register包里的代碼。此處貼一下源碼結(jié)構(gòu)：

這里講解一下Spring對(duì)異步事件機(jī)制的支持，實(shí)現(xiàn)方式有兩種：

1、全局異步

即只要是觸發(fā)事件都是以異步執(zhí)行，具體配置（spring-config-register.xml）如下：

Java代碼  
<task:executor id="executor" pool-size="10" />  
<!-- 名字必須是applicationEventMulticaster和messageSource是一樣的，默認(rèn)找這個(gè)名字的對(duì)象 -->  
<!-- 名字必須是applicationEventMulticaster，因?yàn)锳bstractApplicationContext默認(rèn)找個(gè) -->  
<!-- 如果找不到就new一個(gè)，但不是異步調(diào)用而是同步調(diào)用 -->  
<bean id="applicationEventMulticaster" class="org.springframework.context.event.SimpleApplicationEventMulticaster">  
    <!-- 注入任務(wù)執(zhí)行器 這樣就實(shí)現(xiàn)了異步調(diào)用（缺點(diǎn)是全局的，要么全部異步，要么全部同步（刪除這個(gè)屬性即是同步））  -->  
    <property name="taskExecutor" ref="executor"/>  
</bean>  

通過(guò)注入taskExecutor來(lái)完成異步調(diào)用。具體實(shí)現(xiàn)可參考之前的代碼介紹。這種方式的缺點(diǎn)很明顯：要么大家都是異步，要么大家都不是。所以不推薦使用這種方式。

2、更靈活的異步支持

spring3提供了@Aync注解來(lái)完成異步調(diào)用。此時(shí)我們可以使用這個(gè)新特性來(lái)完成異步調(diào)用。不僅支持異步調(diào)用，還支持簡(jiǎn)單的任務(wù)調(diào)度，比如我的項(xiàng)目就去掉Quartz依賴，直接使用spring3這個(gè)新特性，具體可參考spring-config.xml。

2.1、開(kāi)啟異步調(diào)用支持

Java代碼  
<!-- 開(kāi)啟@AspectJ AOP代理 -->  
<aop:aspectj-autoproxy proxy-target-class="true"/>  
  
<!-- 任務(wù)調(diào)度器 -->  
<task:scheduler id="scheduler" pool-size="10"/>  
  
<!-- 任務(wù)執(zhí)行器 -->  
<task:executor id="executor" pool-size="10"/>  
  
<!--開(kāi)啟注解調(diào)度支持 @Async @Scheduled-->  
<task:annotation-driven executor="executor" scheduler="scheduler" proxy-target-class="true"/>  

2.2、配置監(jiān)聽(tīng)器讓其支持異步調(diào)用

Java代碼  
@Component  
public class EmailRegisterListener implements ApplicationListener<RegisterEvent> {  
    @Async  
    @Override  
    public void onApplicationEvent(final RegisterEvent event) {  
        System.out.println("注冊(cè)成功，發(fā)送確認(rèn)郵件給：" + ((User)event.getSource()).getUsername());  
    }  
}  

使用@Async注解即可，非常簡(jiǎn)單。

這樣不僅可以支持通過(guò)調(diào)用，也支持異步調(diào)用，非常的靈活，實(shí)際應(yīng)用推薦大家使用這種方式。

通過(guò)如上，大體了解了Spring的事件機(jī)制，可以使用該機(jī)制非常簡(jiǎn)單的完成如注冊(cè)流程，而且對(duì)于比較耗時(shí)的調(diào)用，可以直接使用Spring自身的異步支持來(lái)優(yōu)化。

event.rar (10.5 KB)
下載次數(shù): 28

發(fā)表于 2013-07-11 16:16 陳雨晨閱讀(4179) 評(píng)論(1) 編輯收藏

Spring事件驅(qū)動(dòng)模型