Java RSocket 客户端与 Spring RSocket 通道连接答案

【问题标题】：Java RSocket client connect with Spring RSocket channelJava RSocket 客户端与 Spring RSocket 通道连接
【发布时间】：2021-01-18 18:23:36
【问题描述】：

我有简单的 Spring boot RSocket 服务

    @MessageMapping("msend")
    public Flux<String> msend(String message) {
        log.info("msend channel publish " + message);
        return Flux.just(message, " "+System.currentTimeMillis());
    }

很容易连接2个Spring服务，但是我的客户端应用没有spring，我的客户端应该在RSocket java中

我很难理解如何将消息发送（路由，如 Spring RsocketRequester）到该特定通道。

客户端代码应该是：

 Mono<RSocket> rsocket = RSocketConnector.create()               
            .metadataMimeType(WellKnownMimeType.MESSAGE_RSOCKET_COMPOSITE_METADATA.getString())               
            .connect(TcpClientTransport.create(2050));


 ///real path "http://gateway:2022/producer/toProducerRsocket", 2050)
 ///toProducerRsocket redirect to producer/rsocket

是否可以订阅 Spring 频道？

【问题讨论】：

标签： java spring-boot rsocket rsocket-java spring-rsocket

【解决方案1】：

这对于定义元数据类型看起来是正确的。但是您需要为请求流设置它。频道在这里听起来不正确，因为您只有一个输入值消息。

https://stackoverflow.com/a/62776146/1542667

CompositeByteBuf metadata = ByteBufAllocator.DEFAULT.compositeBuffer();
RoutingMetadata routingMetadata = TaggingMetadataCodec.createRoutingMetadata(ByteBufAllocator.DEFAULT, List.of("/route"));
CompositeMetadataCodec.encodeAndAddMetadata(metadata,
        ByteBufAllocator.DEFAULT,
        WellKnownMimeType.MESSAGE_RSOCKET_ROUTING,
        routingMetadata.getContent());

【讨论】：

如果你搜索 github，或者 spring 教程，你应该会找到很多这样的例子。