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

Question

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

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

但当我尝试发送消息创建if时,它会抛出一个异常：

@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);
    }
}

wrap函数有什么问题？

Answer 1

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

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

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