Reactor3

首页 > TAG信息列表 > Reactor3

Reactor3 SpscLinkedArrayQueue源码分析

前言 Reactor3在BUFFER背压策略下，当Publisher发布元素后会先到一个缓存队列中，然后由生产者推送或者消费者拉取。SpscLinkedArrayQueue就是这其中的队列。在JDK9中引入了响应式的接口Flow，在JDK中有一个Flow.Publisher的实现SubmissionPublisher。SubmissionPublisher的背压就

Spring WebFlux(Reactor3)响应式编程处理异常

前言文中部分内容翻译自Reactor Guide，对Reactor Guide中举的一些例子做了一些修改和增减，更方便大家的理解。从命令式编程刚开始接触Reactor对于异常的处理可能会有些不知所措。有很多人说，刚毕业的同学和工作了几年的同学在处理异常上会有很大的区别。是因为刚毕业的同学可能

Reactor3 功能介绍二十四: ConnectableFlux

Flux<Long> flux = Flux.interval(Duration.ofMillis(50), Duration.ofMillis(100)) .take(5) .doOnSubscribe(s -> System.out.println("subscribed to source")); flux.subscribe(x -> { System.out.println("____" + x);

Reactor3 源码解析一: 一个简单的例子

拆解源码之前，可以先参阅入门文章 Project Reactor 核心原理解析及Reactive响应式流入门。实例： Flux.just("tom", "jack", "allen") .filter(s -> s.length() > 3) .map(s -> s.concat("@qq.com")) .subscribe(System.out::println)