SpringBoot 의 응답 식 웹 응용 상세 설명

간단 한 소개
Spring 5 에서 Spring MVC 는 webFlux 의 개념 을 도 입 했 고 webFlux 의 밑바닥 은 reactor-netty 를 바탕 으로 왔 으 며 reactor-netty 는 Reactor 라 이브 러 리 를 사용 했다.
본 고 는 Spring Boot 에서 reactive 가 WebFlux 에서 의 사용 을 소개 할 것 이다.
Reactive in Spring
앞에서 말 했 듯 이 웹 플 럭스 의 기 초 는 Reactor 입 니 다.그래서 Spring Boot 는 두 개의 서로 다른 웹 프레임 워 크 를 가지 고 있 습 니 다.첫 번 째 프레임 워 크 는 전통 적 인 Servlet API 와 Spring MVC 를 바탕 으로 하고 두 번 째 프레임 워 크 는 최신 reactive 프레임 워 크 를 바탕 으로 합 니 다.Spring WebFlux 와 Spring Data 를 포함 한 reactive reposcories 입 니 다.

우 리 는 위의 그림 으로 두 체계의 차 이 를 뚜렷하게 볼 수 있다.
바 텀 데이터 소스 의 경우 MongoDB,Redis,Cassandra 는 직접 reactive 방식 으로 Spring Data 를 지원 할 수 있다.다른 많은 관계 형 데이터베이스,예 를 들 어 Postgres,Microsoft SQL Server,MySQL,H2 와 Google Spanner 는 R2DBC 를 사용 하여 reactive 에 대한 지원 을 실현 할 수 있다.
스프링 클 라 우 드 스 트림 은 RabbitMQ 와 Kafka 의 reactive 모델 까지 지원 할 수 있다.
다음은 구체 적 인 Spring Boot 에서 Spring WebFlux 를 사용 하 는 예 를 소개 하 겠 습 니 다.마음 에 드 셨 으 면 좋 겠 습 니 다.
주석 방식 은 WebFlux 를 사용 합 니 다.
Spring WebFlux 를 사용 하려 면 다음 과 같은 의존 도 를 추가 해 야 합 니 다.

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-webflux</artifactId>
  </dependency>

주석 만 사용 하 는 방식 은 일반적인 Spring MVC 와 유사 합 니 다.저 희 는@RestController 를 사용 하여 rest 서비스 라 고 표시 할 수 있 습 니 다.@GetMapping("/hello")을 사용 하여 get 요청 을 표시 할 수 있 습 니 다.
다른 점 은 우리 가 요청 한 생 성 방식 과 반환 값 이다.
Reactor 를 잘 아 는 친구 들 은 모두 알 고 있 을 것 이다.Reactor 에 서 는 두 가지 서열 을 만 드 는 방식 이 있 는데 하 나 는 Flux 이 고 하 나 는 Mono 이다.그 중에서 Flux 는 1 또는 많 음 을 나타 내 고 모 노 는 0 또는 1 을 나타 낸다.
우리 컨트롤 러 가 어떻게 써 야 하 는 지 보 세 요.

@RestController
public class WelcomeController {

 @GetMapping("/hello")
 public Mono<String> hello() {
  return Mono.just("www.flydean.com");
 }

 @GetMapping("/hellos")
 public Flux<String> getAll() {
  //  lambda   
  return Flux.fromStream(Stream.of("www.flydean.com","flydean").map(String::toLowerCase));
 }

}

이 예 에서 우 리 는 두 가지 get 방법 을 제 공 했 습 니 다.첫 번 째 는 hello 입 니 다.직접 Mono.just 를 사용 하여 모 노 를 되 돌려 줍 니 다.
두 번 째 방법 은 hellos 입 니 다.Flux 의 일련의 조작 을 통 해 마지막 으로 Flux 대상 을 되 돌려 줍 니 다.
모 노 대상 이 있 는데,우 리 는 어떻게 안의 데 이 터 를 꺼 냅 니까?

public class WelcomeWebClient {
	private WebClient client = WebClient.create("http://localhost:8080");

	private final Mono<ClientResponse> result = client.get()
			.uri("/hello")
			.accept(MediaType.TEXT_PLAIN)
			.exchange();

	public String getResult() {
		return " result = " + result.flatMap(res -> res.bodyToMono(String.class)).block();
	}
}

