10

Springs RSocketRequester について質問があります。rsocket サーバーとクライアントがあります。クライアントはこのサーバーに接続し、@MessageMapping エンドポイントを要求します。期待どおりに動作します。

しかし、サーバーを再起動するとどうなりますか。クライアントからrsocketサーバーへの自動再接続を行うには? ありがとう

サーバ:

@Controller
class RSC {

    @MessageMapping("pong")
    public Mono<String> pong(String m) {
        return Mono.just("PONG " + m);
    }
}

クライアント:

@Bean
    public RSocketRequester rSocketRequester() {
        return RSocketRequester
                .builder()
                .connectTcp("localhost", 7000)
                .block();

    }

@RestController
class RST {

    @Autowired
    private RSocketRequester requester;

    @GetMapping(path = "/ping")
    public Mono<String> ping(){
        return this.requester
                .route("pong")
                .data("TEST")
                .retrieveMono(String.class)
                .doOnNext(System.out::println);
    }
}
4

2 に答える 2