IT LAB

1. 전체 흐름[송신 애플리케이션]User Space │ write() ▼[커널 송신 버퍼]Kernel Space │ ▼ NIC │ Network │ ▼[상대방 커널 수신 버퍼] │ read() ▼[상대방 애플리케이션]네트워크 I/O는 애플리케이션끼리 직접 데이터를 주고받는 것이 아니라 커널의 소켓 버퍼를 거쳐서 처리됨 2. 커널 소켓 버퍼구분역할Send BufferApplication이 write()한 데이터를 네트워크로 보내기 전 임시 저장Receive Buffer네트워크에서 받은 데이터를 Application이 read()하기 전 임시 저장 3. I/O 처리 모델Blocking I/O현재 I/O를 수행할 수 없다면 호출한 Thread를 기다리게 ..

1. How It Works동작 순서순서구성요소역할1ClientGateway로 HTTP Request 전송2Gateway Handler Mapping요청이 어떤 Route와 매칭되는지 판단3Gateway Web Handler매칭된 Route의 GlobalFilter + GatewayFilter를 모아 Filter Chain 실행4Pre Filter인증, Rate Limit, Header/Path 수정 등 Backend 호출 전 처리5Proxy Request실제 Downstream Service로 HTTP Request 전달6Post FilterBackend Response가 돌아온 뒤 Header 추가, Logging 등 후처리7Client최종 HTTP Response 수신 2. Route Predica..

1. Creating a New Sequence…​Lazy하게 생성하는 방식을 제공함✅ Subscription 시점에 실제 값을 생성함 APIAPI설명핵심Mono.fromCallable()반환값이 있는 작업을 Subscription 시점에 실행하여 Mono로 생성반환값 → onNext, Exception → onErrorMono.fromRunnable()반환값이 없는 작업을 Reactive Sequence로 생성값 없이 완료 여부만 표현 예제) Mono.fromCallable()더보기Mono userMono = Mono.fromCallable(() -> userRepository.findById(1L)) .subscribeOn(Schedulers.boundedElastic());Bloc..

많은 데이터를 묶음 단위로 나누는 방식을 제공함 1. Grouping with Flux>같은 Key를 가진 데이터끼리 묶는 방식하나의 값은 하나의 그룹에만 속함✅ 각 그룹은 GroupedFlux⚠️ 생성된 GroupedFlux를 실제로 소비해야 데이터를 가져올 수 있음API설명핵심groupBy(Function)같은 Key를 가진 데이터를 각각의 GroupedFlux로 분리Flux → Flux>concatMap()생성된 Group을 하나씩 순차적으로 소비A 그룹 완료 → B 그룹 → C 그룹, 그룹 간 순서 보장예제) groupBy()더보기Flux.just(1, 3, 5, 2, 4, 6) .groupBy(i -> i % 2 == 0 ? "even" : "odd"); 예제) concatMap()더보기F..

0. WebClient란?WebFlux에서 사용하는 Non-Blocking Http Client✅ Reactor 기반 동작✅ Mono / Flux 형태로 응답 처리✅ Streaming 지원➡️ Thread나 동시성 처리를 직접 관리 안함➡️ Server측과 동일한 Codec 체계를 사용하여 Request/Response를 Encode/Decode 가능 1. retrieve()응답을 추출할 때 사용 예시) 전체 ResponseEntity 받기더보기WebClient client = WebClient.create("https://example.org");Mono> result = client.get() .uri("/persons/{id}", id) .accept(MediaType..

0. DispatcherHandler란?WebFlux 요청 처리의 중심✅ FrontController 역할을 담당함 (DispatcherServlet와 비슷)✅ 'webHandler'란 이름으로 빈 등록되며, WebHttpHandlerBuilder가 주변 구성요소들을 모아 WebFlux 처리 Chain에 넣어줌✅ 다양한 Delegate Component를 활용하여 적절한 Handler를 호출함 1. Special Bean TypesDispatcherHandler는 요청을 직접 전부 처리하지 않고, Spring Bean들에게 작업을 위임함Bean Type역할대표 구현체HandlerMappingRequest를 처리할 Handler를 찾음(가장 먼저 매칭된 Handler가 선택됨)- RequestMapping..

spring-web 기반 구조✅ reactive web application을 위한 저수준 기반 기능을 제공함✅ 서버: HTTP Server → HttpHandler → WebHandler API → Controller / Functional Endpoint✅ 클라이언트: HTTP Client → ClientHttpConnector → WebClient 1. HttpHandler서로 다른 HTTP Server를 WebFlux의 공통 Reactive 처리 구조에 연결하는 최소 추상화✅ HTTP Request를 받아 Response를 Non-Blocking으로 처리하고, 처리 완료 여부를 Mono로 반환✅ Netty, Tomcat, Jetty 처럼 서로 다른 서버 API를 Webflux가 동일한 방식으로 사..

1. Spring Webflux란?Reactive Streams와 Reactor 기반Non-blocking 방식으로 HTTP 요청을 처리하는 Spring의 Reactive Web Framework비동기 작업을 Operator + Function Chain 형태의 선언형 API 제공⚠️ 기존 Servlet 기반 Web MVC는 기본적으로 Blocking을 허용하는 구조✅ 동시 요청이 많아지면 이를 감당하기 위해 많은 Thread가 필요함➡️ 적은 Thread로 많은 동시 요청을 처리하는 것이 목적 2. Define “Reactive”Reactive는 변화나 Event가 발생했을 때 반응하는 Programming Model임ex) Network I/O 준비 → Event 발생 → Handler 실행 Non-..

0. 'reactor-core' 모듈Reactor의 핵심 모듈.Publisher를 구현하면서 다양한 Operator를 제공하는 타입 제공✅ 대략 몇개의 데이터를 발행하는지 타입 자체로 표현함 1. Flux, an Asynchronous Sequence of 0-N Items 0~N개의 데이터를 비동기적으로 발행할 수 있는 Publisher✅ Infinite Stream: Flux는 반드시 종료되는 Stream일 필요는 없음. SignalSignal의미onNext(T)데이터 1개 전달onComplete()정상적으로 Stream 종료onError(Throwable)Error로 Stream 종료 예시) 여러 데이터 발행더보기Flux.just("A", "B", "C") .subscribe(System.o..

0. Reactive Programming이란?Reactive Programming은 비동기 데이터 Stream과 변화의 전파를 다루는 Programming Paradigm이다.✅ 데이터가 도착하면 Subscriber에게 전달✅ 값뿐 아니라 Error / Complete도 Signal로 전달✅ 처리 과정을 명령형이 아니라 선언형 Chain으로 표현 Iterator vs Reactive Streams구분IteratorReactive Streams데이터 요청 방식Consumer가 직접 가져옴Publisher가 Subscriber에게 전달대표 구조Iterable → IteratorPublisher → Subscriber처리 방식ImperativeDeclarative다음 데이터next() 호출onNext() S..