一.Publisher 发布者

1
2
3
4
SubmissionPublisher<String> publisher = new SubmissionPublisher<>();  
for (int i = 0; i < 10; i++) {  
publisher.submit("p" + i);  
}

二.Subscriber 订阅者

onXXX:在xxx事件发生时,执行这个回调

三.Subscription 订阅关系

四.Processor 处理器

Mono: 0|1个元素流

Flux: N个元素的流