实战SpringCloud响应式微服务系列教程(第二章)
- 2019 年 10 月 3 日
- 筆記
???????SpringCloud???????????????
1.1.2??
????????????????????????????????
1.?????
????/????????????????????????????????????????????????????????????????????????
?????
?????????????????????1.1.1??????????????????????????????????????????????????????????????????????
????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
???????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
2.???????
??????????????????????????????
1??????
??????????????????????????????????????????????????????????????????????????????????????????????????????????????????
??????????????????????????????????????????????????????????????????????????????????????
2???????
?????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????1.1.1???????
1.1.3 ????
???????????????????????????????????????????????????????
1.??????
???????????????????????????????????????????????????????????????????????????????????????????????????????????
?????????????????????????????????????????????????????????????????????????????????????????????Spring WebFlux???web???Reactor?????????????????????????reactor??
?????????????????????????????????????????????????????????????????????????????????????????
2.??????
Java API?????4?????Publisher<T>
?Subscription
?Subscriber<T>
?Processor<T,R>
?
1?Publisher<T>
????Publisher???????????????????????????????????????????????
public interface Publisher<T>{ public void subscribe (Subscriber<? super T> s); }
2?Subscriber<T>
????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
public interface Subscriber<T>{ public void onSubscribe(Subscription s); public void onNext(T t); public void onError(Throwable t); public void onComplete(); }
???????subscribe()
??????????????onSubscribe()
????????????????????Subscription ????????n???????????????onNext()
??????????n???????????????????onComplete()
???????????n???????????????????????onError()
????????????????????
3?Subscription
???Subscription ????????????????????????????????????????????????????????????????????????????????
public interface Subscription{ public void request(Long n); public void cancel(); }
??????subscribe()
????????????????????onSubscribe()
??Subscription?????????????Subscription???request()
????????????
Publisher<T>
?Subscription
?Subscriber<T>
????????
4?Processor<T,R>
????Processor??????????????????Processor
?????Publisher
?Subscribe
???????????/??????????
Processor<T,R>
????T????????????R???????????????????/??????????????????????
public interface Processor<T,R> extends Subscriber<T>,Publisher<R>{ }
Processor
?Subscriber
?Publisher
????????????????
?????????????????????????????????????????????????????????????????????????????