스프링/--/뮌헨/ Flux<Dish> example Using Pub-Sub(Observer) Pattern

 

 

 

Reactive Stream 은 Pub-Sub(Observer) 패턴이다.

Reactive Programming
1. Non-blocking
2. Asynch
3. FP


수요조절(Backpressure)
Flux<T> 는 container 이다.



Future 의 리턴타입은 Scalar 이다
Flux 의 리턴타입은 Vector 이다,
just() 를 통해 비동기적으로 제공한다 (만들자 마자...)

주방장의 인스턴스를 생성자 주입으로 받는다(연관관계)
kitchen.getDishes() 는 알바가 주방에 가서 요리를 가져오는 모습이다.
요리가 완성되면 즉시 손님에게 전달한다 ... map()
Reactive Consumer 는 다른 Reactive Service 를 호출하고 결과를 변환(transform)한다
서빙 점원의 역할은 웹 컨트롤이다.

 

예제출처

http://www.yes24.com/Product/Goods/101803558?OzSrank=1 

스프링 부트 실전 활용 마스터 - YES24

 

에러발생

우측 에러 메시지를 보면 Parameter 0 of constructor in gradle_jin.JinService.dish.RestaurantController required a bean of type 'gradle_jin.JinService.dish.KitchenService' that could not be found. 이다.

 

KitchenService 의 객체가 없다는 뜻이다. that could not be found 는 Spring Context 에서 찾을 수 없다는 뜻이다.

이것은 KitchenService 를 생성하는 Annotation 을 붙이지 않아서 발생한다.