Respondedores anotados

ApplicationContext context = ... ;
RSocketMessageHandler handler = context.getBean(RSocketMessageHandler.class);
CloseableChannel server =
RSocketServer.create(handler.responder())
.bind(TcpServerTransport.create("localhost", 7000))
.block();

import org.springframework.beans.factory.getBean
val context: ApplicationContext = ...
val handler = context.getBean<RSocketMessageHandler>()
val server = RSocketServer.create(handler.responder())
.bind(TcpServerTransport.create("localhost", 7000))
.awaitSingle()
        

RSocketMessageHandler admite de forma predeterminada compuesto metadatos y enrutamiento. Puede configurar su MetadataExtractor si necesita cambiar a un tipo MIME diferente o registrar tipos de metadatos MIME adicionales.

Necesitará configurar el Encoder y el Decoder instancias, que son necesarias para admitir metadatos y formatos de datos. Para implementar códecs, lo más probable es que necesites el módulo spring-web.

De forma predeterminada, SimpleRouteMatcher se utiliza para negociar rutas a través de AntPathMatcher . Recomendamos conectar PathPatternRouteMatcher desde spring-web para una coincidencia de rutas eficiente. Las rutas de RSocket pueden ser jerárquicas, pero no son rutas de URL. Ambos comparadores de ruta están configurados para usar "." como delimitador predeterminado y no hay decodificación de URL como es el caso de las URL HTTP.

RSocketMessageHandler se puede configurar a través de RSocketStrategies, que puede ser útil si necesita compartir configuración entre cliente y servidor en el mismo proceso:

@Configuration
static class ServerConfig {
@Bean
public RSocketMessageHandler rsocketMessageHandler() {
RSocketMessageHandler handler = new RSocketMessageHandler();
handler.setRSocketStrategies(rsocketStrategies());
return handler;
}
@Bean
public RSocketStrategies rsocketStrategies() {
return RSocketStrategies.builder()
    .encoders(encoders -> encoders.add(new Jackson2CborEncoder()))
    .decoders(decoders -> decoders.add(new Jackson2CborDecoder()))
    .routeMatcher(new PathPatternRouteMatcher())
    .build();
}
}

@Configuration
class ServerConfig {
@Bean
fun rsocketMessageHandler() = RSocketMessageHandler().apply {
rSocketStrategies = rsocketStrategies()
}
@Bean
fun rsocketStrategies() = RSocketStrategies.builder()
    .encoders { it.add(Jackson2CborEncoder()) }
    .decoders { it.add(Jackson2CborDecoder()) }
    .routeMatcher(PathPatternRouteMatcher())
    .build()
}

Contestadores del lado del cliente

Los respondedores anotados del lado del cliente deben configurarse en RSocketRequester.Builder .

@MessageMapping

Una vez que se ha configurado la configuración del respondedor para el servidor o cliente, los métodos con la anotación @MessageMapping se pueden usar de la siguiente manera:

@Controller
public class RadarsController {
@MessageMapping("locate.radars.within")
public Flux<AirportLocation> radars(MapRequest request) {
// ...
}
}

@Controller
class RadarsController {
@MessageMapping("locate.radars.within")
fun radars(request: MapRequest): Flow<AirportLocation> {
// ...
}
}

El método anterior, marcado con anotación @MessageMapping, responde a una interacción de tipo Request-Stream con la ruta "locate.radars.within". Admite una firma de método flexible con la capacidad de utilizar los siguientes argumentos de método:

Se espera que el valor de retorno sea uno o más objetos que se serializarán como datos de respuesta útiles. Estos pueden ser tipos asincrónicos como Mono o Flux, un valor concreto o void o un tipo asincrónico sin un valor como Mono<Void>.

El tipo de interacción RSocket que admite un método anotado con @MessageMapping está determinado por la cardinalidad del conjunto de entrada (es decir, el argumento anotado con @Payload) y salida, donde cardinalidad significa lo siguiente:

La siguiente tabla muestra todas las combinaciones de potencia de conjuntos de entrada y salida y los tipos de interacción correspondientes:

@ConnectMapping

La anotación @ConnectMapping maneja la SETUP marco al comienzo del establecimiento de una conexión RSocket y todas las notificaciones posteriores sobre cómo enviar metadatos a través del marco METADATA_PUSH, es decir, metadataPush(Payload) en io.rsocket.RSocket.

Los métodos con la anotación @ConnectMapping admiten los mismos argumentos que y métodos con la anotación @MessageMapping, pero se basan en metadatos y datos de los marcos SETUP y METADATA_PUSH. La anotación @ConnectMapping se puede proporcionar con una plantilla para limitar el procedimiento de procesamiento a conexiones específicas que tienen una ruta en los metadatos y, si no se declaran plantillas, todas las conexiones coincidirán.

Los métodos anotados @ConnectMapping no pueden devolver datos, por lo que deben declararse utilizando void o Mono<Void> como valor de retorno. Si el procedimiento de procesamiento devuelve un error para una nueva conexión, entonces la conexión se rechaza. El procedimiento de procesamiento no debe retrasarse para que se puedan realizar solicitudes a RSocketRequester para una conexión específica.