SubmissionPublisher实现响应式变量发布订阅-java教程-PHP中文网

SubmissionPublisher 不适合做响应式变量，因其面向多元素数据流，缺乏保存最新值、获取当前值、自动通知变更等能力，仅支持手动 submit 推送，且新订阅者无法获得历史值。

submissionpublisher实现响应式变量发布订阅

SubmissionPublisher 是 Java 9 引入的 java.util.concurrent.Flow 中的一个具体实现类，用于发布（publish）数据流，但它本身不直接支持响应式变量（即动态变化、可观察的单个值）的发布订阅。它面向的是“多元素、有生命周期”的数据流（类似 Reactive Streams 的 Publisher），而非类似 RxJava 的 BehaviorSubject 或 Reactor 的 Mono / AtomicReference + 监听器这类“响应式变量”场景。

为什么 SubmissionPublisher 不适合做“响应式变量”

SubmissionPublisher 的设计目标是：

支持背压（通过 Subscription.request()）
异步、线程安全地批量提交多个元素（submit(T item)）
配合 Flow.Subscriber 实现标准响应式流协议（onSubscribe/onNext/onError/onComplete）

它没有内置机制来：

保存并分发“最新值”给新订阅者（即无状态快照）
暴露当前值（get()）或设置新值（set()）
在值变更时自动通知所有活跃订阅者（除非你手动调用 submit）

如何用 SubmissionPublisher 模拟响应式变量行为

若坚持使用 SubmissionPublisher 实现类似“响应式变量”的效果，需额外封装。核心思路是：每次变量更新时显式 submit，并让订阅者自行缓存最新值。

示例（简易封装）：

public final class ReactiveVar<t> {
    private final SubmissionPublisher<t> publisher = new SubmissionPublisher();
    private volatile T latest;

    public void set(T value) {
        this.latest = value;
        publisher.submit(value); // 主动推送
    }

    public T get() {
        return latest;
    }

    public void subscribe(Flow.Subscriber super T> subscriber) {
        publisher.subscribe(subscriber);
    }

    public void close() {
        publisher.close();
    }
}
</t></t>

⚠️ 注意：

新订阅者不会收到历史值（除非你在 subscribe 时主动调用 subscriber.onNext(latest)）
若需“热发布+初始值回放”，需在 subscribe 中先触发一次 onNext(latest)（但要确保线程安全与订阅时序）
背压对单值变量意义不大，可考虑用 new SubmissionPublisher(null, 0) 禁用缓冲

更合适的替代方案

对于真正的响应式变量（如 UI 状态、配置热更新），推荐以下更自然的工具：

Reactor：用 AtomicReference + Flux.create() 或 DirectProcessor（已弃用）→ 推荐 Sinks.Many.multicast().onBackpressureBuffer()
RxJava：用 BehaviorSubject.createDefault(initial) 或 AtomicReference 配合 Subject
Java 标准库轻量级：自定义 Property 类，内部用 CopyOnWriteArrayList 存监听器，配合 set(T) 触发回调（无背压，简单高效）