业务事件模型的实现

时间  2019-12-08
标签 业务 事件 模型 实现 繁體版
原文   原文链接

　　在实际业务开发过程当中，很常常应用到观察者模式。大体的处理流程是说在模块初始化的时候，注册若干观察者，而后它们处理本身感兴趣的内容。当某一个具体的事件发生的时候，遍历观察者队列，而后”观察者“们就根据以前约定的具体状况，处理本身关注的事件。其实观察者模式本人认为更确切的说法应该是：事件通知模型。那么如今，咱们就用传统的Java语言来实现一下（具体能够查看代码的注释，写的挺详细了）。java

　　业务事件定义以下：spring

/**
 * @filename:BusinessEvent.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:业务事件定义
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.businessevent;

public class BusinessEvent {

    // 某种具体的业务事件的数据内容
    private Object businessData;

    // 某种具体的业务事件的事件类型
    private String businessEventType;

    public BusinessEvent(String businessEventType, Object businessData) {
        this.businessEventType = businessEventType;
        this.businessData = businessData;
    }

    public Object getBusinessData() {
        return this.businessData;
    }

    public String getBusinessEventType() {
        return this.businessEventType;
    }

}

　　接着就是业务事件监听器的定义了app

/**
 * @filename:BusinessEventListener.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:业务事件监听器定义
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.businessevent;

public interface BusinessEventListener {
    
    //事件接口定义
    public void execute(BusinessEvent event);

}

　　业务事件，总要有个管理者吧，那如今就实现一个框架

/**
 * @filename:BusinessEventManagement.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:业务事件管理器定义
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.businessevent;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

//业务事件管理器
public class BusinessEventManagement {

    private Map<String, List<BusinessEventListener>> map = new HashMap<String, List<BusinessEventListener>>();

    public BusinessEventManagement() {

    }

    // 注册业务事件监听器
    public boolean addBusinessEventListener(String BusinessEventType,BusinessEventListener listener) {
        List<BusinessEventListener> listeners = map.get(BusinessEventType);
        
        if (null == listeners) {
            listeners = new ArrayList<BusinessEventListener>();
        }
        
        boolean result = listeners.add(listener);
        
        map.put(BusinessEventType, listeners);
        
        return result;
    }

    // 移除业务事件监听器
    public boolean removeBusinessEventListener(String BusinessEventType,BusinessEventListener listener) {
        List<BusinessEventListener> listeners = map.get(BusinessEventType);

        if (null != listeners) {
            return listeners.remove(listener);
        }

        return false;
    }

    // 获取业务事件监听器队列
    public List<BusinessEventListener> getBusinessEventListeners(String BusinessEventType) {
        return map.get(BusinessEventType);
    }

}

　　再来一个事件的发送者，来负责事件的派发ide

/**
 * @filename:BusinessEventNotify.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:业务事件发送者
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.businessevent;

import java.util.List;

public class BusinessEventNotify {

    private BusinessEventManagement businessEventManagement;;

    public BusinessEventNotify(BusinessEventManagement businessEventManagement) {
        this.businessEventManagement = businessEventManagement;
    }

    // 事件派发
    public void notify(BusinessEvent BusinessEvent) {
        if (null == BusinessEvent) {
            return;
        }

        List<BusinessEventListener> listeners = businessEventManagement.getBusinessEventListeners(BusinessEvent.getBusinessEventType());

        if (null == listeners) {
            return;
        }

        for (BusinessEventListener listener : listeners) {
            listener.execute(BusinessEvent);
        }
    }
}

　　关键的来了，下面能够根据本身的业务规定，注册若干个事件的监听器。下面咱们就先注册两个监听器，分别是短信监听器、彩铃监听器，而后执行本身对“感兴趣”事件进行的操做。函数

/**
 * @filename:SendSmsListener.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:短信消息监听器
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.businessevent;

public class SendSmsListener implements BusinessEventListener {

    @Override
    public void execute(BusinessEvent event) {
        System.out.println("监听器:" + this + "接收到业务事件，业务事件类型是["
                + event.getBusinessEventType() + "] ## 业务事件附带的数据["
                + event.getBusinessData() + "]");
    }

}
/**
 * @filename:ColorRingListener.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:彩铃消息监听器
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.businessevent;

public class ColorRingListener implements BusinessEventListener {

    @Override
    public void execute(BusinessEvent event) {
        System.out.println("监听器:" + this + "接收到业务事件，业务事件类型是["
                + event.getBusinessEventType() + "] ## 业务事件附带的数据["
                + event.getBusinessData() + "]");
    }

}

　　好了，所有的框架都完成了，那如今咱们把上述模块完整的调用起来。this

/**
 * @filename:Main.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:主函数
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.businessevent;

public class Main {

    /**
     * @param args
     */
    public static void main(String[] args) {
        
        // 注册监听器
        BusinessEventManagement businessEventManagement = new BusinessEventManagement();
        
        businessEventManagement.addBusinessEventListener("彩铃监听器",new ColorRingListener());
        businessEventManagement.addBusinessEventListener("短信监听器",new SendSmsListener());

        // 业务事件触发
        BusinessEventNotify sender = new BusinessEventNotify(businessEventManagement);
        
        sender.notify(new BusinessEvent("彩铃监听器", "ReadBusinessEvent"));
        sender.notify(new BusinessEvent("短信监听器", "WriteBusinessEvent"));
    }

}

