您正在使用哪个spring版本?我有一个相同的问题,我通过更改spring-boot-starter-parent 2.2.0.M3来解决了。
这是我的来源 https://github.com/han1448/spring-rsocket-
example
添加。
我解决了这个问题。您需要将mimeType更改为
message/x.rsocket.routing.v0。您可以从获取此mimeType
metadataExtractor.ROUTING。
@BeanRSocket rSocket() { return RSocketFactory.connect() .mimeType(metadataExtractor.ROUTING.toString(), MimeTypeUtils.APPLICATION_JSON_VALUE) .frameDeprer(PayloadDeprer.ZERO_COPY) .transport(TcpClientTransport.create(new InetSocketAddress(7500))) .start() .block();}@BeanRSocketRequester requester(RSocketStrategies strategies) { return RSocketRequester.wrap(rSocket(), MimeTypeUtils.APPLICATION_JSON, metadataExtractor.ROUTING, strategies);}


