Java spring SseEmitter/ResponseBodyEmitter：ブラウザのリロードを検出します。

Question

Java Springでサーバーサイドイベント（SSE）を使用しています。イベントは、私が実行し、クライアントに通知する必要があるときはいつでも、次に

SseEmitter emitter = new SseEmitter(-1L); 
emitter.onCompletion(() -> { 
     logger.debug(TAG + "Emitter completed."); 
     emitters.remove(emitter); 
    }); 
return emitter; 

：

for (ResponseBodyEmitter emitter: emitters) { 
     emitter.send("Message #1"); 
} 

問題新しいクライアントは、私はRESTコントローラで次のコードを実行するイベントサービスに加入するたびにクライアントの1人がブラウザをリロードすると、エミッタが（期待通りに）完成せず、上のコードを呼び出すときにパイプの例外が壊れるということです。この例外がトリガーされた後でなければ、エミッターが完了していることがわかります。

この問題を解決する方法はありますか？

Answer 1

ブラウザがリロードされると、サーバーに新しいEventSourceが確立されます。あなたの問題は、クライアントのエンドポイントがもうない古いものにあります。

これは、同じクライアントに接続していることを検出し、明示的に古いエミッタでcompleteを呼び出すことをお勧めします。

私のケースでは、EventSourceがURLパラメータとして渡すトークンに基づいてこれを検出できます。新しく作成されたエミッタを「ユーザオブジェクト」にフックすると、ユーザフィールド変数に新しいものを割り当てる前に、以前のエミッタを完了するようにします。

コードからは、リストまたはエミッタのセットがあるようです。おそらくマップにする代わりに、クライアントのIDをキーにし、エミッタを値として持つことができますか？

すべてがアプリケーションに依存するため、正確にどの情報をクライアントIDとして使用するかはわかりません。私の場合、それはJWTトークンですが、おそらくクライアントの番号付けスキームを作成することができます。