使用“wrap”函数创建时的Spring RSocketRequester问题

Question

当我像这样创建rsocketRequester时，它工作得很好：

@Bean
RSocketRequester rSocketRequester(RSocketStrategies rSocketStrategies) {
    return RSocketRequester.builder()
            .rsocketStrategies(rSocketStrategies)
            .connectTcp("localhost", 7000)
            .block();
}

但是当我试图发送消息时，它会抛出一个异常，创建如下所示：

@Bean
RSocket rSocket() {
    return RSocketFactory
            .connect()
            .transport(TcpClientTransport.create(7000))
            .start()
            .block();
}

@Bean
RSocketRequester rSocketRequester(RSocketStrategies rSocketStrategies) {
    return RSocketRequester.wrap(rSocket(), MediaType.APPLICATION_CBOR, MimeTypeUtils.parseMimeType(WellKnownMimeType.MESSAGE_RSOCKET_COMPOSITE_METADATA.getString()), rSocketStrategies);
}

发送功能：

public Mono<String> request(String route, String data, Class<String> clazz) {
    return rSocketRequester.route(route).data(data).retrieveMono(clazz);
}

@Controller
@AllArgsConstructor
public class RTestController {

    private EchoService echoService;

    @MessageMapping("test")
    Mono<String> test(String value) {
        return echoService.echo(value);
    }
}

Answer 1

TL；DR：这不是Spring的问题，而是您创建客户机RSocket连接的方式的问题。

RSocketRequester.wrap方法通常用于服务器端，一旦客户端启动了连接并且服务器希望向另一方发送请求。Javadoc表明您可以在客户端使用它，这是一个完全有效的用例。

现在，rsocketRequester.wrap在其参数中接受关于预期数据mime类型和元数据mime类型的数据。这通常是双方在建立连接时协商的，使用RSocket setup/metadata_push帧。一旦建立了连接，就完成了。wrap方法需要这些参数，因为我们不能很容易地从现有的RSocket中提取这些信息。