java的事件模式在图形界面领域的事件模式已经有很多文章介绍,但是在服务器端我们会碰到更多的事件模式,在这里给大家总结一下: 事件直接驱动模式 Command模式经常Java的Reflect一起使用,因为系统的事件处理系统是处于动态变化的,随着功能要求扩展,就可能有动态变化事件处理响应系统,以Struts中action为例,我们知道,StrUCts的一个主要配置文件是struts-config.xml 如下: <struts-config> 它实际是个command和event的映射关系,通过这个配置文件,运行时动态装载相应的Action,完成Command模式, 我们检查LoginAction代码,就可以看出Command模式的基本特征: public final class LoginAction extends Action { 很明显,典型的Command模式需要有一个接口.接口中有一个统一的方法,这里统一的方法就是execute; 比如我们有个实时系统,客户段向服务器发出不同编码代号,意味着不同的请求,不同的请求有不同的Handler进行 处理,Handler接口是: public class Handler{ public byte[] handleRequest(); } 不同性质的处理过程继续这个Handler接口,如负责进入系统的处理过程 public class EnterHandler implements Handler{ public byte[] handleRequest(){ } 调用Handler时是: //从cache中获取这个requestId对应的Handler 以上是常用的一个事件驱动模式。它的特点是靠一个事件直接启动对应的事件处理器。 Chain of Responsibility职责链模式也应该属于这类,当事件到达后,让这个事件在我们提供的一批处理器中逐个挑选适合的处理器进行处理,这个模式缺点是显然的,性能丧失在逐个挑选 上,一般不推荐使用,这个模式适合在我们无法预知发生的事件内容时使用,因为不知道发生事件的具体情况, 我们就无法在程序运行前事先为其指派相应的处理器,只能靠运行时,事件自己去摸索“撞运气”。 监控式事件模式 应用客户端有三种与观察者交互的方式:1.直接融合 2.推方式 3.拉方式。 直接融合就是说应用客户端自己就是观察者,两者融合,这样无疑应用客户端获得的触发时间是最快的; 推方式就是观察者一旦侦测到事件发生,立即将事件Push推到应用客户端;拉方式类似收取邮件,应用客户端在需要时才从观察者拉取事件。 JDK 1.4的None Blocking I/O是监控式事件模式的典型实现,Selector显然是一个监控I/O的第三者,当有外部事件进来,通过 调用Slector.select方法可以获得外部事件,从而进行处理,可参考我的本栏文章。 监控式事件模式适合使用在触发性质的场合,比如数据库后端触发器 界面触发 I/O触发 状态改变触发等。 我们以一个信件触发为例,这其实是个Observer应用例子: 比如用户提请服务器计算一个数据,假如用户同时要求将计算结果向自己信箱发一封,那么我们看如何设计? 按照通常思维,这是一个次序问题,先在内存中计算数据,然后将结果发送到他的信箱,最后返回结果到用户端, 我们知道信件的发送是耗时的,因此,有可能网络的原因造成信件发送很慢,这是用户就一直等不到他的计算结果, 很显然,我们使用监控式事件模式来解决,让发信的事件由监控者去完成,只要需要时触发就可以了: public class Computer extends Observable{ public Computer(){ .......
//计算操作 if (needEmail){ //设置变化点 } } 我们再来看监控观察者代码是如何写的? public class sendMailObserver implements Observer{ public void update(Observable obj,Object email){ if (email instanceof String){ sendMail(email); } } }
既然事件处理模式是众多应用系统的基本模式,那么应该可以形成一个框架标准,JMX的notification Model就是这样一个架构设计。 JMX Notification Model JMX Notification Model答应MBean通过调用notifications广播事件,接受者只要注册为一个listerner, JMX的 MBean notification model 将会激活这个listerner注册一次,然后将一直接受到 来自广播者发出的各种事件。 事件模式有三个角色,第一个是事件发出者producer 然后是事件接受者Consumer,第三个 是要传输的事件。JMX notification model也是这样分别依靠下列组件来实现这三个角色: A. NotificationBroadcaster接口, 事件广播发出者, 这个接口答应监听者在需要发出的notification中注册他们感爱好的事件。 只要是MBean,就既可以成为notification的发布广播者,也可以成为notification的监听者接受者,或者同时两者都可以。 Attribute Change Notifications 在JMX架构中,MBean能够在属性attribute变化发生时,发出通知,关于诊断属性变化的机制以及触发 通知事件并不属于JMX规定部分,每个MBean可以有自己独立的实现方式。 Timer Service Monitoring 当derived gauge值满足一系列条件时,每个monitor server将会发出一个特定类型的通知。 这些条件都是在monitor被初始化时设定的,也可以通过monitor MBean的治理接口动态设定。 根据MBean内部属性值类型有三种monitor: A.CounterMonitor - 使用Java的整数类型来观察属性,有一个行为特征: B.GaugeMonitor - 使用java的整数或浮点类型观察属性。象gauge(测量仪器) 要么上升 要么下降减少。 C StringMonitor - 使用String类型观察属性. 事件处理架构
从上面JMS的架构图可以看出事件三个角色Producer和Consumer以及事件信息本身Message.JMS就是在Producer和Consumer之间建立一个连接Connection. JMS可实现同步或异步的事件触发机制,分别是通过Poin to Point(拉方式)和Pubilsh/Subscibe(推方式)具体完成,在分布式计算环境中,异步机制是非常重要,可以起到解耦作用,因为分布环境中单点错误或通讯问题是经常发生的,整个分布式系统不能总是依靠同步机制来可靠地传递事件或notification. 由此可见,事件处理模式从Java诸多架构到我们具体应用程序,随处可见,根据不同的应用需求选择不同的事件处理模式,才能真正挖掘Java的潜在性能。 (责任编辑:admin) |