예제

Sol님, 안녕하세요?노션 문서를 PDF 문서로 변환하는 과정에서 글자가 잘린것을 확인했습니다.PDF 문서를 업데이트 해놓겠습니다.우선 노션 문서의 링크 자체에 접근 가능하도록 해드릴테니, 아래 링크로 접속하셔서 문서 확인하시면 되겠습니다. Stream API 강의 자료 및 연습문제 링크 https://www.notion.so/section1-class03-Stream-API-e2177c8ca10e469bb80f145ad7a01a3a?source=copy_link불편을 드려서 죄송합니다!

자바 2탄 3탄 커리큘럼 문의

안녕하세요? 추석 연휴는 잘 보내셨나요? 답변이 좀 늦어서 죄송하고 좋은 질문 해 주셔서 감사합니다. ^^질문 주신 부분들에 대해서 제 의견을 잠깐 말씀 드릴게요. "강사님의 강의 철학과 같이 자바 기본 문법들을 배우고 다양한 예제를 단계별로 풀어보며 비로소 왜 이렇게 돌아가는지 메커니즘이 궁금할때 위에 딥한 강의를 찾아보는게 낫다고 생각이 듭니다"--> 프로그래밍 언어를 배울때 일반적으로 두 가지 방식의 학습 방법이 있다는건 잘 알고 계실거에요. 하나는 특정 프로그래밍 언어의 문법 및 사용법 위주의 강의나 책을 모두 완강 또는 완독하고 난 후에 다음 스텝을 밟는것. 또 하나는 일단 아주 최소한의 사용법만 익힌 뒤 간단한거라도 만들어 보면서 막히는 부분이 있으면 다시 책을 찾아보면서 막히는 부분을 해결하면서 앞으로 나아 가는 것.둘 중에 어떤게 더 낫다 그렇지 않다라고 말씀 드리긴 어렵겠지만(사람마다 자신에게 맞는 학습 방법이 다를테니까요) 제 경험상 후자 쪽이 흥미를 잃지 않고 성장하기가 더 쉬운 것 같았습니다.그래서 Java 관련 미니 프로젝트 강의를 만들고 있는 중이구요. 요즘엔 한국인들도 영어로 잘 말하는 분들이 많지만 제가 영어를 배울때만 해도 문법 위주로 영어를 배웠는데 결국 외국인들 만나서 말 한마디 못하고, 외국인이 말하는 내용을 알아 듣지도 못하는 그런 상태가 되어버렸는데요. ^^;프로그래밍 언어도 우리가 배우는 영어라는 언어를 배우는것과 꽤나 비슷한 것 같더라구요.기본 문법이나 고급 기법을 배워도 이걸 이용해서 아주 작은 애플리케이션이라도 만들어보지 않으면 이걸 왜 배우고 어디에 써먹을 수 있는지 깨닫기 어렵다는 사실은 프로그래밍을 배우는 많은 분들이 느끼는 고민이라고 생각합니다.영어로 자신 있게 말할 수 있다는건 Java로 내가 생각하는대로 구현을 할 수 있다는 말과 같은 것 같고, 영어를 잘 알아 듣는다는 건 다른 사람이 짠 코드(Chat GPT 같은 AI 포함)를 잘 이해할 수 있다는 말과 비슷한것 같아요.이런 이유때문에 제 강의 수강생 인원이 적긴하지만 나름 현실적으로 도움이 될만한 괜찮은 강의라고 생각하고 있습니다. ^^; "혹시나 이 소인의 의견을 긍정적으로 보시고 관련된 내용이 반영 된다면 제발 주니어 입장에서 자세한 설명과 쉬운거 부터 단계별로 다양한 문제로 부탁 드립니다"--> 1부 강의의 세 가지 애플리케이션을 다 만들어보셨는지는 모르겠지만 1부 강의에 나오는 애플리케이션만 만들어 보셔도 나중에 웹 애플리케이션을 만들 때 Java의 왠만한 문법들은 잘 사용을 하실거라고 생각해요. 결론은 1부 강의가 제일 쉬운 단계입니다. ^^; 그것보다 더 쉬운건 실무적으로는 도움이 안될 거 같아서 제외한 부분도 있습니다. ^^; 2부 같은 경우에는 이번달에 오픈 예정인데 굉장히 중요한 주제로 프로젝트를 진행할 예정이에요. 태경님 주변을 돌아보면 '주문'과 관련된 서비스가 굉장히 많다는걸 아실 수 있을텐데요. 예를 들면 배달 앱, 쇼핑몰, 오픈 마켓, 티켓 예매 등등 무수히 많은 서비스가 무언가를 주문하는 시스템이죠. 그래서 주문이라는 도메인을 활용해서 어떤 애플리케이션을 직접 만들어보는건 굉장히 중요하다고 생각합니다.참고로 2부 강의는 1부 강의보다는 조금 더 난이도가 있기때문에 1부에서 구현에 대한 기본기를 잘 쌓으신 다음에 수강하시는게 머리가 덜 아프지 않을까 하는 의견드립니다. ^^; 3부는 위에서 태경님께서 잠깐 언급하셨던 Thread를 어떻게 활용할 수 있는지 왜 사용하는지에 대한 부분이 포함된 애플리케이션을 만드는 강의를 2부 강의 오픈 후에 순차적으로 오픈할 예정이에요.JavaFX를 이용해서 UI가 있는 굉장히 재미있는 애플리케이션을 만들어 볼 예정입니다. "마지막으로 ㅇ..이러면 안되지만.. ㅎ..혹시 2, 3탄 ㄹ..론칭 할인 할인 쿠폰을 제공해주실 예정이 있으신가욥..?"--> 쿠폰 제공하는게 그리 어려운 일이 아니라서 가능할 것 같습니다. ㅎㅎ 참고로 오픈때는 할인된 가격으로 오픈을 할 예정이니 가격에 대한 부담은 크지 않을 것 같다는 생각이 드네요.ㅎ그리고 1부 강의보다 2부 강의는 오히려 조금 더 낮게 책정할 예정이에요. 강의 퀄리티가 낮아서가 아니라 Java 입문하시는 분들 입장에서 1부도 중요하지만 2부가 더 중요하다고 판단되어서 혹여나 부담되는 가격때문에 제 강의를 안듣는 케이스를 줄이고 싶은 바램이 있어서 그렇습니다.제가 유명한 강사가 아니다보니 가격이 너무 낮으면 오히려 강의 퀄리티 의심이 따를수는 있겠지만 그건 어쩔 수 없죠. 제 강의 들으신 분들이 잘 판단해 주셔서 좋은 강의라고 말씀해 주시길 바랄 뿐입니다. ㅎㅎ 질문해 주신 부분에 대한 답변이 잘 되었는지 모르겠네요.더 궁금한게 있으시면 언제든지 편하게 말씀해 주세요. 감사합니다~

