面试题：Java中观察者模式在分布式系统消息传递中的角色及简单实现

角色阐述

被观察者：在分布式系统消息传递场景中，被观察者通常是消息的生产者。它负责产生消息，当自身状态发生变化（比如有新的数据产生、某个操作完成等）时，会通知所有注册的观察者。被观察者维护着一个观察者列表，提供注册、移除观察者的方法，并在状态变化时遍历该列表通知观察者。
观察者：观察者是消息的消费者。它们向被观察者注册自己，以便在被观察者状态变化时能接收到通知。接收到通知后，观察者执行相应的操作来处理收到的消息，比如更新自身状态、进行业务逻辑处理等。

代码示例

import java.util.ArrayList;
import java.util.List;

// 被观察者接口
interface Subject {
    void registerObserver(Observer observer);
    void removeObserver(Observer observer);
    void notifyObservers(String message);
}

// 具体被观察者
class ConcreteSubject implements Subject {
    private List<Observer> observers = new ArrayList<>();

    @Override
    public void registerObserver(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifyObservers(String message) {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }

    // 模拟被观察者状态变化
    public void someStateChange(String message) {
        notifyObservers(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 + " 收到消息: " + message);
    }
}

public class ObserverPatternExample {
    public static void main(String[] args) {
        ConcreteSubject subject = new ConcreteSubject();

        ConcreteObserver observer1 = new ConcreteObserver("观察者1");
        ConcreteObserver observer2 = new ConcreteObserver("观察者2");

        subject.registerObserver(observer1);
        subject.registerObserver(observer2);

        subject.someStateChange("新的消息来了！");

        subject.removeObserver(observer2);
        subject.someStateChange("又有新消息了！");
    }
}

星途面试题库

面试题：Java中观察者模式在分布式系统消息传递中的角色及简单实现

知识考点

面试题答案

角色阐述

代码示例