引子
在之前寫的《activiti之事件日志》一文中講到，通過配置enableDatabaseEventLogging屬性可以達(dá)到事件觸發(fā)后，自動(dòng)保存相關(guān)日志對(duì)象候衍。這里面的實(shí)現(xiàn)原理就是本文要討論的內(nèi)容。當(dāng)一個(gè)事件觸發(fā)后，會(huì)由已經(jīng)注冊好的監(jiān)聽器去監(jiān)聽到這個(gè)事件橄妆，然后在監(jiān)聽器內(nèi)部去實(shí)現(xiàn)相關(guān)邏輯衙伶。
配置監(jiān)聽器Listener
- eventListeners 監(jiān)聽所有的事件
- typedEventListeners 監(jiān)聽指定事件類型的事件
- activiti:EventListener 只監(jiān)聽特定流程定義的事件
相關(guān)類
- ActivitiEvent 事件對(duì)象類
- ActivitiEventListener 事件監(jiān)聽器類
- ActivitiEventType 事件類型(枚舉類型)
示例
首先編寫一個(gè)監(jiān)聽器類來監(jiān)聽流程啟動(dòng)事件,它繼承于ActivitiEventListener。
public class ProcessEventListener implements ActivitiEventListener {
private static final Logger logger = LoggerFactory.getLogger(HelloWorld.class);
public void onEvent(ActivitiEvent event) {
ActivitiEventType eventType = event.getType();
if(ActivitiEventType.ACTIVITY_STARTED.equals(eventType)){
logger.info("流程啟動(dòng)");
}
}
public boolean isFailOnException() {
return false;
}
}
另外配置activiti.cfg.xml文件：
<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db_activiti" />
<property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
<property name="jdbcUsername" value="root" />
<property name="jdbcPassword" value="abc123" />
<property name="eventListeners">
<list>
<bean class="com.activiti.event.ProcessEventListener"></bean>
</list>
</property>
</bean>
將自己寫的監(jiān)聽器類配置上去后害碾，啟動(dòng)流程后矢劲，就回打印出我們想要的“流程啟動(dòng)”了。
上述配置方式監(jiān)聽的是所有的事件慌随，如果想要監(jiān)聽特定的事件芬沉，需要配置如下：
<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db_activiti" />
<property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
<property name="jdbcUsername" value="root" />
<property name="jdbcPassword" value="abc123" />
<property name="typedEventListeners">
<map>
<entry key="PROCESS_STARTED">
<list>
<bean class="com.activiti.event.ProcessEventListener"></bean>
</list>
</entry>
</map>
</property>
</bean>
這樣流程啟動(dòng)后同樣也能監(jiān)聽并打印日志了。
自定義事件監(jiān)聽和發(fā)布
之前的事件都是activiti自帶的事件儒陨，如何自定義事件花嘶，并且監(jiān)聽和發(fā)布呢笋籽？實(shí)現(xiàn)如下：
runtimeService.addEventListener(new ProcessEventListener());
runtimeService.dispatchEvent(new ActivitiEventImpl(ActivitiEventType.CUSTOM));
即首先發(fā)布事件監(jiān)聽器蹦漠，這里這個(gè)ProcessEventListener監(jiān)聽器監(jiān)聽所有事件，然后發(fā)布自定義事件车海。這樣就能自己監(jiān)聽自己發(fā)布的事件了笛园。
之前我們定義的監(jiān)聽器繼承于ActivitiEventListener接口，實(shí)現(xiàn)了onEvent方法侍芝，自己去判斷事件類型研铆，進(jìn)行相應(yīng)處理，這里再介紹一下工作流內(nèi)部提供的實(shí)現(xiàn)類BaseEntityEventListener州叠，這個(gè)類重寫了ActivitiEventListener接口的onEvent方法：
@Override
public final void onEvent(ActivitiEvent event) {
if (isValidEvent(event)) {
// Check if this event
if (event.getType() == ActivitiEventType.ENTITY_CREATED) {
onCreate(event);
} else if (event.getType() == ActivitiEventType.ENTITY_INITIALIZED) {
onInitialized(event);
} else if (event.getType() == ActivitiEventType.ENTITY_DELETED) {
onDelete(event);
} else if (event.getType() == ActivitiEventType.ENTITY_UPDATED) {
onUpdate(event);
} else {
// Entity-specific event
onEntityEvent(event);
}
}
}
protected void onCreate(ActivitiEvent event) {
// Default implementation is a NO-OP
}
......
所以如果只是用到基本的監(jiān)聽事件棵红，也可以繼承BaseEntityEventListener這個(gè)類，復(fù)寫它的onCreate等方法來實(shí)現(xiàn)監(jiān)聽咧栗，會(huì)更加方便逆甜。