깃허브 주소 오류

안녕하세요? 불편을 드려서 죄송합니다.'강의 소개 > 학습 자료' 섹션에 총 4개의 Github 링크가 있고, 확인해보니 모두 Public Repository로 잘 연결이 되는데 혹시 어떤 경로로 접속해보니 접속이 안되시는지 여쭤봐도 될까요?

window 예제 1번 request(n) * maxSize 부분을 잘 모르겠습니다.

안녕하세요? 제가 해외에 있어서 답변이 조금 늦어진 점 양해 부탁드리겠습니다. 지금쯤 주무시고 계실것 같은데 여긴 아침이라서 아침 먹고 바로 답변쓰고 있습니다. ^^; 궁금해 하시는 내용이 아마도 window()라는 operator를 어떤 상황에서 적절하게 사용할 수 있는지 라고 생각되어서 이 부분을 말씀드릴게요. 공식 문서에서도 설명이 되어 있지만 window() operator는 upstream의 데이터를 지정된 개수만큼 포함한 flux window로 쪼개어서 downstream에서 처리하도록 한다 라고 나와있습니다.flux window라는건 말 그대로 window라는 단위로 데이터가 포함되어 있는데 이 데이터들을 각각의 flux를 이용해서 개별적으로 처리할 수 있다라는건데요(개별적으로 처리할 수도 있고, List로 변환해서 한꺼번에 처리할 수도 있을테구요).다만, buffer(maxSize) 같은 경우에는 maxSize만큼 데이터를 쪼개서 버퍼에 담지만 Downstream으로 내려줄때 flux가 아닌 List 형태로 내려줍니다.flux로 내려주느냐 List로 내려주느냐는 확연한 차이점이 있습니다.flux를 전달받으면 flux에서 emit되는 개별 데이터를 처리하기 위해 다른 Operator 들을 이용해서 유연하게 처리할 수있고, 비동기적인 처리도 손쉽게 할 수 있기 때문에 buffer 보다 조금 더 상황에 맞는 유연한 처리가 가능하다라고 생각합니다. buffer()는 쪼개어서 List에 담긴 데이터들을 한 번에 모아서 일괄 처리하는데 중점을 둔 operator이기 때문에 window() operator보다는 좀 더 처리가 심플할테구요. 물론 buffer가 아니라 window operator를 이용해서 buffer처럼 데이터를 한번에 일괄 처리할 수도 있을텐데 이 경우에 비동기적으로 처리할 수 있기 때문에 효율성 측면에서 더 나을 수 있다고 생각합니다. 한마디로 buffer는 쪼개어진 데이터에 대한 단순 일괄 처리, window는 단순 일괄 처리 이상의 작업들(비동기 처리, 데이터의 복잡한 가공처리, 지연 처리 등)을 처리할 때 사용한다. 이렇게 생각하시면 될 것 같아요. 답변이 도움 되셨으면 좋겠네요.감사합니다! 좋은 꿈 꾸세요~

