SSEイベントを非同期で処理する方法はありますか？

Question

最適には、私はちょうどそれは私がやろうとしたものを説明するのに役立つだろうと思った、まさにそのようにする必要はありません。もちろん、この

Request request = new Request("http://someendpoint") 
request.onMessage(payload -> System.out.println(payload)) 
request.onError(error -> error.printStackTrace()) 
request.onClose(() -> System.out.println("closed")) 
request.onConnect(isReconnect -> System.out.println("connected")) 

ような何かをできるようにしたいと思います。

私はジャージーでこれについて何らかのサポートがあることを知りました。私は代替案を探していますが、他に何も利用できない場合はそれを使用します。

Answer 1

SSEは、javax.ws.rs.sseパッケージのJavaEE 8〜JAX-RS 2.1で利用できます。非同期または非同期の要求および応答とは異なり、SSEは性質上非同期です。

SSEのデモンストレーションについては、video by David Delaba sse eをご覧ください。あなたのコード（クライアント側のみ）だろうが、このようなものになります。

Client client = ClientBuilder.newClient(); 
WebTarget target = client.target("http://someendpoint"); 

SseEventSource eventSource = SseEventSource.target(target) 
              .reconnectingEvery(5, TimeUnit.SECONDS) 
              .build(); 
eventSource.register(payload -> System.out.println(payload), // Consumer<InboundSseEvent> 
        error -> error.printStackTrace(),   // Consumer<Throwable> 
        () -> System.out.println("no more events")); 
eventSource.open(); 
// and eventually 
eventSource.close(); 

が（再）接続と終了のための組み込みのハンドラはありませんが、しかし、あなたは同じ効果を持つために何かをカスタマイズすることができます。

JAX-RS 2.1は、（少なくとも）に実装されている：Glassfishの5及びペーシュ・カショーロ5アルファ/スナップショット/プレリリースに含まれる

Jersey
• 2.26を、。
• RESTEasy 4.0.0.Beta1（1か月以内にリリース）、Wildfly 10以上で動作することが報告されていますが、Wildfly 12のみがJavaEE 8の完全な実装となると思います。