java中事件机制

介绍

最近在学习spring框架源码，看到了其中涉及事件处理，打算研究下事件的实现方式，所以从头学起，研究java中的事件实现机制。而且现实应用中很多都需要使用事件机制，而且使用事件机制也能对应用进行一定程度解耦。所以有必要好好了解下java中的事件机制。

场景假设

我们以网购12306火车票为场景，假设以下一些操作。
用户购买火车票成功后，会触发发送短信操作告知用户买了哪个车的票。
用户购买火车票成功后，会触发发送邮件操作告知用户买了哪个车的票。

重点理解

针对上面的场景，我们分析可以有如下几个对象或操作。
1.火车票对象，2.购买成功发短信操作，3.购买成功发邮件操作。
事件概念理解：
事件源：触发事件的对象，例如购买火车票成功后发短信的火车票就是就是事件源。
事件：对事件源进行操作产生的事件，例如购买成功后会产生发短信事件和发邮件事件。
事件监听器：对事件源产生的事件进行处理，可以对不同的事件设置不同的事件监听器，处理不同事件。
事件派发器：事件派发器主要处理事件的派发和事件监听器的管理，注册和删除事件监听器等。

目前java中EventObject对应事件，提供事件的基类，任何自定义事件都集成自该类；
EventListener对应事件监听器，提供事件监听器者接口，任何自定义的事件监听器都实现了该接口。

事件派发器java中没有提供，需要自己去实现。

自己写代码实现

以网购火车票为例，整体代码结构如图

TrainTicket事件源类

package me.wiliam;
/**
 * 事件源类
 * @author wiliam
 *
 */
public class TrainTicket {
	private String userName;
	
	private String ticketName;

	public String getUserName() {
		return userName;
	}

	public void setUserName(String userName) {
		this.userName = userName;
	}

	public String getTicketName() {
		return ticketName;
	}

	public void setTicketName(String ticketName) {
		this.ticketName = ticketName;
	} 
	

}

TrainTicketEvent购票事件基类

package me.wiliam;

import java.util.EventObject;
/**
 * 购票事件基类
 * @author wiliam
 *
 */
public class TrainTicketEvent extends EventObject {

	
	private static final long serialVersionUID = 1L;

	public TrainTicketEvent(TrainTicket source) {
		super(source);
	}

}

SendEmailEvent发送邮件事件

package me.wiliam;
/**
 * 发送邮件事件
 * @author wiliam
 *
 */
public class SendEmailEvent extends TrainTicketEvent {

	private static final long serialVersionUID = 1L;

	private TrainTicket trainTicket;
	
	public SendEmailEvent(TrainTicket source) {
		super(source);
		this.trainTicket = source;
	}
	
	public TrainTicket getTrainTicket(){
		return trainTicket;
	}
	
	public String getEmailData(){
		if(trainTicket != null){
			String data = "发送邮件："+trainTicket.getUserName() + "您好，您已成功购买火车票"+trainTicket.getTicketName();
			return data;
		}
		return "";
	}

}

SendSMSEvent发送短信事件

package me.wiliam;
/**
 * 发送短信事件
 * @author huhailong
 *
 */
public class SendSMSEvent extends TrainTicketEvent {

	private static final long serialVersionUID = 1L;
	private TrainTicket trainTicket;
	
	public SendSMSEvent(TrainTicket source) {
		super(source);
		this.trainTicket = source;
	}
	
	public TrainTicket getTrainTicket(){
		return trainTicket;
	}
	
	public String getSMSData(){
		if(trainTicket != null){
			String data = "发送短信："+trainTicket.getUserName() + "您好，您已成功购买火车票"+trainTicket.getTicketName();
			return data;
		}
		return "";
	}

}

TrainTicketListener火车票事件监听器接口

package me.wiliam;

import java.util.EventListener;
/**
 * 火车票事件监听器接口
 * @author wiliam
 *
 */
public interface TrainTicketListener extends EventListener {

	void handEvent(TrainTicketEvent tte);
}

EmailAndSMSListener同时处理发送邮件事件和短信事件

package me.wiliam;

/**
 * 同时处理发送邮件事件和短信事件
 * @author wiliam
 *
 */
public class EmailAndSMSListener implements TrainTicketListener {

	@Override
	public void handEvent(TrainTicketEvent tte) {

		if(tte instanceof SendEmailEvent){
			SendEmailEvent see = (SendEmailEvent)tte;
			System.out.println(see.getEmailData());
		}else if(tte instanceof SendSMSEvent){
			SendSMSEvent sse = (SendSMSEvent)tte;
			System.out.println(sse.getSMSData());
		}else{
			System.out.println("发送未知事件，无法处理");
		}
	}

}

config.properties配置文件

#灵活使用监听器，多个可以用逗号间隔
listener=me.wiliam.EmailAndSMSListener

TestBuyTrainTicketSuccessEvent事件测试类

package me.wiliam;

/**
 * 事件测试类
 * @author wiliam
 *
 */
public class TestBuyTrainTicketSuccessEvent {

	public static void main(String[] args) {
		TestBuyTrainTicketSuccessEvent  tbtts = new TestBuyTrainTicketSuccessEvent();
		tbtts.buySuccessTicket();
	}
	
	private void buySuccessTicket(){
		TrainTicket tt = new TrainTicket();
		tt.setTicketName("【北京---济南】");
		tt.setUserName("小明");
		System.out.println("购票成功");
		TrainTicketPublisher.instance().publishEvent(new SendEmailEvent(tt));
		TrainTicketPublisher.instance().publishEvent(new SendSMSEvent(tt));
	}

}

运行上面的测试类，结果如下：

购票成功
发送邮件：小明您好，您已成功购买火车票【北京---济南】
发送短信：小明您好，您已成功购买火车票【北京---济南】

思考

首先如果想要增加其它的监听器，在配置文件中配置下就可以了。
针对上面的事件发布器中对事件监听的处理完全可以单独启动一个线程，一直监听事件队列，有事件消息就处理，这样就可以即时响应各种消息了，解耦一定的程序模块。

代码下载

代码已上传到我的github上:https://github.com/wiliam2015/EventDemo

想了解更多技术文章信息，请继续关注wiliam.s Blog，谢谢，欢迎来访！