Пример (Java-подобный, упрощённо)
interface Observer {
void update(Object event);
}
class Subject {
private final List observers = new ArrayList();
public void attach(Observer o) { observers.add(o); }
public void detach(Observer o) { observers.remove(o); }
public void notifyAll(Object event) {
for (Observer o : new ArrayList(observers)) { // копия для безопасности
o.update(event);
}
}
// пример: изменение состояния
public void setState(Object state) {
// ... изменить состояние ...
notifyAll(state);
}
}
class LoggerObserver implements Observer {
public void update(Object event) { System.out.println("log: " + event); }
}
Когда использование оправдано
- Простая внутренняя (in-process) публикация событий между компонентами в одном приложении.
- Небольшое число подписчиков и низкая/средняя частота событий.
- Нужна простая синхронная реакция на изменения (например, UI-компонты, паттерн MVC).
- Требуется простая, легко тестируемая и понятная реализация без дополнительной библиотеки.
Когда лучше выбрать другие подходы (например, реактивные потоки)
- Высокая пропускная способность событий, потоковая обработка, сложные преобразования/фильтрация/комбинация потоков — тут удобнее реактивные библиотеки (Rx, Reactor, Flow).
- Нужна поддержка асинхронности, параллелизма и управления backpressure (реактивные потоки предоставляют механизмы контроля нагрузки).
- События распределяются между процессами/сервисами — лучше использовать брокеры (Kafka, RabbitMQ) или распределённый pub/sub.
- Требуется богатая композиция операторов (map/filter/flatMap), отложенная/ленивая обработка, retry, timeout и т.п.
Вопросы масштабируемости и тестируемости — кратко
- Масштабируемость: Observer (простая версия) — ограничена одним процессом, синхронна, без backpressure; реактивные потоки и message brokers масштабируются лучше и управляют нагрузкой.
- Тестируемость: простая реализация Observer легко мокается и детерминирована (удобно для unit-тестов). Реактивные потоки требуют тест-сьедулеров/виртуального времени и специальных тест-утилит, но дают мощные возможности для интеграционных/поведенческих тестов потоков.
- Память/утечки: у Observer риск утечек при незакрытых подписках — решение: явное отписывание, WeakReference, автоотписка. Реактивные библиотеки имеют понятные lifecycle и disposable/Subscription механизмы.
Рекомендация
- Для простых внутренняя связей и низкой нагрузки — Observer (легко и прозрачно).
- Для высоконагруженных, асинхронных, распределённых или требующих сложной композиции — реактивные потоки или брокеры.