Polishing contribution
Closes gh-34828
This commit is contained in:
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2002-2021 the original author or authors.
|
||||
* Copyright 2002-2025 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -23,78 +23,69 @@ import org.reactivestreams.Publisher;
|
||||
import reactor.core.publisher.Mono;
|
||||
|
||||
/**
|
||||
* Handler for a WebSocket session.
|
||||
*
|
||||
* <p>A server {@code WebSocketHandler} is mapped to requests with
|
||||
* Handler for a WebSocket messages. You can use it as follows:
|
||||
* <ul>
|
||||
* <li>On the server side, {@code WebSocketHandler} is mapped to requests with
|
||||
* {@link org.springframework.web.reactive.handler.SimpleUrlHandlerMapping
|
||||
* SimpleUrlHandlerMapping} and
|
||||
* {@link org.springframework.web.reactive.socket.server.support.WebSocketHandlerAdapter
|
||||
* WebSocketHandlerAdapter}. A client {@code WebSocketHandler} is passed to the
|
||||
* WebSocketHandlerAdapter}.
|
||||
* <li>On the client side, {@code WebSocketHandler} is passed into the
|
||||
* {@link org.springframework.web.reactive.socket.client.WebSocketClient
|
||||
* WebSocketClient} execute method.
|
||||
* </ul>
|
||||
*
|
||||
* <p>Use {@link WebSocketSession#receive() session.receive()} to compose on
|
||||
* the inbound message stream, and {@link WebSocketSession#send(Publisher)
|
||||
* session.send(publisher)} for the outbound message stream. Below is an
|
||||
* example, combined flow to process inbound and to send outbound messages:
|
||||
* <p>{@link WebSocketSession#receive() session.receive()} handles inbound
|
||||
* messages, while {@link WebSocketSession#send(Publisher) session.send}
|
||||
* sends outbound messages. Below is an example of handling inbound messages
|
||||
* and responding to every message:
|
||||
*
|
||||
* <pre class="code">
|
||||
* class ExampleHandler implements WebSocketHandler {
|
||||
* class ExampleHandler implements WebSocketHandler {
|
||||
*
|
||||
* @Override
|
||||
* public Mono<Void> handle(WebSocketSession session) {
|
||||
*
|
||||
* Flux<WebSocketMessage> output = session.receive()
|
||||
* .doOnNext(message -> {
|
||||
* // This is for side effects such as
|
||||
* // - Logging incoming messages
|
||||
* // - Updating some metrics or counters
|
||||
* // - Performing access checks or validations (non-blocking)
|
||||
* System.out.println("Got message: " + message.getPayloadAsText());
|
||||
* })
|
||||
* .concatMap(message -> {
|
||||
* // This is where you handle the actual processing of the incoming message. It
|
||||
* // might involve:
|
||||
* // - Parsing the message content (e.g., JSON parsing)
|
||||
* // - Invoking a reactive service (e.g., database, HTTP call, etc.)
|
||||
* // - Returning a transformed value, typically a Mono<String> or Mono<SomeType>
|
||||
* // if you're mapping to another data format
|
||||
* return Mono.just(message.getPayloadAsText());
|
||||
* })
|
||||
* .map(value -> {
|
||||
* // This is where you produce one or more responses for the message
|
||||
* return session.textMessage("Echo " + value));
|
||||
* });
|
||||
*
|
||||
* return session.send(output);
|
||||
* }
|
||||
* }
|
||||
* @Override
|
||||
* public Mono<Void> handle(WebSocketSession session) {
|
||||
* Flux<WebSocketMessage> output = session.receive()
|
||||
* .doOnNext(message -> {
|
||||
* // Imperative calls without a return value:
|
||||
* // perform access checks, log, validate, update metrics.
|
||||
* // ...
|
||||
* })
|
||||
* .concatMap(message -> {
|
||||
* // Async, non-blocking calls:
|
||||
* // parse messages, call a database, make remote calls.
|
||||
* // Return the same message, or a transformed value
|
||||
* // ...
|
||||
* });
|
||||
* return session.send(output);
|
||||
* }
|
||||
* }
|
||||
* </pre>
|
||||
*
|
||||
* <p>If processing inbound and sending outbound messages are independent
|
||||
* streams, they can be joined together with the "zip" operator:
|
||||
*
|
||||
* <pre class="code">
|
||||
* class ExampleHandler implements WebSocketHandler {
|
||||
* class ExampleHandler implements WebSocketHandler {
|
||||
*
|
||||
* @Override
|
||||
* public Mono<Void> handle(WebSocketSession session) {
|
||||
* @Override
|
||||
* public Mono<Void> handle(WebSocketSession session) {
|
||||
*
|
||||
* Mono<Void> input = session.receive()
|
||||
* .doOnNext(message -> {
|
||||
* // ...
|
||||
* })
|
||||
* .concatMap(message -> {
|
||||
* // ...
|
||||
* })
|
||||
* .then();
|
||||
* Mono<Void> input = session.receive()
|
||||
* .doOnNext(message -> {
|
||||
* // ...
|
||||
* })
|
||||
* .concatMap(message -> {
|
||||
* // ...
|
||||
* })
|
||||
* .then();
|
||||
*
|
||||
* Flux<String> source = ... ;
|
||||
* Mono<Void> output = session.send(source.map(session::textMessage));
|
||||
* Flux<String> source = ... ;
|
||||
* Mono<Void> output = session.send(source.map(session::textMessage));
|
||||
*
|
||||
* return Mono.zip(input, output).then();
|
||||
* }
|
||||
* }
|
||||
* return Mono.zip(input, output).then();
|
||||
* }
|
||||
* }
|
||||
* </pre>
|
||||
*
|
||||
* <p>A {@code WebSocketHandler} must compose the inbound and outbound streams
|
||||
|
||||
Reference in New Issue
Block a user