实战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????????????????

?????????????????????????????????????????????????????????????????????????????