　　彩铃监听器感兴趣的事件是读事件（ReadBusinessEvent），短信监听器感兴趣的事件是写事件（WriteBusinessEvent）。运行起来以后，发现果真组织的很好。固然有人会说，上面的状况JDK里面已经有现成的类（java.util.EventObject、java.util.EventListener）支持了。那下面咱们就根据上面的例子，利用Spring框架来模拟一下事件模型是如何更优雅的应用的。spa

　　在Spring里面，全部事件的基类是ApplicationEvent，那咱们从这个类派生一下，从新定义一下咱们的业务事件。代码以下code

/**
 * @filename:BusinessEvent.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:业务事件定义
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.spring;

import org.springframework.context.ApplicationEvent;

public class BusinessEvent extends ApplicationEvent {
    
    // 某种具体的业务事件的数据内容
    private Object businessData;

    // 某种具体的业务事件的事件类型
    private String businessEventType;

    public BusinessEvent(String businessEventType, Object businessData) {
        super(businessEventType);

        this.businessEventType = businessEventType;
        this.businessData = businessData;
    }

    public Object getBusinessData() {
        return this.businessData;
    }

    public String getBusinessEventType() {
        return this.businessEventType;
    }
}

　　一样的，事件的发送者也要进行一下调整，代码以下xml

/**
 * @filename:BusinessEventNotify.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:业务事件发送者
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.spring;

import java.util.List;

import newlandframework.spring.BusinessEvent;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;

public class BusinessEventNotify implements ApplicationContextAware {

    private List<String> businessListenerList;
    
    private ApplicationContext ctx;

    public void setBusinessListenerList(List<String> businessListenerList) {
        this.businessListenerList = businessListenerList;
    }

    public void setApplicationContext(ApplicationContext applicationContext)
            throws BeansException {
        this.ctx = applicationContext;
    }

    public void notify(BusinessEvent businessEvent) {
        if (businessListenerList.contains(businessEvent.getBusinessEventType())) {
            BusinessEvent event = new BusinessEvent(
                    businessEvent.getBusinessEventType(),
                    businessEvent.getBusinessData());
            ctx.publishEvent(event);

            return;
        }
    }
}

　　下面咱们就来注册一下Spring方式的短信、彩铃监听器：

/**
 * @filename:SendSmsListener.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:短信消息监听器
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.spring;

import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;

public class SendSmsListener implements ApplicationListener {
    
    final String strKey = "SMS";

    public void onApplicationEvent(ApplicationEvent event) {
        // 这里你能够截取感兴趣的实际类型
        if (event instanceof BusinessEvent) {
            BusinessEvent businessEvent = (BusinessEvent) event;

            if (businessEvent.getBusinessEventType().toUpperCase().contains(strKey)) {
                System.out.println("监听器:" + this + "接收到业务事件，业务事件类型是["
                        + businessEvent.getBusinessEventType()
                        + "] ## 业务事件附带的数据[" + businessEvent.getBusinessData()
                        + "]");
            }
        }
    }
}
/**
 * @filename:ColorRingListener.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:彩铃消息监听器
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.spring;

import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;

public class ColorRingListener implements ApplicationListener {

    public void onApplicationEvent(ApplicationEvent event) {
        if (event instanceof BusinessEvent) {
            BusinessEvent businessEvent = (BusinessEvent) event;
            System.out.println("监听器:" + this + "接收到业务事件，业务事件类型是["
                    + businessEvent.getBusinessEventType() + "] ## 业务事件附带的数据["
                    + businessEvent.getBusinessData() + "]");
        }
    }
}

　　最后咱们编写一下Spring的依赖注入的配置文件spring-event.xml，固然事件的监听器也是在这里面依赖注入实现自动装配的。

<?xml version="1.0" encoding="GBK"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
             http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"
    default-autowire="byName">
    <bean id="smsListener" class="newlandframework.spring.SendSmsListener" />
    <bean id="ringListener" class="newlandframework.spring.ColorRingListener" />
    <bean id="event" class="newlandframework.spring.BusinessEventNotify">
        <property name="businessListenerList">
            <list>
                <value>DealColorRing</value>
                <value>DealSms</value>
            </list>
        </property>
    </bean>
</beans>

　　一切准备就绪，如今咱们把上面Spring方式实现的事件模型，完整的串起来，代码以下：

/**
 * @filename:Main.java
 *
 * Newland Co. Ltd. All rights reserved.
 * 
 * @Description:主函数
 * @author tangjie
 * @version 1.0
 * 
 */

package newlandframework.spring;

import newlandframework.spring.BusinessEvent;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Main {

    public static void main(String[] args) {
        ApplicationContext ctx = new ClassPathXmlApplicationContext("newlandframework/spring/spring-event.xml");

        BusinessEventNotify sender = (BusinessEventNotify) ctx.getBean("event");

        sender.notify(new BusinessEvent("DealColorRing", "ReadBusinessEvent"));

        sender.notify(new BusinessEvent("DealSms", "ReadBusinessEvent"));
    }
}

　　运行的结果以下，很是完美，不是么？

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程