Java中如何创建Observer

在Java中，创建一个观察者（Observer）通常涉及到实现java.util.Observer接口和java.util.Observable类。但是，从Java 9开始，Observable和Observer已经被标记为过时（deprecated），推荐使用新的观察者模式实现，即基于java.beans包中的PropertyChangeListener和PropertyChangeSupport，或者使用第三方库如RxJava。

下面是使用Observable和Observer的示例：

1. 创建一个观察者类，实现Observer接口：

import java.util.Observer;
import java.util.Observable;

public class MyObserver implements Observer {
    @Override
    public void update(Observable o, Object arg) {
        System.out.println("观察者收到通知: " + arg);
    }
}

2. 创建一个被观察者类，继承Observable类：

import java.util.Observable;

public class MyObservable extends Observable {
    public void doSomething() {
        // ...执行一些操作
        setChanged(); // 标记状态已改变
        notifyObservers("这是通知信息"); // 通知观察者
    }
}

3. 在主程序中使用观察者和被观察者：

public class Main {
    public static void main(String[] args) {
        MyObservable myObservable = new MyObservable();
        MyObserver myObserver = new MyObserver();

        myObservable.addObserver(myObserver); // 将观察者添加到被观察者
        myObservable.doSomething(); // 触发通知
    }
}

如果你使用的是Java 9或更高版本，可以考虑使用PropertyChangeListener和PropertyChangeSupport：

1. 创建一个观察者类，实现PropertyChangeListener接口：

import java.beans.PropertyChangeEvent;
import java.beans.PropertyChangeListener;

public class MyPropertyChangeListener implements PropertyChangeListener {
    @Override
    public void propertyChange(PropertyChangeEvent evt) {
        System.out.println("属性值发生变化: " + evt.getPropertyName() + ", 旧值: " + evt.getOldValue() + ", 新值: " + evt.getNewValue());
    }
}

2. 创建一个被观察者类，使用PropertyChangeSupport：

import java.beans.PropertyChangeListener;
import java.beans.PropertyChangeSupport;

public class MyPropertyChangeSupport {
    private final PropertyChangeSupport support;

    public MyPropertyChangeSupport() {
        support = new PropertyChangeSupport(this);
    }

    public void addPropertyChangeListener(PropertyChangeListener pcl) {
        support.addPropertyChangeListener(pcl);
    }

    public void removePropertyChangeListener(PropertyChangeListener pcl) {
        support.removePropertyChangeListener(pcl);
    }

    public void doSomething() {
        // ...执行一些操作
        support.firePropertyChange("propertyName", oldValue, newValue); // 触发通知
    }
}

3. 在主程序中使用观察者和被观察者：

public class Main {
    public static void main(String[] args) {
        MyPropertyChangeSupport myPropertyChangeSupport = new MyPropertyChangeSupport();
        MyPropertyChangeListener myPropertyChangeListener = new MyPropertyChangeListener();

        myPropertyChangeSupport.addPropertyChangeListener(myPropertyChangeListener); // 将观察者添加到被观察者
        myPropertyChangeSupport.doSomething(); // 触发通知
    }
}

如果你想使用RxJava，可以参考相关文档和教程来了解如何创建和使用观察者。