subscription signal 에 upstream 으로 이동하는 순서

안녕하세요. 좋은 질문 주셔서 감사드립니다.아래 링크를 보시면 Reactor에서 signal이 어떤 흐름으로 발생하는지 정리가 잘 되어 있는데, 한번 읽어보시면 도움이 되실 것 같아요.https://itvillage.tistory.com/entry/Reactor-Sequence%EC%97%90%EC%84%9C-%EB%B0%9C%EC%83%9D%ED%95%98%EB%8A%94-signal%EC%9D%98-%EC%A0%84%ED%8C%8C-%ED%9D%90%EB%A6%84일단 핵심만 간략하게 말씀드리면, Reactor의 Operator는 기본적으로으로 Operator 하나를 Operator 체인에 연결할 때 마다 내부적으로 subscribe()가 한번씩 발생되면서 Upstream 쪽으로 subscription이 전파되는 식으로 전파가 끝나면 데이터가 Downstream 쪽으로 emit 되는 형태로 동작을 하는데요.이 흐름에 맞춰서 Context의 동작도 발을 맞추는 거라고 생각을 합니다.그런데 어떤 Operator 들(특히 Thread 관련된)은 내부 동작이 꽤 복잡해서 위 아래로 왔다 갔다하는 흐름도 보입니다.아무튼 링크에 적힌 내용들 천천히 읽어보시면 도움되실 것 같습니다.감사합니다~

Webflux의 Non-Blocking 특성에 대해 문의 드립니다.

