1. 반응형 프로그래밍과 Spring WebFlux 개요
반응형 프로그래밍은 비동기 데이터 스트림을 기반으로 하는 프로그래밍 패러다임입니다. 반응형 시스템은 높은 동시성과 이벤트 기반 아키텍처를 특징으로 합니다. Spring WebFlux는 Spring 5에서 도입된 반응형 웹 프레임워크로, Reactive Streams 사양을 구현하여 논블로킹 방식으로 동작합니다.
2. Reactive Streams와 Reactor
Reactive Streams는 비동기 데이터 스트림 처리를 위한 표준 사양이며, Flow API를 통해 Java에서 제공됩니다. WebFlux는 Reactor 라이브러리를 기본으로 사용하며, Mono와 Flux 클래스를 통해 데이터 스트림을 처리합니다.
- Mono: 0-1개의 데이터를 발행하는 Publisher
- Flux: 0-N개의 데이터를 발행하는 Publisher
3. WebFlux 애플리케이션 개발
컨트롤러
WebFlux에서는 @RestController를 사용하여 반응형 컨트롤러를 작성합니다. 요청 처리 메서드는 Mono나 Flux를 반환합니다.
|
1
2
3
4
|
@GetMapping(“/{id}”)
public Mono<User> getUserById(@PathVariable Long id) {
return userService.getUserById(id);
}
|
cs |
라우터 함수
함수형 프로그래밍 스타일로 엔드포인트를 정의할 수 있습니다. RouterFunction과 HandlerFunction을 사용합니다.
|
1
2
3
4
|
@Bean
public RouterFunction<ServerResponse> userRoute(UserHandler userHandler) {
return route(GET(“/users/{id}”), userHandler::getUser);
}
|
cs |
4. 데이터베이스 접근
Spring Data R2DBC를 사용하여 반응형 데이터베이스 접근을 할 수 있습니다. ReactiveCrudRepository를 통해 반응형 쿼리 메서드를 제공합니다.
|
1
2
3
|
public interface UserRepository extends ReactiveCrudRepository<User, Long> {
Flux<User> findByName(String name);
}
|
cs |
5. 웹클라이언트와 테스트
WebClient를 사용하여 반응형 HTTP 클라이언트를 구현할 수 있습니다. WebTestClient를 통해 WebFlux 애플리케이션을 효과적으로 테스트할 수 있습니다.
|
1
2
3
4
5
6
7
|
@Test
void getUserById() {
webTestClient.get().uri(“/users/1”)
.exchange()
.expectStatus().isOk()
.expectBody(User.class).isEqualTo(new User(1L, “John”));
}
|
cs |
6. 실전 예제
간단한 사용자 관리 API를 WebFlux로 구현해보겠습니다.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
@RestController
@RequestMapping(“/users”)
public class UserController {
private final UserService userService;
public UserController(UserService userService) {
this.userService = userService;
}
@GetMapping
public Flux<User> getAllUsers() {
return userService.getAllUsers();
}
@GetMapping(“/{id}”)
public Mono<User> getUserById(@PathVariable Long id) {
return userService.getUserById(id);
}
@PostMapping
public Mono<User> createUser(@RequestBody User user) {
return userService.createUser(user);
}
}
|
cs |
|
1
2
|
public interface UserRepository extends ReactiveCrudRepository<User, Long> {
}
|
cs |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
@Service
public class UserService {
private final UserRepository userRepository;
public UserService(UserRepository userRepository) {
this.userRepository = userRepository;
}
public Flux<User> getAllUsers() {
return userRepository.findAll();
}
public Mono<User> getUserById(Long id) {
return userRepository.findById(id);
}
public Mono<User> createUser(User user) {
return userRepository.save(user);
}
}
|
cs |
위와 같이 컨트롤러, 레포지토리, 서비스 클래스를 작성하면 간단한 사용자 관리 API를 구현할 수 있습니다. 데이터베이스에 사용자 정보를 저장하고, 조회 및 생성 기능을 제공합니다.
Spring WebFlux를 사용하여 반응형 웹 애플리케이션을 개발할 수 있습니다. Reactive Streams 사양을 기반으로 동작하며, Reactor 라이브러리를 활용합니다. 컨트롤러, 라우터 함수, 반응형 데이터베이스 접근 등 다양한 방법으로 애플리케이션을 구성할 수 있습니다.
WebFlux는 높은 동시성과 확장성이 필요한 시스템에 적합하지만, 학습 비용이 필요하고 모든 상황에 적용하기에 적절하지 않을 수 있습니다. 요구사항과 팀의 역량을 고려하여 적절히 활용해야 합니다.
반응형 프로그래밍은 최근 트렌드이며, Spring WebFlux는 Java 진영에서의 반응형 웹 개발을 선도하고 있습니다. WebFlux를 통해 효율적이고 확장 가능한 애플리케이션을 구축해 보시기 바랍니다.