우 리 는 웹 클 라 이언 트 를 통 해 get 의 결 과 를 얻 고 exchange 를 통 해 클 라 이언 트 Response 로 변환 합 니 다.
그리고 getResult 방법 을 제공 하여 result 에서 최종 결 과 를 가 져 옵 니 다.
여기 서,우 리 는 먼저 FlatMap 을 호출 하여 Client Response 를 전환 한 다음 에 block 방법 을 호출 하여 새로운 subscription 을 만 듭 니 다.
마지막 으로 Spring Boot 의 시작 클래스 를 살 펴 보 겠 습 니 다.

@Slf4j
@SpringBootApplication
public class Application {

 public static void main(String[] args) {
  SpringApplication.run(Application.class, args);

  WelcomeWebClient welcomeWebClient = new WelcomeWebClient();
  log.info("react result is {}",welcomeWebClient.getResult());
 }
}

프로 그래 밍 방식 은 webFlux 를 사용 합 니 다.
방금 주해 방식 은 사실 우리 가 자주 사용 하 는 Spring MVC 와 기본적으로 같다.
다음은 위의 논 리 를 프로 그래 밍 방식 으로 작성 하려 면 어떻게 처리 해 야 하 는 지 살 펴 보 자.
우선,우 리 는 hello 요청 을 처리 하 는 프로 세 서 를 정의 합 니 다.

@Component
public class WelcomeHandler {

	public Mono<ServerResponse> hello(ServerRequest request) {
		return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN)
			.body(BodyInserters.fromValue("www.flydean.com!"));
	}
}

일반적인 처리 와 마찬가지 로 우 리 는 모 노 대상 으로 돌아 가 야 한다.
여 기 는 ServerRequest 입 니 다.WebFlux 에 Servlet 이 없 기 때 문 입 니 다.
프로세서 가 있 습 니 다.경로 설정 을 위해 Router 를 써 야 합 니 다.

@Configuration
public class WelcomeRouter {

	@Bean
	public RouterFunction<ServerResponse> route(WelcomeHandler welcomeHandler) {

		return RouterFunctions
			.route(RequestPredicates.GET("/hello").
					and(RequestPredicates.accept(MediaType.TEXT_PLAIN)), welcomeHandler::hello);
	}
}

위의 코드 는/hello 와 welcome Handler:hello 를 연결 하 였 습 니 다.
Welcome WebClient 와 Application 은 첫 번 째 방식 과 같 습 니 다.

public class WelcomeWebClient {
	private WebClient client = WebClient.create("http://localhost:8080");

	private Mono<ClientResponse> result = client.get()
			.uri("/hello")
			.accept(MediaType.TEXT_PLAIN)
			.exchange();

	public String getResult() {
		return " result = " + result.flatMap(res -> res.bodyToMono(String.class)).block();
	}
}

public class Application {

 public static void main(String[] args) {
  SpringApplication.run(Application.class, args);

  WelcomeWebClient welcomeWebClient = new WelcomeWebClient();
  log.info("react result is {}",welcomeWebClient.getResult());
 }
}

Spring WebFlux 테스트
웹 플 럭스 코드 를 어떻게 테스트 합 니까?
본질 적 으로 WelcomeWebClient 의 실현 과 같 습 니 다.우 리 는 대응 하 는 대상 을 요청 한 다음 에 반환 값 을 검사 하고 마지막 으로 반환 값 이 우리 가 기대 하 는 내용 인지 판단 합 니 다.
다음 과 같다.

@ExtendWith(SpringExtension.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class WelcomeRouterTest {
 @Autowired
 private WebTestClient webTestClient;

 @Test
 public void testHello() {
  webTestClient
    .get().uri("/hello")
    .accept(MediaType.TEXT_PLAIN)
    .exchange()
    .expectStatus().isOk()
    .expectBody(String.class).isEqualTo("www.flydean.com!");
 }
}

총결산
웹 Flux 는 Reactor 를 기본 으로 사용 합 니 다.일반적인 웹 요청 방식 과 는 많이 다 르 지만,우리 의 Spring 프레임 워 크 를 통 해 기 존의 코드 작성 스타일 과 습관 을 최대한 보장 할 수 있 습 니 다.
개별 부분 에서 만 미세 조정 을 해 야 한다.이 간단 한 예 를 통 해 Reactive 의 기본 인 코딩 을 숙지 하 시기 바 랍 니 다.
본 논문 의 예 는 참고 할 수 있다.
SpringBoot 의 응답 식 웹 애플 리 케 이 션 에 대한 자세 한 설명 은 여기까지 입 니 다.더 많은 SpringBoot 응답 식 웹 애플 리 케 이 션 내용 은 예전 의 글 을 검색 하거나 아래 의 관련 글 을 계속 찾 아 보 세 요.앞으로 많은 응원 부 탁 드 리 겠 습 니 다!