Reactvie-web

reactive-web

비동기 + 논블로킹

• 논블로킹: 점원이 주문을 받자마자 진동벨(제어권)을 내 손에 쥐여줍니다. (내가 멈춰있지 않고 자리에 앉아서 폰을 볼 수 있음)

• 비동기: 커피가 완성되었을 때 점원이 "커피 나왔습니다!"(알림) 하고 부를 때까지 내가 커피 만드는 과정을 계속 지켜보고 있지 않습니다.

Netty 서버

Event Loop 쓰레드 모델

WebFlux 프레임워크

@RestController
public class UserController {

    // 1. 단건 조회: Mono 반환
    @GetMapping("/users/{id}")
    public Mono<User> getUser(@PathVariable String id) {
        // 스레드는 멈추지 않고 즉시 Mono(약속)를 반환함!
        return userService.findById(id); 
    }

    // 2. 실시간 스트리밍(SSE): Flux 반환
    @GetMapping(value = "/stream/messages", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<Message> streamMessages() {
        // 메시지가 생길 때마다 연결된 브라우저로 계속 쏴줌!
        return messageService.getMessageStream(); 
    }
}


이렇게 있다고 가정할 때에 
A 스레드가 getUser 메서드가 끝날때까지 다른 일을처리 못하는게 아닌
DB에 조회 요청하는 일을 이벤트로 등록을 해놓고 곧 바로 
streamMessages 메서드에 실시간으로 들어오는 메시지들을 화면에 보내는 일을한다.
그러다 이벤트로 등록해놓은 조회가 끝나면 놀고있는 스레드가 결과 데이터를 챙겨서 A 유저의 HTTP 응답으로 쏴준다

I/O

• 네트워크 I/O (Network I/O):
• Input: 클라이언트(브라우저, 앱)가 보낸 HTTP 요청을 서버가 받음, DB가 반환한 데이터를 서버가 받음
• Output: 서버가 클라이언트에 응답 데이터를 보냄, 서버가 DB나 외부 API로 쿼리/요청을 보냄

• 파일/디스크 I/O (File/Disk I/O):
• Input: 하드디스크(SSD)에 저장된 파일이나 로깅 데이터를 읽어옴
• Output: 서버가 파일이나 로그를 디스크에 저장함

• DB I/O:
• 사실상 네트워크/디스크 I/O의 연장선으로, DB에 SQL 쿼리를 날리고 결과를 가져오는 모든 과정

CDC(Change Data Capture)

SSE(Server-Sent Events)