project-reactor

1热度

1回答

当当前正在执行的线程进入等待状态时，runOn（）方法为什么没有在池中的下一个可用线程上执行映射操作符？

我试图在4核心机器上执行以下代码。我在池中有5个线程，在map运算符中，我将执行线程休眠几秒钟。我想到的是，核心将放在执行的线程睡眠，当一个事件是可用的，应该从线程池的下一个可用线程中执行的地图操作，而不是我看到的行为。我看到池中的4个线程继续等待13秒，并且只有等待完成后才能处理下一个事件。为什么runOn()方法在线程进入等待状态时不对池中的下一个可用线程执行映射操作符？我使用的反应堆

0热度

2回答

如何使用Reactor创建随机数生成器？

我想通过反复发射随机数来模拟测量数据。我试着用反应堆做到这一点，但它不会产生任何输出： private static Random random = new Random(); public static void main(String[] args) throws InterruptedException { Flux<Double> doubleGenerator = Flux

0热度

1回答

基于反应堆的Spring MVC是什么？

我刚才一直在阅读关于Spring和电抗器尽我所能，做意识到，将反应器应该被包含在即将到来的Spring框架5（在生产BTW使用这个人？）我的兴趣是用它Spring MVC，因为它目前不是框架的一部分，在Spring MVC中如何使用Reactor？从网上的例子看来，在等待Framework 5的时候，现在在Spring中使用Reactor，就是使用reactor-bus。 Spring MVC

0热度

1回答

如何将长时间运行的任务返回到地图内？

我想单声道的映射函数内部转换数据： long result = 0.0; return Mono.just(result).map(value -> { // do some long running transformation here // and assign it to result (maybe 5 seconds task) // in our ca

0热度

1回答

将多个反应性Publisher/Flux/Mono对象组合到阻止请求中

我对被动世界非常陌生，并且很难理解如何完成任务。我正在开发一个遗留项目，我必须实现一个接口，该接口有许多方法可以从redis中查询各种对象。有时查询就像通过ID查询散列一样简单，因此只需一次调用redis即可获取散列。其他时候，我可能需要首先根据一些参数从redis集合中查找ID，然后使用生成的ID获取哈希值。我在Spring Boot应用程序中使用Reactor 3.1.0.M3和Lettuce

0热度

1回答

使用Flux而不是for循环，有什么好处？

我试图让我的周围反应式编程的头，所以我想问一下，如果有任何好处在这里使用助焊剂：它依赖于 override fun notifyObserversOnMessage(message: Message) { for (observer in observers) { observer.reactOnMessage(message) } } ：中

0热度

1回答

适应RxJava 1.1.5反应堆核心3.1.0.M3

我想使用RxJava 1.1.5与Spring WebFlux（即反应堆核心3.1.0.M3），但我无法适应ObservableFlux。我想这将是相对简单的，但我的适配器不工作： import reactor.core.publisher.Flux; import rx.Observable; import rx.Subscriber; import rx.Subscription;

0热度

1回答

使用Reactor实现http速率限制服务重试

我刚刚在Java中使用Reactor 3进行了反应式编程。我想使用reactor-netty实现一个http服务的客户端。到目前为止，我有非常基本的http请求被完美发送。但是，该服务期望客户遵守费率限制（通过传统的X-RateLimit-Limit，X-RateLimit-Remaining等标题通知客户）。我想要在速度限制时自动重试请求，但我不确定什么是最具“惯用”或有效的方式来做到这一点与

0热度

1回答

带有Project Reactor的Java：为什么Mono block（）没有看到错误？

给定以下代码，result.block（）等于“xx”，isError（）== false，但繁荣错误处理程序运行，堆栈跟踪显示，承诺未完成。我希望结果是“ko”。我在做什么错？块（）的Javadoc说将返回null的onComplete，T如果onNext public class RApp { static final Logger LOG = LoggerFactory.getLog

0热度

1回答

如何将订户与reactor.core.publisher.Flux连接？

我想连接用户和反应堆通量。然而我的小例子并不产生任何输出： public static void main(String[] args) throws InterruptedException { Flux.just("a", "b", "c") .subscribe(new BaseSubscriber<String>() { @Override