안녕하세요. Non-Blocking에 관해서 질문을 주셨는데요.WebFlux에서 Non-Blocking이라는 개념은,Java에서 쓰레드를 추가로 할당해서 동시성의 형태로 여러 요청을 번갈아 처리하는 구조라기보다는,요청을 처리하는 쓰레드(이벤트 루프)가 특정 작업에 묶이지 않고 자유롭게 움직일 수 있는 상태, 즉 Blocking 되지 않은 상태를 말합니다.즉, Reactor 체인에서 별도의 쓰레드를 사용하지 않아도, Reactor-Netty 서버는 각 요청을 처리하는 흐름이 Blocking되지 않으면 하나의 이벤트 루프 ㅆ레드로도 여러 요청을 빠르게 처리할 수 있습니다.하지만 만약 어떤 요청이 순차적으로만 처리되고, 다른 요청이 기다리는 현상이 발생한다면,그건 보통 요청 처리 로직에서 Blocking 연산이 있거나, CPU 연산이 오래 걸려서이벤트 루프가 다음 요청으로 넘어가지 못하고 쓰레드가 점유된 상태일 가능성이 큽니다.즉, WebFlux의 Non-Blocking은 쓰레드가 작업 도중 Blocking 되지 않게 만드는 처리 방식임을 이해하는 것이 중요하다고 생각합니다.아직 3부를 제작하지 않은 상태여서 Spring MVC와 Spring WebFlux를 비교하는 샘플 테스트에서는 클라이언트에서 단순 for문을 이용해서 요청 처리를 시뮬레이션 했는데요.만약에 실무적으로 쓰레드가 Blocking 되지 않는다 라는 사실을 확인하려면 여러 클라이언트가 동시 다발적으로 요청을 보내는 상황을 만들어야 하고, 서버측 WebFlux 애플리케이션에서도 DB 등의 I/O까지 Fully Non-Blocking하게 처리하는 상황을 만들어서 테스트 해야하는데, 말씀하신 코드를 지금 다 만들기에는 사실상 무리가 있어서 3부 강의 때 말씀드려야 할 것 같아요.이점 양해 부탁드리고, Non-Blocking의 의미는 쓰레드가 Blocking 되지 않게 하는것이지 우리가 알고 있는 멀티 쓰레드 작업 처리 방식처럼 동시에 요청을 처리하는것은 아니라는 사실은 꼭 기억을 해주시면 감사드리겠습니다.

Downstream Mono, Flux가 subscriber인가요?

안녕하세요? Downstream Flux, Mono에 대해서 질문을 주셨는데요.아래 간단한 코드를 예로 들면(Mono도 같은 원리라고 보시면 됩니다.)Flux .just(1, 2, 4) .filter(num -> num % 2 == 0) .subscribe(result -> System.out.println(result));just()는 일반적으로 최초로 데이터를 emit하기 때문에 생산자, Publisher, 발행자로 이해하면 됩니다.그런데 filter() 입장에서는 just()가 Upstream Flux가 되고, 반대로 just() 입장에서는 filter()가 Downstream Flux가 됩니다.이렇게 부르는 이유는 just()와 filter() 같은 Operator들이 리턴하는 리턴 타입이 Mono 또는 Flux이기 때문입니다.즉, filter() 입장에서는 윗쪽에 있는 just()가 리턴하는 Flux를 이용해서 다음 흐름을 이어가기 때문에 just()가 Upstream Flux가 되는 것입니다. 그리고 Subscriber는 내부적으로 좀 복잡한 과정을 거치는데 다 이해하실 필요는 없고, 일반적으로 .subscribe(...) 여기에서 ... 에 해당되는 람다 표현식이 Subscriber라고 이해하셔도 무방할 것 같습니다. 혹시 제 설명이 좀 어려우시다면 just()와 filter() 같은 Operator 내부로 들어가셔서 리턴 타입을 직접 눈으로 확인하시면 좋을 것 같아요. 감사합니다!

onErrorResume을 사용하지 않는 모든 경우 예외 발생 시, 시퀀스는 종료되나요?

