markdown Flux响应式编程]

Posted 2021-05-05

### 1 构建一个retry
```
Retry<?> retryOptimisticLockException = Retry.anyOf(OptimisticLockingException.class)
                                                               .retryMax(10)
                                                               .doOnRetry(ctx -> log.debug(
                                                                   "Retrying after OptimisticLockingException",
                                                                   ctx.exception()
                                                               ));
                                    
// usage 
this.find(id)
                   .flatMap(application -> remappingFunction.apply(id, application))
                   .flatMap(this::save)
                   .retryWhen(this.retryOptimisticLockException);
```
### 2 静态Flux 转化为动态
```
val producer=Flux.create(xxx)
val dp=producer.publish(); // 发布
dp.subscribe(xxx)
dp.subscribe(xxx)
dp.connect(); // 激活
```
### 3 Flux.generate 可以同步生成序列,可以有重载方法添加计数等状态

### 4 Flux.create 可以异步生成序列

### 5 Flux.then 方法可以等待Complete后返回Mono<Void>
### 6 *Flux.first*  方法,返回第一个返回的
### 7 switchIfEmpty 如果为空的话转换一个
### 8 justOrEmpty   just高级方法
### 9 flatMap 返回1对多的Flux,注意是异步线程.