JAVA观察者模式-案例

怼烎@ 2024-03-27 19:24 79阅读 0赞

## Java观察者模式 ##

import java.util.ArrayList;  
    import java.util.List;  
      
    // 主题接口，定义了添加、删除观察者等方法  
    interface Subject {
          
        void register(Observer observer);  
        void unregister(Observer observer);  
        void notifyObservers(String message);  
    }  
      
    // 具体主题类，实现了主题接口，并维护了一个观察者列表  
    class ConcreteSubject implements Subject {
          
        private List<Observer> observers = new ArrayList<>();  
        private String message;  
      
        @Override  
        public void register(Observer observer) {
          
            observers.add(observer);  
        }  
      
        @Override  
        public void unregister(Observer observer) {
          
            observers.remove(observer);  
        }  
      
        @Override  
        public void notifyObservers(String message) {
          
            this.message = message;  
            for (Observer observer : observers) {
          
                observer.update(message);  
            }  
        }  
    }  
      
    // 观察者接口，定义了观察者更新方法  
    interface Observer {
          
        void update(String message);  
    }  
      
    // 具体观察者类，实现了观察者接口，并实现了更新方法  
    class ConcreteObserver implements Observer {
          
        private String name;  
      
        public ConcreteObserver(String name) {
          
            this.name = name;  
        }  
      
        @Override  
        public void update(String message) {
          
            System.out.println(name + " received message: " + message);  
        }  
    }  
      
    // 测试类，创建主题和观察者对象，并测试通知功能  
    public class Test {
          
        public static void main(String[] args) {
          
            Subject subject = new ConcreteSubject();  // 创建主题对象  
            Observer observer1 = new ConcreteObserver("Observer 1");  // 创建观察者1对象  
            Observer observer2 = new ConcreteObserver("Observer 2");  // 创建观察者2对象  
            subject.register(observer1);  // 主题添加观察者1  
            subject.register(observer2);  // 主题添加观察者2  
            subject.notifyObservers("Hello World!");  // 主题通知所有观察者更新，输出"Observer 1 received message: Hello World!"和"Observer 2 received message: Hello World!"  
            subject.unregister(observer1);  // 主题移除观察者1，此时只有观察者2存在，通知输出"Observer 2 received message: Hello World!"  
            subject.notifyObservers("Hello Java!");  // 主题通知所有观察者更新，只有观察者2收到了消息，输出"Observer 2 received message: Hello Java!"。由于移除了观察者1，因此没有输出"Observer 1 received message: Hello Java!"。  
        }  
    }