使用 RSocketFactory 的替换

Question

我一直在查看一些 RSocket 演示和示例以了解它们是如何工作的，但其中大多数都有过时的代码。

例如，我有这个演示，在不推荐使用时使用 RSocketFactory。

@Bean
RSocket rSocket () {
    return RSocketFactory
            .connect()
            .dataMimeType(MimeTypeUtils.APPLICATION_JSON_VALUE)
            .frameDecoder(PayloadDecoder.ZERO_COPY)
            .transport(TcpClientTransport.create(7000))
            .start()
            .block();
}

我通过搜索发现它已被 RSocketConnectorConfigurer 取代，但我找不到新用法的示例代码。以前玩过 RSocket 的人是否有机会帮助使用新的配置方法？

谢谢！

Answer 1

由于 api 的变化，我也遇到了类似的问题。你可以使用这个例子。

点击此处了解更多信息 - http://www.vinsguru.com/rsocket-integrating-with-spring-boot/

@Configuration
public class RSocketConfig {

    @Bean
    public RSocketStrategies rSocketStrategies() {
        return RSocketStrategies.builder()
                .encoders(encoders -> encoders.add(new Jackson2CborEncoder()))
                .decoders(decoders -> decoders.add(new Jackson2CborDecoder()))
                .build();
    }

    @Bean
    public Mono<RSocketRequester> getRSocketRequester(RSocketRequester.Builder builder){
        return builder
                .rsocketConnector(rSocketConnector -> rSocketConnector.reconnect(Retry.fixedDelay(2, Duration.ofSeconds(2))))
                .dataMimeType(MediaType.APPLICATION_CBOR)
                .connect(TcpClientTransport.create(6565));
    }

}

使用 RSocketFactory 的替换

Using the replacement of RSocketFactory

java

spring

lombok

rsocket