Java 9のPublisherインターフェースのルールとは？Reactive Streamsの規約を徹底解説

Publisherインターフェースとは

Publisher（パブリッシャー）とは、無限に続く可能性のある順序付けられた要素を、Subscriber（サブスクライバー）からの需要（デマンド）に応じて発行するプロバイダーのことです。これはJava 9で導入されたFlow API（Reactive Streams）の中核となる概念であり、非同期ストリーム処理におけるバックプレッシャー（背圧）制御を実現する基盤となっています。

Publisher<T>インターフェースは型Tの要素を発行する役割を担い、サブスクライバーが接続するためのsubscribe()メソッドを1つだけ提供します。

public interface Publisher<T> {
    public void subscribe(Subscriber<? super T> s);
}

Publisherインターフェースの主なルール

Publisherを実装する際には、Reactive Streams仕様で定められた以下のルールに従う必要があります。

1. 要素の発行に関するルール

• PublisherからSubscriberへ通知されるonNext()メソッドの総数は、常にそのSubscriberのSubscriptionが要求した要素の総数以下でなければなりません。
• Publisherは要求された数より少ないonNext()しか通知しなくても構いません。その場合はonComplete()またはonError()メソッドを呼び出してSubscriptionを終了できます。

2. シグナル通知の順序に関するルール

• Subscriberに通知されるonSubscribe()、onNext()、onError()、onComplete()の各メソッドは、逐次的（シリアルに）に通知されなければなりません。
• Publisher.subscribe()メソッドは、渡されたSubscriberに対して他のシグナルを送る前に必ずonSubscribe()を呼び出し、通常どおり返る必要があります。ただし、引数として渡されたSubscriberがnullの場合は例外で、呼び出し元にNullPointerExceptionをスローしなければなりません。
• Publisher.subscribe()メソッドは、毎回異なるSubscriberを引数として、必要な回数だけ何度でも呼び出すことができます。

3. 正常終了・異常終了に関するルール

• Publisherが失敗した場合は、必ずonError()メソッドを通知しなければなりません。
• Publisherが正常に完了した場合は、必ずonComplete()メソッドを通知しなければなりません。
• PublisherがSubscriberに対してonError()またはonComplete()を通知した場合、そのSubscriberのSubscriptionはキャンセルされなければなりません。
• 終端状態（onError()、onComplete()）が一度通知された後は、それ以上のシグナルが発生してはなりません。

4. キャンセルとマルチキャストに関するルール

• Subscriptionがキャンセルされた場合、該当するSubscriberへのシグナル通知は停止しなければなりません。
• Publisherは複数のSubscriberをサポートでき、各Subscriptionがユニキャストかマルチキャストかを自身で決定できます。

まとめ

Publisherインターフェースのルールは、Reactive Streamsにおける信頼性の高い非同期データ配信を保証するために設計されています。特に「要求された要素数を超えて発行しない」「終端状態以降はシグナルを送らない」といった規約は、バックプレッシャーによる過負荷防止とストリームの一貫性維持において非常に重要です。これらのルールを正しく理解することで、Java 9以降のFlow APIやReactor、RxJavaなどのリアクティブライブラリを安全かつ効果的に活用できるようになります。