使用泛型的观察者模式过于通用



我在Java中使用泛型实现了一个简单的观察者模式。

无论如何,现在这个例子之所以有效,只是因为ConcreteObserver的update方法是用所有对象通用的.toString()方法实现的。

在现实世界中,ConcreteObserver只对特定类型的数据进行操作。例如,如果我的ConcreteObserver是一个播放器,它可以播放.mp3或.avi,但不能播放.doc.

哪种方法是"强制"特定类型的数据作为Observer和Observable之间的契约传递泛型太通用了。。。

在方法签名的情况下,我可以使用Interfaces强制实现特定签名。

哪种方式可以强制传递特定的数据类型

例如:我想要一种由以下组成的数据:

  • 字符串
  • int(下一个二进制数据块的长度(
  • a二进制数据块
  • 二进制块的某种元数据描述符

我希望这种数据接口是唯一允许的。


这是我使用泛型的代码。

public interface Observable<T> {
public void add(Observer<T> observer);
public void remove(Observer<T> observer);
public void sendNotify(T notification);
}
public class ConcreteObservable<T> implements Observable<T> {
ArrayList<Observer<T>> observerList = new ArrayList<>();
public void add(Observer<T> observer){
observerList.add(observer);
}
public void remove(Observer<T> observer) {
observerList.remove(observer);
}
public void sendNotify(T notification) {
for (Observer observer : observerList) {
observer.update(notification);
}
}
}

public interface Observer<T> {
public void update(T value);
}
public class ConcreteObserver<T> implements Observer<T> {
@Override
public void update(T value) {
System.out.println(value.toString()); 
}
}
public static void main(String[] args) {
ConcreteObservable observable = new ConcreteObservable();
ConcreteObserver observer = new ConcreteObserver();
observable.add(observer);
int value = 5;
observable.sendNotify(value);
String string = "Test";
observable.sendNotify(string);      
}
ConcreteObservable observable = new ConcreteObservable();
ConcreteObserver observer = new ConcreteObserver();

这里的问题是您使用的是原始类型:您省略了observerobservable上的类型参数。

添加类型参数。例如,如果指定Integer,则无法传递String参数:

ConcreteObservable<Integer> observable = new ConcreteObservable<>();
ConcreteObserver<Integer> observer = new ConcreteObserver<>();
observable.add(observer);       // Fine.
int value = 5;
observable.sendNotify(value);   // Fine.
String string = "Test";
observable.sendNotify(string);  // Error!

IDE或编译会警告您使用原始类型:请注意它们(代码中还有其他原始类型(。


此外,请注意,您可以在Observable<T>接口及其实现中使用Observer<? super T>而不是Observer<T>。这使API更加灵活,因此您可以使用Observer<Object>(它将接受sendNotifyInteger参数(,而不仅仅是Observer<Integer>

最新更新