java中的事件机制的参与者有3种角色:
1.event object:就是事件产生时具体的“事件”,用于listener的相应的方法之中,作为参数,一般存在与listerner的方法之中
2.event source:具体的接受事件的实体,比如说,你点击一个button,那么button就是event source,这样你必须使button对某些事件进行相应,你就需要注册特定的listener,比如说MouseEvent之中的MouseClicked方法,这是他就必须有了add方法
3.event listener:具体的对监听的事件类,当有其对应的event object产生的时候,它就调用相应的方法,进行处理。在windows程序设计里边这种相应使用callback机制来实现的
先看看jdk提供的event包:
public interface EventListener:所有事件侦听器接口必须扩展的标记接口。
public class EventObject extends Object implements Serializable所有事件状态对象都将从其派生的根类。 所有 Event 在构造时都引用了对象 "source",在逻辑上认为该对象是最初发生有关 Event 的对象。
在Java2处理事件时,没有采用dispatchEvent()-postEvent()-handleEvent()方式,采用了监听器类,每个事件类都有相关联的监听器接口。事件从事件源到监听者的传递是通过对目标监听者对象的Java方法调用进行的。 对每个明确的事件的发生,都相应地定义一个明确的Java方法。这些方法都集中定义在事件监听者(EventListener)接口中,这个接口要继承 java.util.EventListener。
实现了事件监听者接口中一些或全部方法的类就是事件监听者。 伴随着事件的发生,相应的状态通常都封装在事件状态对象中,该对象必须继承自java.util.EventObject。事件状态对象作为单参传递给应响应该事件的监听者方法中。发出某种特定事件的事件源的标识是:遵从规定的设计格式为事件监听者定义注册方法,并接受对指定事件监听者接口实例的引用。 开始之前首先问个问题:您熟悉java.util.EventObject 和java.util.EventListener两个类以及他们已有的子类吗?
如果你已经能够熟练使用jdk为我们提供的事件监听器,并且很熟悉MouseEvent, KeyEvent, WindowEvent等等这些jdk为我们准备好的事件,那么想必你对java的事件机制已经有所理解。但是也许你还是觉得虽然用起来没什么问题,但是原理还是有些糊涂,那么下面我们再进一步自己实现这些事件和监听器,我们把这个取名为自定义事件。 其实自定义事件在java中很有用处,我们有的时候想让自己的程序产生一个事件,但有不希望(或者不可能)用鼠标,键盘之类的输入设备进行操作,比如你写一个应用程序,在这个程序中一旦收到邮件就对邮件进行相关处理,对于“收到邮件”这个事件,jdk中就没有定义。对于这样的事件,以及对于这样的事件的监听器,我们只能自己动手完成了。
其实呢,java事件处理机制就是观察者模式,我这里详细的整理一下,在并发编程中,动不动就给某一个主题注册一个监听,然后当主题状态发生变化的时候,监听就会被触发。好了,废话不多说了,我贴出几篇代码好了。
第一步:
/**
*
*/
package test; /**
* @author LinkinPark
* @date 2015年8月31日 下午3:07:34
* @Description:
* 前面我已经整理了观察者模式,这里对照这个设计模式来整理下java事件
* 这里先写个最简单的模拟
*/
public class Util
{ public static void main(String[] args)
{
// 首先初始化一个被观察者,然后在初始化一个观察者
// 然后将观察者绑定到被观察者上面,然后使用被观察者看看观察者里面的事件有没有被触发
Observable observable = new Observable();
Observer observer = new Observer();
observable.setObserver(observer);
observable.test();//事件被成功的触发了
} } //这个模拟被观察者
class Observable
{
//绑定到被观察者上面的观察者
private Observer observer; //被观察者对外面提供的操作
public void test()
{
observer.test();
} public Observer getObserver()
{
return observer;
} public void setObserver(Observer observer)
{
this.observer = observer;
}
} // 这个模拟观察者
class Observer
{
// 这个模拟事件
public void test()
{
System.out.println("这里就是事件。。。");
}
}
第二步:
/**
*
*/
package test; import java.util.ArrayList;
import java.util.List; /**
* @author LinkinPark
* @date 2015年8月31日 下午3:07:34
* @Description:
* 现在在原来的基础上稍微复杂一点,现在不在被观察者身上只绑一个观察者了。
* 现在绑定多个观察者。
*/
public class Util
{ public static void main(String[] args)
{
// 首先初始化一个被观察者,然后在初始化2个观察者
// 然后将观察者绑定到被观察者上面,然后使用被观察者看看观察者里面的事件有没有被触发
Observable observable = new Observable();
Observer observer1 = new Observer();
Observer observer2 = new Observer();
observable.registObserver(observer1);
observable.registObserver(observer2);
//调用外部事件,看看观察者里面的事件执行了没有
observable.notifyObserver("被观察者触发了操作了呢");
} } // 这个模拟被观察者
class Observable
{
// 绑定到被观察者上面的观察者
private List<Observer> observers = new ArrayList<Observer>(); // 添加一个观察者到被观察者身上
public void registObserver(Observer observer)
{
observers.add(observer);
} // 从绑定的观察者集合中去掉当前这个
public void removeObserver(Observer observer)
{
observers.remove(observer);
} // 定义外部执行
public void notifyObserver(String str)
{
for (Observer observer : observers)
{
observer.test(str);
}
} } // 这个模拟观察者
class Observer
{
// 这个模拟事件
public void test(String str)
{
System.out.println("这里就是事件-->" + str);
}
}
第三步:
/**
*
*/
package test; import java.util.ArrayList;
import java.util.List; /**
* @author LinkinPark
* @date 2015年8月31日 下午3:07:34
* @Description:
* 现在在原来的基础上稍微复杂一点,现在不在被观察者身上只绑一个观察者了。
* 现在绑定多个观察者。现在在稍微复杂一点,观察者和被观察者都面向接口编程,里面提供多个实现
*/
public class Util
{ public static void main(String[] args)
{
// 首先初始化一个被观察者,然后在初始化2个观察者
// 然后将观察者绑定到被观察者上面,然后使用被观察者看看观察者里面的事件有没有被触发
Iobservable observable = new Observable();
Iobserver observer = new Observer();
Iobserver observer1 = new Observer1();
observable.registObserver(observer);
observable.registObserver(observer1);
// 调用被观察者的外部事件,看看观察者里面的事件执行了没有
observable.notifyObserver("被观察者触发了操作了呢");
} } // 被观察者对外提供的接口,其实这里定义成抽象类,也就是模板好一点。
interface Iobservable
{
// 绑定到被观察者上面的观察者
public List<Iobserver> observers = new ArrayList<Iobserver>(); // 添加一个观察者到被观察者身上
void registObserver(Iobserver observer); // 从绑定的观察者集合中去掉当前这个
void removeObserver(Iobserver observer); // 定义外部执行
public void notifyObserver(String str);
} // 观察者对外提供的接口。
interface Iobserver
{
// 这个模拟事件
public void test(String str);
} // 这个模拟被观察者
class Observable implements Iobservable
{ public void registObserver(Iobserver observer)
{
observers.add(observer);
System.out.println("这里添加一个被观察者-->" + observer.getClass());
} public void removeObserver(Iobserver observer)
{
observers.remove(observer);
System.out.println("这里溢出一个被观察者-->" + observer.getClass());
} public void notifyObserver(String str)
{
for (Iobserver observer : observers)
{
observer.test(str);
}
} } // 这个模拟观察者0
class Observer implements Iobserver
{
public void test(String str)
{
System.out.println("这里就是Observer事件-->" + str);
}
} // 这个模拟观察者1
class Observer1 implements Iobserver
{
public void test(String str)
{
System.out.println("这里就是Observer1事件-->" + str);
}
}
第四步:
/**
*
*/
package test; import java.util.ArrayList;
import java.util.List; /**
* @author LinkinPark
* @date 2015年8月31日 下午3:07:34
* @Description:
* 现在在原来的基础上稍微复杂一点,现在不在被观察者身上只绑一个观察者了。
* 现在绑定多个观察者。现在在稍微复杂一点,观察者和被观察者都面向接口编程,里面提供多个实现。
* 最后现在提供一个最完美的观察者模式,其实和我前面那篇博客写的差不多
*/
public class Util
{ public static void main(String[] args)
{
// 首先初始化一个被观察者,然后在初始化2个观察者
// 然后将观察者绑定到被观察者上面,然后使用被观察者看看观察者里面的事件有没有被触发
Iobservable observable = new Observable();
Iobserver observer = new Observer();
Iobserver observer1 = new Observer1();
observable.registObserver(observer);
observable.registObserver(observer1);
// 调用被观察者的外部事件,看看观察者里面的事件执行了没有
System.out.println("===========华丽丽的分割线=============");
observable.notifyObserver("LinkinPark...");
} } // 被观察者对外提供的接口,其实这里定义成抽象类,也就是模板好一点。
abstract class Iobservable
{
// 绑定到被观察者上面的观察者
public List<Iobserver> observers = new ArrayList<Iobserver>(); // 添加一个观察者到被观察者身上
abstract void registObserver(Iobserver observer); // 从绑定的观察者集合中去掉当前这个
abstract void removeObserver(Iobserver observer); // 通知给观察者,让其开始做相关处理
public void notifyObserver(String str)
{
for (Iobserver observer : observers)
{
observer.test(str);
}
} } // 观察者对外提供的接口。
interface Iobserver
{
// 这个模拟事件
public void test(String str); } // 这个模拟被观察者
class Observable extends Iobservable
{ private String name; public String getName()
{
return name;
} // 在给这个被观察者重新设值name的时候,也就说现在观察者状态发生改变了,那么就要通知给观察者,让他也来做相关的处理
public void setName(String name)
{
this.name = name;
notifyObserver(name);
} public void registObserver(Iobserver observer)
{
observers.add(observer);
System.out.println("这里添加一个被观察者-->" + observer.getClass());
} public void removeObserver(Iobserver observer)
{
observers.remove(observer);
System.out.println("这里移除一个被观察者-->" + observer.getClass());
} } // 这个模拟观察者0
class Observer implements Iobserver
{ public Observer()
{
System.out.println("Observer:观察者原来的name-->" + getName());
} private String name = "Observer"; public String getName()
{
return name;
} public void setName(String name)
{
this.name = name;
} public void test(String str)
{
System.out.println("Observer:原来的name-->" + getName());
setName(str);
System.out.println("被观察者状态改变后本地的同步name-->" + getName());
}
} // 这个模拟观察者1
class Observer1 implements Iobserver
{
public Observer1()
{
System.out.println("Observer1:观察者原来的name-->" + getName());
} private String name = "Observer1"; public String getName()
{
return name;
} public void setName(String name)
{
this.name = name;
} public void test(String str)
{
System.out.println("Observer1:原来的name-->" + getName());
setName(str);
System.out.println("被观察者状态改变后本地的同步name-->" + getName());
}
}
最后一步:java事件监听了呢。
package test; import java.util.ArrayList;
import java.util.EventListener;
import java.util.EventObject;
import java.util.Iterator;
import java.util.List; /**
* @author LinkinPark
* @date 2015年9月1日 下午1:46:52
* @Description: java事件监听机制
*/
public class Linkin
{
// 初始化主题-->被观察者
DemoSource source = new DemoSource();
// 初始化监听-->观察者
DemoListener Listener1 = new Listener1();
DemoListener Listener2 = new Listener2(); public Linkin()
{
source.addDemoListener(Listener1).addDemoListener(Listener2).addDemoListener(new DemoListener()
{
@Override
public void demoEvent(DemoEvent demoEvent)
{
System.out.println("匿名内部类收到主题推送-->" + demoEvent.getSource().getClass());
}
});
System.out.println("主题原来的状态-->" + name);
} private String name = "nameOld"; /**
* @return the name
*/
public String getName()
{
return name;
} /**
* @param name the name to set
*/
public void setName(String name)
{
this.name = name;
System.out.println("主题现在的状态-->" + name);
source.notifyDemoEvent();
} public static void main(String[] args)
{
new Linkin().setName("nameNew");
}
} // 就是事件产生时具体的“事件”,用于listener的相应的方法之中,作为参数,一般存在与listerner的方法之中
class DemoEvent extends EventObject
{
private static final long serialVersionUID = 1L;
Object obj; public DemoEvent(Object source)
{
super(source);
obj = source;
} public Object getSource()
{
return obj;
} } // 具体的对监听的事件类,当有其对应的event object产生的时候,它就调用相应的方法,进行处理。
interface DemoListener extends EventListener
{
void demoEvent(DemoEvent demoEvent);
} // 这个相当于观察者
class Listener1 implements DemoListener
{ @Override
public void demoEvent(DemoEvent demoEvent)
{
System.out.println("Listener1监听收到了主题的推送消息" + demoEvent.getSource());
}
} // 这个相当于观察者
class Listener2 implements DemoListener
{ @Override
public void demoEvent(DemoEvent demoEvent)
{
System.out.println("Listener2监听收到了主题的推送消息" + demoEvent.getSource());
}
} // 具体的接受事件的实体,也就是观察者模式中的被观察者。比如说,你点击一个button,那么button就是event source,
// 这样你必须使button对某些事件进行相应,你就需要注册特定的listener,比如说MouseEvent之中的MouseClicked方法,这是他就必须有了add方法
class DemoSource
{
private List<Object> repository = new ArrayList<Object>();
DemoListener dl; public DemoSource()
{
} // 添加监听
public DemoSource addDemoListener(DemoListener dl)
{
repository.add(dl);
return this;
} // 状态改变被触发
public void notifyDemoEvent()
{
Iterator<Object> it = repository.iterator();
while (it.hasNext())
{
dl = (DemoListener) it.next();
dl.demoEvent(new DemoEvent(this));
}
}
}