rSocket

2020-01-18

개발

2020

Netflix 에서 개발한 Reactive Stream을 기반으로 한 어플리케이션 프로토콜. 마이크로 서비스상에서 Http 통신이 비효율적인 부분이 있기 때문에 오버헤드가 적은 프로토콜로 대체하려는 용도로 개발됨

사용해 보기

https://start.spring.io/ 에서 rsocket Dependencies 를 추가하여 프로젝트 생성 후 작업 진행

서버

설정

application.properties 에 rsocket port 설정

spring.rsocket.server.port=7000
spring.main.lazy-initialization=true

EndPoint 생성

@MessageMapping 사용

@Controller
public class RSocketController {


    @MessageMapping("hello")
    public Mono<String> helloRSocket(String name) {
        return Mono.just("Hello " + name + ", time : " + Instant.now());
    }
}

클라이언트

설정

RSocketRequester Bean 생성

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

EndPoint 호출

    @GetMapping("hello/{name}")
    public Publisher<String> hello(@PathVariable String name) {
        return rSocketRequester
            .route("hello")
            .data(name)
            .retrieveMono(String.class);
    }