``` // Subject 主题接口 public interface Subject { public void registerObserver(Observer o); public void removeObserver(Observer o); public void notifyAllObservers(); } // 观察者接口 public interface Observer { public void update(Subject s); } // 视频网站某狐实现 Subject 接口 public class VideoSite implements Subject{ // 观察者列表以及更新了的视频列表 private ArrayList userList; private ArrayList videos; public VideoSite(){ userList = new ArrayList(); videos = new ArrayList(); } @Override public void registerObserver(Observer o) { userList.add(o); } @Override public void removeObserver(Observer o) { userList.remove(o); } @Override public void notifyAllObservers() { for (Observer o: userList) { o.update(this); } } public void addVideos(String video) { this.videos.add(video); notifyAllObservers(); } public ArrayList getVideos() { return videos; } public String toString(){ return videos.toString(); } } // 实现观察者，即看视频的美剧迷们 public class VideoFans implements Observer { private String name; public VideoFans(String name){ this.name = name; } @Override public void update(Subject s) { System.out.println(this.name + ", new videos are available! "); // print video list System.out.println(s); } } // 测试一下 public class Main { public static void main(String[] args) { VideoSite vs = new VideoSite(); vs.registerObserver(new VideoFans("LiLei")); vs.registerObserver(new VideoFans("HanMeimei")); vs.registerObserver(new VideoFans("XiaoMing")); // add videos vs.addVideos("Video 1"); //vs.addVideos("Video 2"); } } ``` ##实现原理 ####一 ``` interface Subject { public void registerObserver(Observer o); public void removeObserver(Observer o); public void notifyAllObservers(); } ``` 建一个接口，给网站用的，至于干嘛就不多说了，看里头仨方法的字面意思都知道干嘛的 ``` // 观察者接口 interface Observer { public void update(Subject s); } ``` 然后，建立观察者接口，里头搁个更新推送的方法 ####二 class VideoSite implements Subject{ // 观察者列表以及更新了的视频列表 private ArrayList userList; private ArrayList videos; public VideoSite(){ userList = new ArrayList(); videos = new ArrayList(); } @Override public void registerObserver(Observer o) { userList.add(o); } @Override public void removeObserver(Observer o) { userList.remove(o); } @Override public void notifyAllObservers() { for (Observer o: userList) { o.update(this); } } public void addVideos(String video) { this.videos.add(video); notifyAllObservers(); } public ArrayList getVideos() { return videos; } public String toString(){ return videos.toString(); } } 建立一个实现Subject接口类的VIdeoSite类里头先定义俩列表userList和videos，在构造函数里头初始化他们 rigister的时候添加一个Observer进userList里头，remove时就remove一个。 ``` class VideoSite implements Subject{ // 观察者列表以及更新了的视频列表 private ArrayList userList; private ArrayList videos; public VideoSite(){ userList = new ArrayList(); videos = new ArrayList(); } @Override public void registerObserver(Observer o) { userList.add(o); } @Override public void removeObserver(Observer o) { userList.remove(o); } ``` notify里头是，遍历以便userlist，然后让list里的每个Observer都update一下 ``` @Override public void notifyAllObservers() { for (Observer o: userList) { o.update(this); } } ``` 添加视屏的时候，把实参那个字符串add到videolist里，然后再notify。 public void addVideos(String video) { this.videos.add(video); notifyAllObservers(); } ####三 ``` // 实现观察者，即看视频的美剧迷们 class VideoFans implements Observer { private String name; public VideoFans(String name){ this.name = name; } @Override public void update(Subject s) { System.out.println(this.name + ", new videos are available! "); // print video list System.out.println(s); } } ``` 一个连接Observer接口的类，里头定义个String，构造函数里初始化它，构造函数将创建对象时的实参String赋值给类内的String，以便类内的update在用String的时候用的是创建新对象时要用到的String```new VideoFans("LiLei")```。update的逻辑就不多说了 ####总结 ``` // 测试一下 public class Main { public static void main(String[] args) { VideoSite vs = new VideoSite(); vs.registerObserver(new VideoFans("LiLei")); vs.registerObserver(new VideoFans("HanMeimei")); vs.registerObserver(new VideoFans("XiaoMing")); // add videos vs.addVideos("Video 1"); //vs.addVideos("Video 2"); } } ``` 建一个VideoSite 对象，由于VideoSite 类实现了Subject接口并重写了Subject内的三个方法```registerObserver()```，```removeObserver()```，```notifyAllObservers()```，所以这个对象就可以调用这些方法并传入需要用的相应参数。而前两个方法的参数都是Observer类型的对象，且update这个方法是Observer下的，也就是实现了Observer接口的VideoFans类的对象才能用update。那么我们就把VideoFans对象（它就相当于是个Observer对象）传入registerObserver(Observer o)的参数里，然后在这个方法内，把这个对象add到实现创建好的VideoSite类下的Observer类的userList里。然后再在```notifyAllObservers()```类里遍历一遍这个userList，然后挨个调动Observer类的update方法（这个方法内就是输出一些文字什么的）。这样的话还不够，因为要实现的是添加了个视频就向所有用户更新消息，那么向所有用户更新消息的方法建好了，谁来调用他们呢？这时就需要添加视频的方法addVideos上场了。```VideoSite.addVideos("Video 1");```，addVideos内的逻辑时把他的参数（要添加新视频的那个视频名,String类型），add到事先VideoSite类内建好的String类型的videolist里。add完之后，就直接调用上一段提到的```notifyAllObservers()```方法，这样的话，就实现了：先建个视频网站，网站内注册几个用户，更新视频时向所有用户推送消息的功能。（说的有些啰嗦，结合着代码看）

“Java 设计模式详解”实验报告