안녕하세요. 주말이라서 답변이 좀 늦었네요.onErrorResume 같은 에러 처리를 위한 Operator를 사용하지 않으면 기본적으로 Sequence 내에서 에러가 발생하면 Subscriber에게 onError Signal 형태로 에러 정보가 Exception 형태로 전달됩니다. 다만, onErrorResume을 사용하지는 않지만 특정 상황에서 onErrorContinue Operator를 사용하거나 retry Operator를 사용하면 에러 발생 시점에 Sequence가 즉시 중단되지 않을 수는 있습니다.방금 말씀 드린 내용은 error handling 섹션에 있는 영상으로 확인하실 수 있습니다. AI 인턴이 답변 남겨두었듯이 doOnError 같은 Operator를 이용하면 에러를 직접적으로 핸들링하는건 아니지만 에러가 발생했을 때, 로그를 남긴다든지 하는 후속 작업을 통해 에러를 간접적으로 알려서 추후에 디버깅을 할 수 있습니다. 디버깅 관련해서는 1부 영상을 확인하시면 될 것 같습니다.감사합니다.

source.next와 source.emit의 차이에 대한 질문입니다.

안녕하세요? 어제 일찍 잠이 드는 바람에 답변이 좀 늦어졌네요. 양해 부탁드리겠습니다. ^^; 우선 아래 예제를 실행시켜 보시면 next() 호출 후에 onComplete signal이 발생하지 않기 때문에 Sequence가 종료 되지 않고 무한 대기 상태가 되는걸 확인하실 수가 있는데요. TestPublisher source = TestPublisher.create(); StepVerifier .create(source.flux()) .expectSubscription() .then(() -> source.next(2, 4, 6, 8, 10)) .expectNext(2, 4, 6, 8, 10) .expectComplete() .verify(); 말씀하셨던대로 TestPublisherTestExample01에서 expectComplete()이 통과하는 이유는 zipWith()를 사용했기 때문입니다. 아래 그림을 보시면 zipWith()의 파라미터로 전달한 Flux에서 데이터 emit이 끝나면 onComplete signal이 발생하는데 zipWith()의 경우 둘 중 하나의 Sequenc가 종료될 경우 최종적으로 합쳐진 Source Flux에서 onComplete signal이 발생합니다.(사진)

StepVerifier를 이용한 Testing (1) - expectNoEvent 에 관해서

안녕하세요? expectNoEvent()의 의미가 조금 헷갈리시죠?테스트 하셨던 코드처럼 .expectNoEvent(Duration.ofMinutes(1)) 를 두 번 연달아 호출했다고 해서 2분의 딜레이 타임을 가진다라는 의미가 아니라 매 1분(여기서는 두 번 호출했으니까 총 2분이겠죠) 즉, 총 2분 동안 단지 어떠한 이벤트도 발생하지 않았는지를 단순히 검증만 하는 것이라서 .expectNoEvent(Duration.ofMinutes(1)) 를 호출했다고 해서 getVoteCount()에서 리턴한 Flux의 Tuple 데이터가 emit 되지는 않고 예제 코드에서처럼 expectNext()를 호출해야 데이터 하나가 emit이 됩니다.지금 테스트 해 보셨던 코드에서는 ... .expectNoEvent(Duration.ofMinutes(1)) .expectNoEvent(Duration.ofMinutes(1)) .expectNext(Tuples.of("강서구", 32040)) ... ....expectNoEvent(Duration.ofMinutes(1)) 를 두 번 호출 한 다음에 호출한 .expectNext()가 세번째 .expectNext() 이기 때문에 "강서구"가 맞으므로 테스트에 통과하는 것입니다. 그리고 아직 테스트 대상 메서드의 Flux에서 emit되지 않은 데이터가 남았는데 expectNext()나 expectNextCount() 등으로 남아있는 데이터의 emit에 해당하는 onNext 이벤트를 트리거 해주지 않으면 테스트 코드가 종료되지 않고 무한정 기다릴 수 있는 상황도 발생할 수 있으니 참고해 주시면 좋을 것 같아요.