问题标签 [reactor]

我正在使用扭曲反应器来非阻塞读取套接字输入。但是，我想在反应器开始运行后运行另一个循环

问题是循环后reactor.run()不起作用while。我可以知道而不是在 main 中使用线程te = Thread(target=reactor.run, args=(False,)).start()，还有其他方法可以使reactor.run()工作非阻塞吗？

谢谢你。

我尝试使用带有嵌入式tomcat的spring boot webApplication和来自reactor的netServer开发一个“混合”服务器，以扩大我的Rest Api。没有 Spring 控制器，所有传入的请求都由 netServer 处理。无论如何，我都希望有一个使用 spring security 的登录页面，记住我的设施来验证用户并使用此身份验证来保护 reactor netServer 上的传入请求。

根据本教程reactor thumbmailer，我开始实现 netServer

这是我的网络服务器：

因此，当用户尝试加载他的个人资料时，传入的请求由 userController 处理：

这是 hack：getUserProfile 是一个静态方法，所以我不能使用 GlobalMethodSecurity 来保护它。然后我使用 StaticContextAccessor 在这个控制器中注入一个 userService ：

用户服务：

该服务由spring管理，所以我想我可以在它上面使用spring GlobalMethodSecurity（我仍在开发这部分，但我不确定这是保护我的netServer的最佳方式）

有没有更简单的方法在 reactor netServer 上使用 Spring 安全性？？？我的第一个网站版本是使用 nodeJS 开发的，以处理许多并发用户，我尝试使用 JVM nio 解决方案对其进行重构。那么 spring / reactor / netty 是拥有高度可扩展服务器的一个很好的解决方案，还是我应该使用类似 play 的东西！或 vertx.io ？

太感谢了

我正在评估 Reactor ( https://github.com/reactor/reactor ) 是否适合在我的 Spring / 企业应用程序中创建事件调度框架。

首先，考虑一个场景，其中您有一个接口A和具体的事件类B，C等等。我想将具体事件分派给多个消费者，即观察者。这些Reactor在 bean 后处理期间注册到全局实例。但是，您可以动态注册它们。在大多数情况下，只有一个生产者以高速率向多个消费者发送事件。

我使用Selector了 s，即，ClassSelector将正确的事件类型分派给正确的消费者。这似乎工作得很好。

要通知，请使用事件的类型作为键

但是，我想知道这是否是有效调度事件的建议方法？

其次，我想知道是否可以根据事件数据过滤事件？如果我理解正确，Selectors 仅用于检查密钥。我在这里指的不是事件标头，而是特定于域的对象属性。我想知道使用Streamsand Stream.filter(Predicate<T> p)，但是是否也可以使用Reactorand Selectors 进行过滤？当然，我可以编写一个委托消费者来检查数据并在需要时将其委托给注册消费者。

我在reactor-core 1.1.4-RELEASE下面尝试过，但没有打印出来。我应该错过什么？

@编辑

下面的测试确认接收器守护线程可以在处理事件之前退出。

我们正在评估反应堆库，以便在我们的项目中使用它。我们的项目得到了spring context的支持。所以我们需要一个工具来构建具有spring支持的事件驱动应用程序。

此外，我们主要关注的领域是组合异步事件序列的能力（流和承诺）。在某些其他用例中，我们可能需要发布者/订阅者模型或异步运行长时间运行的进程。

在我评估时，我注意到以下一些最新发布的 reactor-spring 版本是 v1.1.3，它依赖于我们可以使用的 reactor-v1.1.3。

但我也注意到有 reactor-v.2.0.0（正在开发中），它有很多变化，尤其是在 Streams 和 Promises 领域。

请建议我使用带有弹簧支持的 reactor-v1.1.3 是否是一个好主意，或者如果我们必须使用更多的 Streams 和 Promises，我们是否应该等待 reactor-v2.0。

如果我们继续使用 reactor-v1.1.3.RELEASE 可能需要进行多少代码更改才能将自己升级到 v2.0.0。

我还想检查我们是否有任何用于 reactor-v1.1.3/v1.1.4 的“反应器样本”分支。到目前为止，我只能看到一个可用的 master 分支，它已更新为使用 reactor-v2.0。

我们有最新版本 v1.1.4 的反应器 API。目前 API ( https://reactor.github.io/docs/api/ ) 指向 Reactor 1.1.0 Release。

我在哪里可以找到 reactor-core-2.0.0 代码库？我发现很难找到。

由于我是这个图书馆的新手，如果我提到的任何观点/问题不正确，请随时纠正我。谢谢。

经过几个小时的修补和尝试代码片段，我在stackoverflow中发现，我终于设法定期运行scrapy：

我的问题是，ReactorAlreadyRunning第二次运行后我仍然得到。我怎样才能解决这个问题？

我已经开始玩 Reactor，但我的第一个活动遇到了麻烦：D

按照github中的例子，我尝试写一个“hello world”但没有成功......

问题是什么？

代码：

输出：

我在我的 Web 应用程序中使用 Spring 的反应器模式。在内部，它使用LMAX 的 RingBuffer实现作为它的消息队列之一。我想知道是否有任何方法可以动态找出当前的 RingBuffer 占用情况。这将帮助我确定所需的生产者和消费者的数量（以及它们的相对比率），以及作为消息队列的 RingBuffer 是否得到最佳使用。我尝试了reactor.event.dispatch.Abs ​​tractSingleThreadDispatcher类的getBacklog()，但它似乎总是给出相同的值：我在实例化反应器时使用的 RingBuffer 的大小。 任何有关该问题的信息将不胜感激。

我正在评估反应堆库以在我们的项目中使用它。我用谷歌搜索了很多，但找不到 Netflix 的 RxJava 和 Spring 的 Reactor API 之间的区别（优点/缺点）。有人可以帮我决定或提供一些指示吗？

谢谢。

阿尔乔姆。很高兴看到新版本的 si。是否可以在 Spring 集成流程中使用反应器或 rxjava？像这样

例如：输入带有一些集合的xml=>reactive splitter->reactive transformer->reactive outbound