묻고 답해요
135만명의 커뮤니티!! 함께 토론해봐요.
인프런 TOP Writers
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
import com.itvillage.utils.Logger;
안녕하세요. '리액터의 구성 요소 및 용어 정의' 강의에서Flux sample 코드 작성시 import com.itvillage.utils.Logger; 를 import 해오는데, build.gradle 설정에서 어떤 의존성을 더 추가해야 할까요?plugins { id 'java' id 'org.springframework.boot' version '3.3.1' id 'io.spring.dependency-management' version '1.1.5' } group = 'com.example' version = '0.0.1-SNAPSHOT' java { toolchain { languageVersion = JavaLanguageVersion.of(17) } } configurations { compileOnly { extendsFrom annotationProcessor } } repositories { mavenCentral() } dependencies { implementation 'org.springframework.boot:spring-boot-starter-webflux' testImplementation 'org.springframework.boot:spring-boot-starter-test' testImplementation 'io.projectreactor:reactor-test' testRuntimeOnly 'org.junit.platform:junit-platform-launcher' compileOnly 'org.projectlombok:lombok' annotationProcessor 'org.projectlombok:lombok' } tasks.named('test') { useJUnitPlatform() } 검색해서 implementation 'com.itvillage:utils:1.0.0' 라는 것을 build.gradle 에 추가해봐도 되지 않더라구요.좋은 강의 잘 보고 있습니다. 감사합니다.
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Interceptor에서 reactor Context 유지하는 방법
외부에서 들어온 요청 헤더 정보를 Reactor Context에 저장하고, 내부적으로 grpc호출 할때 clientInterceptor에서 저장된 Context를 읽어오고 싶은데, Context0과 함께 읽지 못하는 문제가 있습니다.Interceptor에서도 읽어오려면 어떻게 해야할까요 ㅜㅜ외부 요청 헤더를 Context에 저장하는 코드@Component class RequestHeaderFilter() : WebFilter { companion object { const val X_REQUEST_ID_KEY = "X-Request-Id" } override fun filter(exchange: ServerWebExchange, chain: WebFilterChain): Mono<Void> { val requestId = exchange.request.headers.getFirst(HeaderNames.REQUEST_ID) return chain.filter(exchange) .contextWrite { context -> context.put(X_REQUEST_ID_KEY, requestId ?: "test!!") } .doFinally { } .subscribeOn(Schedulers.boundedElastic()) } }grpc 요청 interceptor에서 reator Context 조회하여 grpc Metadata에 추가하는 코드class CustomHeaderInterceptor() : ClientInterceptor { companion object { const val X_REQUEST_ID_KEY = "X-Request-Id" val X_REQUEST_ID_HEADER_KEY: Metadata.Key<String> = Metadata.Key.of("x-request-id", Metadata.ASCII_STRING_MARSHALLER) } override fun <ReqT : Any, RespT : Any> interceptCall( method: MethodDescriptor<ReqT, RespT>, callOptions: CallOptions, next: Channel ): ClientCall<ReqT, RespT> { return object : ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { override fun start(responseListener: Listener<RespT>, headers: Metadata) { Mono.deferContextual { context -> val requestId: String = context.getOrDefault(X_REQUEST_ID_KEY, fallbackRequestId()) ?: fallbackRequestId() headers.put(X_REQUEST_ID_HEADER_KEY, requestId) delegate().start(responseListener, headers) Mono.just(requestId) }.subscribe() } } } private fun fallbackRequestId() = "${UidUtils.generateUid()}"
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 2부
filterWhen의 차이
filter와 달리 filterWhen은 비동기로 동작한다고 했는데, 실제 예제를 돌려보면 동일하게 동기로 돌아가는 것 같습니다. FilterWhenExample01 예제에서 종료 sleep을 10초로 늘려주고, 조건을 3_000 변경 후public static void main(String[] args) { Flux .fromIterable(SampleData.coronaVaccineNames) /** filterWhen : 데이터를 비동기적으로 filtering 하고 싶을때 사용 */ .filterWhen(vaccine -> isGreaterThan(vaccine, 3_000)) .subscribe(Logger::onNext); TimeUtils.sleep(10000); } isGreaterThan 메소드에서 비동기 동작 확인을 위해 sleep 1초를 주었습니다.public static Mono<Boolean> isGreaterThan(SampleData.CoronaVaccine coronaVaccine, int amount) { TimeUtils.sleep(1000); return Mono .just(vaccineMap.get(coronaVaccine).getT2() > amount) .publishOn(Schedulers.parallel()); } 예상 결과로 아래 출력 5건이 1초 후 동시에 나올 것이라 생각했는데 동기와 동일하게 1초당 1건씩 출력이 됩니다.> Task :FilterWhenExample01.main()14:37:55.393 [main] DEBUG reactor.util.Loggers - Using Slf4j logging framework14:37:56.494 [parallel-1] INFO com.itvillage.utils.Logger - # onNext(): Pfizer14:37:57.501 [parallel-2] INFO com.itvillage.utils.Logger - # onNext(): AstraZeneca14:37:58.513 [parallel-3] INFO com.itvillage.utils.Logger - # onNext(): Moderna14:37:59.527 [parallel-4] INFO com.itvillage.utils.Logger - # onNext(): Janssen14:38:00.537 [parallel-5] INFO com.itvillage.utils.Logger - # onNext(): Novavax 좀더 간단한 예제로 아래 코드는 동기적으로 1초당 1건씩 출력되어, filter와의 차이점을 모르겠습니다.public static void main(String[] args) { Flux .range(1, 20) .filterWhen(num -> { TimeUtils.sleep(1000); // 예시를 위해 잠시 대기 return Mono.just(num % 2 == 0); }) .subscribe(Logger::onNext); }filterWhen의 특성을 정확하게 나타낼 수 있는 예제와 설명을 부탁드립니다감사합니다~
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
예시코드는 webflux의 이점보단 webclient의 이점 아닌가요?
for문 5번 도는데, resttemplate은 blocking / webclient은 non-blocking 이라 결과가 달라진 것 같아서요 보내는게 non-blocking 이면 mvc도 결과가 동일 했을 것 같아요
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
advancedTimeBy와 thenAwait 사용 예시가 궁금합니다
안녕하세요, advancedTimeBy와 thenAwait 사용 예시를 모르겠어서 문의드립니다.강의 중 advancedTimeBy는 '특정 시간을 당겨서 앞서 나가는 것'이라 설명해주셨고, thenAwait은 해당 시간이 빠르게 다가오는 걸로 이해하면 된다고 설명해주셨습니다. 궁금한 점은1) 각각의 테스트가 필요한 예시를 조금만 더 자세히 들어주실 수 있으실까요? 특정 프로젝트에서 어떤 상황일 때 해당 방법이 필요한지 감이 잡히지 않습니다.1-2) 어떤 상황에 필요한 것인지 모르다보니, advancedTimeBy와 thenAwait의 쓰임이 분명히 구분돼 있을텐데도 유사한 방식이 아닌가? 라는 생각이 듭니다. 이 부분도 예시로 설명해주실 수 있다면 함께 설명해주시면 감사하겠습니다.
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
context의 read, write의 실행 순서
안녕하세요, context의 read와 write 부분을 듣다 궁금한 점이 생겨 질문을 남깁니다.Context는 체인이 맨 아래에서부터 위로 전파된다는 내용은 이해했습니다.궁금한 점은 'Context read 읽는 동작이 Context write 동작 밑에 있을 경우에는 write된 값을 read할 수 없'는 동작을 컴퓨터는 어떻게 이해하고 실행하는지를 모르겠습니다. 위에서부터 아래로 코드를 읽어나가면 contextWrite()는 마지막에 읽히게 되니까요.컴파일하면서 write의 위치가 바뀌어 write가 먼저 진행되는지 혹은 subscribe()를 만나기 전까지는 실제 stream이 동작하지 않아 write된 값이 저장돼 있는지..코드 작동 순서/원리가 궁금합니다. 감사합니다.
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
DROP 전략과 LATEST 전략의 차이점이 무엇인가요?
안녕하세요. 수업 잘 듣고 있습니다~백프레셔 전략 중 DROP과 LATEST 전략은 결국 버퍼가 비워질 때까지 Publsiher에서 emit되는 데이터를 제거(drop or discard)하는 것으로 이해했습니다. 버퍼가 비어지는 시점 이후로 emit되는 데이터를 다시 버퍼에 채운다는 점에서 두 전략은 같은 것으로 보입니다. 차이점을 알려주시면 감사하겠습니다~
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
백프레셔 전략 관련해서
폐기와 드랍의 차이를 정확히 모르겠습니다. subscriber 입장에선 버퍼가 다시 비어져 있을 때 처리는 똑같아 보이는데 폐기는 publisher 에서 데이터 삭제를 의미하고 drop 은 데이터 건너 뛰기로 이해 하면 될까요?
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Backpressure Example 코드 질문드립니다
기존 예제 (sleep 시간이 5L인 경우)에선 Exception이 발생하는 것을 확인했습니다. 하지만 sleep 시간을 더 늘리니까 Erorr가 발생하지않았습니다. 제 예상대로라면 버퍼가 더 빨리 차기 때문에 에러가 발생해야하는데, 동작이 이해가 되지 않습니다. public class BackpressureStrategyErrorExample { public static void main(String[] args) { Flux .interval(Duration.ofMillis(1L)) .onBackpressureError() .doOnNext(Logger::doOnNext) .publishOn(Schedulers.parallel()) .subscribe(data -> { // 왜 50L, 500L로 하면 에러가 발생하지 않을까? TimeUtils.sleep(500L); Logger.onNext(data); }, error -> Logger.onError(error)); TimeUtils.sleep(5000L); } }
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Backpressure 전략
안녕하세요~ 유익한 강의 정말 감사드립니다.Backpressure 기법에 대해 강의를 듣던 중 궁금한 게 생겼습니다.Error, latest, drop, ignore 등의 backpressure 기법은 buffer에 데이터가 다 찼을 때 데이터를 drop 하는 것 같은데 drop되는 data들은 유실 된다고 볼 수 있을까요?그게 아니라면 re-try하는 과정이 backpressure 이후에 진행되는 건지 궁금합니다.
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Flux 와 Mono
흔히 Spring Boot WebFlux 라고 공고에도 많이 올라오고 , 사람들이 많이들 부르는데, 이때 WebFlux 는 Mono 를 제외한 Flux 인가요 ??아니면 Mono 와 Flux 를 모두 포함해서 WebFlux 라고 하나요 ??
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Spring WebFlux 를 사용하기 적합한 시스템
일반적인mvc rest api 를 사용하지 않고 , spring web flux 를 사용해도 되나요 ?? 그렇게 많이 사용하고 있나요 ?
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Sinks 와 thread-safe
안녕하세요.강의 중 Sinks가 thread-safe 하다는 이야기가 잘 이해가 안 가서 질문 드립니다.혹시 예시를 들어 설명해주실 수 있나요?구글링 해봐도 어떤 원리로 therad-safe 한지 이해가 안 가서요.
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Mono 의 정의를 잘 모르겠습니다..
안녕하세요 문의 사항이 있어 글을 올립니다.@PutMapping("/{userId}") public Mono<User> updateUser(@PathVariable Long userId, @RequestBody UserUpdateRequestDto userRequestDto) { return mainService.updateUser(userId, userRequestDto); }public Mono<User> updateUser(Long id, UserUpdateRequestDto userUpdateRequestDto) { // 데이터베이스에서 사용자 조회 return dataRepository.findById(id) .flatMap(existingUser -> { // 기존 사용자가 있으면 업데이트 수행 existingUser.setName(userUpdateRequestDto.getName()); // 다시 데이터베이스에 저장 return dataRepository.save(existingUser); }); } 과 같이 Mono<User> 를 리턴 하는데 포스트맨으로 응답이 json 형태로 옵니다.저는 User를 리턴한게 아닌 Mono<User> 를 리턴한건데 어떻게 포스트맨이 별도의 처리 없이 Mono 안의 User 값을 받을 수 있나요?Mono<User> userMono = webClient.get() .uri("/user/{id}", userId) .retrieve() .bodyToMono(User.class);위와 같은 코드를 보았는데 이 경우 Mono<User> userMono로 받게 되던데 결국 리턴은 Mono<User> 가 맞는거 같은데포스트맨이 어떻게 User 값을 바로 가져다 썼는지 이해가 잘 안가서 질문 올립니다.+ 추가로 mono나 flux는 subscribe()를 해줘야 동작을 한다고 하셨었는데 subscribe()를 적지 않았는데 어떻게 update가 동작한건지 궁금합니다.
-
해결됨Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 2부
혹시 다음강의부터는 ppt 한번에 묶어서 올려주실수있나요?
일일히 다운받으려니까 힘들기도하고 자료들이 피피티 파일 하나에 다 담겨있는게 나중에 복습하기도 편할거같아서요
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
RestTemplate과 Webclient
webflux를 사용할때, webClient를 사용하게 되는데, non-blocking하게 동작해서,,, 란 추상적인 의미 때문에 사용합니다. webclient는 왜 non-blocking 하게 작동하는 걸까요?.. 제대로 이해하지 못하고 사용하는것 같은데, 강사님께 설명 부탁드립니다. 그에 반해 RestTemplate, openFeign은 사용하지 않는데,예제코드를 보니 다음과 같이 사용해도 똑같이 non-blocking 하게 작동할까요?Mono.just(restTemplate.get()).subscribe() Mono.just(feign.get()).subscribe()
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
이벤트 루프와 요청핸들러 관련해서 질문있습니다.
안녕하세요 이벤트 루프와 요청 핸들러 관련해서 질문이 있습니다.netty의 이벤트는 channel에서 발생한다고 들었는데 그림의 요청핸들러가 channel인가요? 만약 channel이 맞다면 그림에선 핸들러가 한개지만 실제는 클라이언트 요청수 만큼 channel이 생성되는게 맞나요? 다른 질문의 답변을 보니 이벤트루프가 cpu 코어 개수만큼 생성된다고 하셨는데 여러 요청들은 이벤트루프를 무작위로 선택하나요?만약 클라이언트의 요청이 DB io 를 사용하는데 비동기방식을 지원하지않는 jdbc라면 해당 스레드는 이벤트 루프 없이 blocking으로 DB 작업을 처리하는게 맞나요?
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
Logger 문의
안녕하세요~ 해당 강의를 촬영한 시점이 2년전정도? 되는거 같은데Logger::OOO 이 사용이 되지 않는다면 @Slf4j어노테이션 사용을 권장드립니다.log.info 메서드를 통해 로깅을 하실 수 있어요
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
.contextWrite의 실행시점
안녕하세요예제 코드에서 질문이 있습니다.@SneakyThrows public static void main(String[] args) { String key = "message"; Mono<String> mono = Mono.deferContextual(ctx -> Mono.just("Hello" + " " + ctx.get(key)) .doOnNext(msg -> log.info("context value : {}", msg))) .subscribeOn(Schedulers.boundedElastic()) .publishOn(Schedulers.parallel()) .transformDeferredContextual((mono2, ctx) -> mono2.map(data -> data + " " + ctx.get(key))) .contextWrite(context -> context.put(key, "Reactor")).doOnNext(msg -> log.info("contextWrite value : {}", msg)); mono.subscribe(data -> log.info("data : {}", data)); Thread.sleep(100L); } 설명하시는 내용을 들어보면 코드의 순서와 상관없이.contextWrite()이 먼저 발생하여 context에 {message, Reactor} 값을 저장하고Mono.deferContextual가 실행되어 ctx에서 contextWrite에서 했던 값을 가져오고 있습니다. 이부분이 잘 이해가 안가는데요그전 강의까지는 `.subscribeOn`, `.publishOn` 이런 메서드의 체이닝은 탑다운 방식으로 진행되었었는데Context부터는 순서가 달라 혹시 실행하는 우선순위가 있는지 궁금합니다.
-
미해결Kevin의 알기 쉬운 Spring Reactive Web Applications: Reactor 1부
마지막 예제에 질문있습니다.
안녕하세요.마지막 Context 예제에서 "직교성을 가지는 정보를 표현할 때 주로 사용된다."라고 하셨는데 "직교성", "애플리케이션에 영향을 주지않는 데이터"의 의미가 정확하게 와닿지가 않아서요! jwt토큰을 단순히 변수에 값을 저장하고 파라미터로 넘기는것과 context에 담아서 넘기는 것에 어떤 차이가 있나요? 사실 context를 어떻게 활용해야될지 잘 모르겠어요....ㅜㅜ