当前位置：网站首页>Activiti global process monitors activitieventlistener to monitor different types of events, which is very convenient without configuring task monitoring in acitivit

Activiti global process monitors activitieventlistener to monitor different types of events, which is very convenient without configuring task monitoring in acitivit

2022-07-06 20:32:00 【Programmer Shi Lei】

If we want to configure monitoring for tasks , As a rule, it's like this

activiti Global process monitoring ActivitiEventListener, Realize monitoring different types of events , Don't need to acitivit Configure task listening , Very convenient _ Business logic

Configure one by one , More trouble .

Now use ActivitiEventListener, Monitor global events , And we can judge different event types , And then perform different business logic .

1. Define event handling handler Interface

Using interfaces to define uniform conventions

       
        public interface EventHandler {
        
    void handle(ActivitiEvent event);
        
}
       
       
        1.
        2.
        3.

2. Implement different events

End of mission Events

       
        */
        
public class TaskCompleteListener implements EventHandler {
        

        
    protected Logger logger = LoggerFactory.getLogger(getClass());
        
    @Override
        
    public void handle(ActivitiEvent event) {
        
        ActivitiEntityEventImpl eventImpl = (ActivitiEntityEventImpl) event;
        
        TaskEntity taskEntity = (TaskEntity) eventImpl.getEntity();
        

        

        
    }
        
}
       
       
        1.
        2.
        3.
        4.
        5.
        6.
        7.
        8.
        9.
        10.
        11.
        12.

Task creation Events

       
        public class TaskCreateListener implements EventHandler {
        

        
    protected Logger logger = LoggerFactory.getLogger(getClass());
        

        
    @Override
        
    public void handle(ActivitiEvent event) {
        
        ActivitiEntityEventImpl eventImpl = (ActivitiEntityEventImpl) event;
        
        TaskEntity taskEntity = (TaskEntity) eventImpl.getEntity();
        

        
    }
        

        
}
       
       
        1.
        2.
        3.
        4.
        5.
        6.
        7.
        8.
        9.
        10.
        11.
        12.

There are many more events , such as TASK_ASSIGNED,PROCESS_STARTED,PROCESS_COMPLETED

3. Realization ActivitiEventListener

       
        public class GlobalEventListener implements ActivitiEventListener {
        
    protected Logger logger = LoggerFactory.getLogger(getClass());
        
    /**
        
     *  Various types  Event  The processor of 
        
     */
        
    private Map<ActivitiEventType, EventHandler> handlers = new HashMap<ActivitiEventType, EventHandler>();
        

        

        

        
    @Override
        
    public void onEvent(ActivitiEvent event) {
        
        EventHandler eventHandler = handlers.get(event.getType());
        
        if(eventHandler!=null){
        
            eventHandler.handle(event);
        
        }
        
    }
        

        
    @Override
        
    public boolean isFailOnException() {
        
        return false;
        
    }
        

        
    public Map<ActivitiEventType, EventHandler> getHandlers() {
        
        return handlers;
        
    }
        

        
    public void setHandlers(Map<ActivitiEventType, EventHandler> handlers) {
        
        this.handlers = handlers;
        
    }
        
}
       
       
        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.

4. Register event monitoring

       
        <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
        
        <property name="dataSource" ref="dataSource"/>
        
        <property name="transactionManager" ref="transactionManager"/>
        
        <property name="databaseSchemaUpdate" value="true"/>
        
        <property name="jobExecutorActivate" value="false"/>
        
        <property name="history" value="full"/>
        
        <property name="processDefinitionCacheLimit" value="10"/>
        

        
        <!--  Generate font for flowchart  -->
        
        <property name="activityFontName" value=" Song style "/>
        
        <property name="labelFontName" value=" Song style "/>
        
        <property name="annotationFontName" value=" Song style "/>
        
        <!--  Automatic deployment  -->
        
        <property name="deploymentResources">
        
            <list>
        
                <value>classpath*:*</value>
        
            </list>
        
        </property>
        
        <!--  <property name="idGenerator" ref="idGenerator"/>-->
        
        <property name="eventListeners">
        
            <list>
        
                  <ref bean="globalEventListener"/>
        
            </list>
        
        </property>
        
        <property name="customFormTypes">
        
            <bean class="org.activiti.engine.impl.form.DateFormType">
        
                <constructor-arg value="yyyy-MM-dd HH:mm:ss"/>
        
            </bean>
        
        </property>
        
    </bean>
        

        
    <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
        
        <property name="processEngineConfiguration" ref="processEngineConfiguration"/>
        
    </bean>
        

        
    <bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService"/>
        
    <bean id="runtimeService" factory-bean="processEngine" factory-method="getRuntimeService"/>
        
    <bean id="formService" factory-bean="processEngine" factory-method="getFormService"/>
        
    <bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService"/>
        
    <bean id="taskService" factory-bean="processEngine" factory-method="getTaskService"/>
        
    <bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService"/>
        
    <bean id="managementService" factory-bean="processEngine" factory-method="getManagementService"/>
        

        
    <!-- Process global event handler -->
        
    <bean id="globalEventListener" class="GlobalEventListener">
        
         <property name="handlers">
        
             <map>
        
                 <entry key="TASK_CREATED">
        
                     <bean class="TaskCreateListener"/>
        
                 </entry>
        
                   <entry key="TASK_COMPLETED">
        
                     <bean class="TaskCompleteListener"/>
        
                   </entry>
        
             </map>
        
         </property>
        
     </bean>
       
       
        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.
        35.
        36.
        37.
        38.
        39.
        40.
        41.
        42.
        43.
        44.
        45.
        46.
        47.
        48.
        49.
        50.
        51.
        52.
        53.
        54.
        55.
        56.