[webflux] PublishOn, SubscribeOn

 

WebFlux를 사용하는데 있어서, publisher와 subscriber 모델의 개념을 이해하는데까지 시간이 많이 소요가 되었다.

 

mvc로 개발할 때는 메서드 호출만 하면 결과값이 return이 되었다. 

webflux를 사용해 비동기식으로 개발을 할 때는 메서드만 호출해서는 원하는 결과를 얻기가 힘들다. 

 

webflux에서는 subscribe(구독) 을 해야 동작을 한다. 

 

 

PublishOn

• 신호 처리 스케줄링으로 
• onNext, onComplete, onError 가 지정된 Scheduler 의 스레드에서 신호 처리 스레드 설정
• 다음 PublishOn을 만날 때까지 같은 스레드에서 동작
• 안만나면 동작 끝내고 마침

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publishOn-reactor.core.scheduler.Scheduler-

 

SubscribeOn

• 시퀀스를 실행할 스레드를 결정
• PublishOn을 만날 때까지 같은 스레드에서 동작
• PublishOn이 신호를 처리할 스레드를 지정하므고 PublishOn 뒤에 오는 SubscribeOn 은 무시됨

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribeOn-reactor.core.scheduler.Scheduler-

 

 

 

 

 

참고

publishOne

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#publishOn-reactor.core.scheduler.Scheduler-

Flux (reactor-core 3.4.17)

 

subscribeOn

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#subscribeOn-reactor.core.scheduler.Scheduler-

Flux (reactor-core 3.4.17)