使用rsocketfactory替换

lyr7nygr 于 2021-07-12 发布在 Java

关注(0)|答案(1)|浏览(316)

我已经看过一些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的人有没有可能帮助使用新的配置方法？
谢谢！

Java spring rsocket lombok

来源：https://stackoverflow.com/questions/63489822/using-the-replacement-of-rsocketfactory

1条答案

按热度按时间

xsuvu9jc1#

由于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));
    }

}

赞(0）回复(0）举报 2021-07-12

我来回答

使用rsocketfactory替换

1条答案

相关问题

热门标签

最新问答