工具
1、java编程环境
2、电脑
创建一个java工程,建一个观察者的包com.djxy5101.observers
创建观察者接口
//观察者接口
public interface IObserver {
//处理被观察者发送来的信息
void handleNotify(String message);
}
定义一号观察者FirstObserver
//定义一号观察者
public class FirstObserver implements IObserver {
@Override
public void handleNotify(String message) {
System.out.println("一号观察者接收到消息【" + message + "】,正在处理消息。。。");
}
}
和二号观察者SecondObserver
//定义二号观察者
public class SecondObserver implements IObserver{
@Override
public void handleNotify(String message) {
System.out.println("二号观察者接收到消息【" + message + "】,正在处理消息。。。");
}
}
到这里就完成了观察者的定义,在创建被观察者包com.djxy5101.observerable
编写被观察者接口IObserverable
//被观察者接口,即“可被观察的”接口
public interface IObserverable {
//添加观察者
void addObserver(IObserver observer);
//删除观察者
void removeObserver(IObserver observer);
//向观察者发送信息
void notifyObservers(String message);
}
定义被观察者Some
//定义被观察者
public class Some implements IObserverable {
//声明观察者集合
private List<IObserver> observers;
public Some() {
//在被观察者对象创建的同时,就像观察者集合创建
observers = new ArrayList<>();
}
@Override
public void addObserver(IObserver observer) {
observers.add(observer);
}
@Override
public void removeObserver(IObserver observer) {
observers.remove(observer);
}
@Override
public void notifyObservers(String message) {
//通知每一个观察者
for (IObserver observer : observers
) {
observer.handleNotify(message);
}
}
}
创建测试类来测试一下结果
public class MyTest {
public static void main(String[] args) {
//创建多个观察者
IObserver first = new FirstObserver();
IObserver second = new SecondObserver();
//创建被观察者
Some some = new Some();
//被观察者添加观察者
some.addObserver(first);
some.addObserver(second);
//被观察者向所有观察者发送消息
some.notifyObservers("全体注意,出发!");
System.out.println("============================");
//被观察者删除制定的观察者
some.removeObserver(first);
//被观察者向所有观察者发送消息
some.notifyObservers("全体注意,出发!");
}
}