Kotlin 设计模式：简化观察者模式

用户4235284

发布于 2024-02-29 09:02:50

850

发布于 2024-02-29 09:02:50

文章被收录于专栏：后端学习之道后端学习之道

观察者模式是一种行为设计模式，其中对象（主体）维护其依赖者（观察者）的列表，并自动通知它们任何状态更改。

此模式可确保在发生某些状态更改时通知多个对象。它广泛用于实现分布式事件处理系统。

观察者模式将主体与其观察者解耦，并允许动态添加或删除观察者。

Java 中的方法

让我们设计一个在温度变化时发送通知,让显示屏对应做出变化的气象站。Java示例如下：

// Observer Interface:
public interface Observer {
    void update(float temperature);
}

// Subject Interface:
public interface Subject {
    void registerObserver(Observer o);
    void removeObserver(Observer o);
    void notifyObservers();
}

// Concrete Subject:
public class WeatherStation implements Subject {
    private float temperature;
    private List<Observer> observers = new ArrayList<>();

    public void setTemperature(float temperature) {
        this.temperature = temperature;
        notifyObservers();
    }

    public void registerObserver(Observer o) {
        observers.add(o);
    }

    public void removeObserver(Observer o) {
        observers.remove(o);
    }

    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(temperature);
        }
    }
}

// Concrete Observer:
public class Display implements Observer {
    private String displayId;

    public Display(String id) {
        this.displayId = id;
    }

    public void update(float temperature) {
        System.out.println(displayId + ": Temperature updated: " + temperature);
    }
}

// Client:
public class WeatherApp {
    public static void main(String[] args) {
        WeatherStation station = new WeatherStation();
        Display display1 = new Display("Display 1");
        Display display2 = new Display("Display 2");

        station.registerObserver(display1);
        station.registerObserver(display2);
        station.setTemperature(30f);
    }
}

在此Java示例中，WeatherStation是Subject，Display是在温度变化时更新的观察者。当站点温度发生变化时，两者都会显示display1并display2收到通知 ( )。update(float temperature)

Java 8+ 中的函数式方法

您可以使用Java 8+ 函数式特性来简化观察者模式，并使用函数式接口和 Java 的 lambda 表达式实现非常相似的方法。

以下是如何调整的示例：

import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;

public class WeatherStation {
    private float temperature;
    private List<Consumer<Float>> onTemperatureChangeListeners = new ArrayList<>();

    public void setTemperature(float temperature) {
        this.temperature = temperature;
        notifyTemperatureChange(temperature);
    }

    private void notifyTemperatureChange(float newTemperature) {
        onTemperatureChangeListeners.forEach(listener -> listener.accept(newTemperature));
    }

    public void onTemperatureChange(Consumer<Float> listener) {
        onTemperatureChangeListeners.add(listener);
    }
}

// Usage:
WeatherStation station = new WeatherStation();

// Registering listeners using lambda expressions:
station.onTemperatureChange(temp -> System.out.println("Display 1: Temperature updated to " + temp));
station.onTemperatureChange(temp -> System.out.println("Display 2: Temperature updated to " + temp));

// Simulating a temperature change:
station.setTemperature(30f);

在这个Java示例中：

该类WeatherStation维护一个对象列表Consumer<Float>，这些对象是 Java 中可与 lambda 表达式一起使用的函数接口。
该onTemperatureChange方法允许注册Consumerlambda 表达式，当温度变化时将调用该表达式。
当setTemperature被调用时，它会触发notifyTemperatureChange，它会使用新的温度执行所有已注册的 lambda 表达式。

Kotlin 的方法：

Kotlin提供观察者委托功能。Delegates.observable()简化了对象属性更改的观察者模式实现：

您可以组合观察者委托来观察属性更改和高阶函数来注册回调。

import kotlin.properties.Delegates

class WeatherStation {
    // Observable property with callbacks:
    var temperature: Float by Delegates.observable(0f) { _, _, newValue ->
            onTemperatureChangeListeners.forEach { it(newValue) }
    }

    // List of callbacks:
    private val onTemperatureChangeListeners = mutableListOf<(Float) -> Unit>()

    // Function to add callbacks:
    fun onTemperatureChange(listener: (Float) -> Unit) {
        onTemperatureChangeListeners.add(listener)
    }
}

// Client:
fun main() {
    val station = WeatherStation()

    // Registering callbacks:
    station.onTemperatureChange { println("Display 1: Temperature updated to $it") }
    station.onTemperatureChange { println("Display 2: Temperature updated to $it") }

    // Simulating temperature change:
    station.temperature = 30f
}

在这个Kotlin实现中：

temperature中的属性是WeatherStation可观察属性。当它改变时，所有注册的回调onTemperatureChangeListeners都会被调用。
该onTemperatureChange方法允许注册对温度变化做出反应的 lambda 表达式（回调）。
客户端注册回调WeatherStation，每当属性更改时就会执行回调temperature。