首先 打开开发工具 在里面 我们创建一个项目

为了 方便 我们直接下载一个Spring项目

配置一下基本信息 然后点Next

这边 Spring Boot版本尽量选在2.几左右 然后点击 Finish

然后 我们的一个项目就出来啦

我们打开刚创建的项目 找到src下的 main 下的 java 下的com.example.springapiweb

在下面创建一个包 叫 javaReactor8
在 javaReactor8包下创建一个类 叫 ObserverDemc
参考代码如下

package com.example.springapiweb.javaReactor8;import java.util.Observable;public class ObserverDemc extends Observable {public static void main(String args[]) {ObserverDemc observer = new ObserverDemc();observer.addObserver((o, arg) -> {System.out.println("发生了变化");});}
}

我们这里定义了自己的一个对象 ObserverDemc
然后通过addObserver给ObserverDemc 对象加上观察者监听
然后 我们运行代码如下

可以看到 控制台其实什么都没有 因为我们并没有发生变化 所以监听没有被触发

我们在 main 方法最后面加上两行代码

observer.setChanged(); //最据变化
observer.notifyObservers(); //通知

这里 我们直接手动变化并通知
运行结果如下

这时 我们的观察者就观察到了变化

简单理解 响应式变成就是 数据流改变时进行通知做出其他处理的编程模式

同时 一个对象也不一定只有一个观察者
将ObserverDemc类代码修改如下

package com.example.springapiweb.javaReactor8;import java.util.Observable;public class ObserverDemc extends Observable {public static void main(String args[]) {ObserverDemc observer = new ObserverDemc();observer.addObserver((o, arg) -> {System.out.println("发生了变化");});observer.addObserver((o, arg) -> {System.out.println("我也监听到了变化");});observer.setChanged(); //最据变化observer.notifyObservers(); //通知}
}

这里 我们就又加了一个观察者 运行结果如下

这样呢 我们两个观察者就都发现了