project-reactor

1热度

1回答

我有研究和阅读文件，他们不是很容易理解。我想实现的是以下功能：我正在使用Spring Reactor项目并使用eventBus。我的事件总线正在向模块A投掷事件。模块A应接收事件并插入到将保存唯一值的热流中。每250个Milisecons溪流应拉动所有的价值，并在他们身上进行冥想......等等。例如：的eventBus抛出事件与数：1,2,3,2,3,2 的流应该得到和保持独特的价值观

0热度

3回答

由于缺少可用的gradle依赖关系，无法构建https://github.com/reactor/reactor-samples

我使用Gradle插件在eclipse中克隆和导入了gradle项目。但我得到所有反应堆类的导入错误。项目中提到的BUILD.SNAPSHOTS都不能找到。 ./gradlew compileJava ：compileJava 失败：建立失败，一个例外。出错了：无法解析配置'：compile'的所有依赖关系。找不到io.projectreactor：reactor-stream：2.5.0

0热度

1回答

带DeferredResult和Reactor的Spring异步REST

这是我可以详细阐述的在REST调用中获得与Reactor的异步性的最佳想法，可用性如下：我不满意..有关如何更好地实现它的任何想法？（complete code here for reference） REST接口： @RestController public class REST_Interface { @Autowired public EventBus event

8热度

1回答

共享EventBus多个应用程序和容器堆

我期待它是如何通过Spring引导和电抗器有多个应用程序（它自己的Spring引导容器上运行的每一个），其使用一个独立运行的一个共享/共享EventBus - 单独的容器。它是一个具有多个应用程序的微服务环境，每个应用程序都是专用的，并且应该在事件链中调用。可能吗？这是代表场景图：预先感谢您。

0热度

1回答

重构遗留SOA系统使用非阻塞异步微服务

我刚开始尝试让我的头绕过RxJava，以便我可以使用项目反应堆重构遗留SOA系统使用非阻塞异步微服务。在我做了可行性研究，并考虑使用像勺子来改造传统服务代码的时刻（有无关然而这个问题）我想知道我会怎样使用reactor-bus Request/Reply语法来替换此同步服务代码。或者即使我应该使用完全不同的反应器结构。下面是一个传统的soa服务的例子，它被设计出来，因此它可能没有什么意义，但

5热度

2回答

Spring 5反应失败扩展Flux /实现Publisher并调用s.onNext（）多于一次

我刚开始玩新的Spring 5反应性支持，想模拟一些异步数据生成，注意到两个错误行为： 1）调用s.onNext（字符串）不止一次： @GetMapping("/strings") public Publisher<String> getStrings(){ return new Publisher<String>() { @Override public

13热度

1回答

Spring 5 Web反应式编程 - HTTP客户端的优点是什么？

允许假设具有延迟产生随机数的量的控制器的这两个场景： 1）反应性弹簧5的反应性应用： @GetMapping("/randomNumbers") public Flux<Double> getReactiveRandomNumbers() { return generateRandomNumbers(10, 500); } /** * Non-blocking randon n

3热度

2回答

Spring 5 Web反应式编程 - WebClient ClassCastException从Spring反应式控制器解编流式数据时的JSON

此问题与this one有关，其中我询问了如何从反应式弹簧控制器流式传输数据。正如Rossen指出的，我们必须使用text/event-stream将流结果作为服务器发送的事件发送回来，到目前为止情况非常好。我有一个这样的服务： @GetMapping(value="/accounts/alertsStreaming", headers="accept=text/event-stream")

-1热度

1回答

同时使用一个使用反应器的集合

不时需要在我参与的项目中实现经典的并发生产者 - 消费者解决方案，几乎在减少某些集合从多个线程填充以及哪些正在被多个消费者消费。简而言之，一旦缓冲区大小被命中，一个工作任务被提交消耗这些10k个实体，这个工作者的限制被称为10，这在最坏的情况下意味着我可以将其设置为10k实体，有多达10名工人每人消耗10k个实体。我必须玩一些锁定这里和那里缓冲区溢出（如果生产者产生太多的数据，而所有的工人都

0热度

2回答

flux.take（x）或flux.all（..）不等待所有排放

我有一个flux，它由8个元素的Iterable（Flux.fromIterable(..)）构建而成。每个通量发射，我想异步调用一个方法。我试过dispatchOn和publishOn，这种方式不行，我最终用map(CompletableFuture.supplyAsync(..), executor)来解决，它将flux转换成flux<CompletableFuture<Boolean>>。