问题标签 [reactor]

我正在基于 Epoll 用 C++ 实现异步模式 Reactor。首先，我们将通过调用函数向 Reactor 注册文件描述符

然后，调用永远运行的方法 hand_events

我的问题是如何在这种情况下组织存储模型：存储句柄，以及文件描述符和句柄之间的映射（是否有适合它的模式）

希望看到你的回答！

I am in the process of starting a new project (java-based). I need to build it as a modular, distributed and resilient architecture.

Therefore I would like to have the business processes to communicate among themselves, be interoperable, but also independent.

I am looking right now at two frameworks that, besides their difference in age, express 2 different views:

• Akka (http://akka.io)
• Reactor (https://github.com/reactor/reactor)

What I should consider when choosing one of the above frameworks?

As far as I understand till now, Akka is still somehow coupled (in a way that I have to 'choose' the actor I want to send the messages to), but very resilient. While Reactor is loose (as is based on event posting).

Can someone help me understand how make a proper decision?

UPDATE

After reviewing better the Event Bus of Akka, I believe in some way the features expressed by Reactor are already included in Akka.

For example the subscription and event publishing, documented on https://github.com/reactor/reactor#events-selectors-and-consumers, can be expressed in Akka as following:

Therefore it seems to me now that the major differences between the two are:

• Akka, more mature, bound to Typesafe
• Reactor, early stage, bound to Spring

Is my interpretation correct? But what is conceptually the difference between the Actor in Akka and the Consumer in Reactor?

我有一个非常简单的实用程序脚本，我用 JavaScript 为 node.js 编写了它，它读取一个文件，进行一些计算，然后写入一个输出文件。当前形式的源代码如下所示：

这很好用，但我想知道在这种情况下使用这些函数的同步种类是否有任何缺点，如下所示：

对我来说，这比回调类型更容易阅读和理解。在这种情况下是否有任何理由使用前一种方法？

我意识到对于我在本地运行的这个简单脚本，速度根本不是问题，但我有兴趣了解它背后的理论。什么时候使用异步方法有帮助，什么时候没有？即使在生产应用程序中，如果我只是读取一个文件，然后等待执行下一个任务，是否有任何理由使用异步方法？

Node 的所有文件系统 IO 操作都有一个异步/同步版本，但我想知道：如何在 Node.js 中实现异步文件 IO 以对本地文件进行操作？我自己在搞乱 libevent，它使用反应器模式，比如 Node，但是我读到在本地文件上使用事件 IO 是没有意义的，因为它们总是可读和可写的，所以它们会立即被操作。

如果这是真的，这些方法之间有什么区别，至少对于本地文件？

如果我通过这样做创建多个客户端：

我如何 - 优雅地 - 停止反应器？如果我做：

在协议中，然后执行：

在工厂里，下一个客户将尝试再次停止反应堆。但是，这当然会导致错误：

在这种情况下如何优雅地停止反应器？

首先，我想说这是我第一次使用反应器模式。我用我所拥有的知识尝试了一切，但没有任何成功。到目前为止，这是我的脚本：

并测试脚本我有这个

所以我创建了一个新的反应器对象，向它添加了一个事件监听器，然后调度事件。但在回调函数中，我希望“this”成为“test”对象。

我在主干应用程序上使用反应器http://getreactor.xtify.com/并尝试构建自定义收件箱。我使用 auto-run="false" 配置参数。然后我为 onBeforeMessage 定义一个函数

这个函数大部分时间都被调用了，但其他一些没有。第一个问题，尽管我指定了 auto-run="false" ，但为什么会触发 onBeforeMessage ？第二个问题为什么不总是触发 onBeforeMessage ？

我正在尝试找出我们应该在下一个项目中使用 Akka 还是 Reactor。最重要的问题之一是未来选择的框架是否会提供远程处理。正如我所看到的，Akka 以我们想要的方式提供了这个。

在 GitHub wiki 中，不幸的是 TCP-server/client 部分是空白的，我还找不到关于它的其他信息。

反应堆会提供远程处理吗？

我的服务器有问题。

当我想在 ThreadPool 中执行任务时服务器崩溃。

这是使用线程池的函数的一部分：

执行案例 666 时，服务器崩溃。（只有这种情况使用线程池进行测试）

有 WorkerThreadPool 类：

有 QuitHandler 类：

并运行定义：

记录“app.logger().information("quith");”之前的应用程序崩溃。

谢谢。

在扭曲的文档中，它说：

新的应用程序代码应该更喜欢在需要的地方传递和接受反应器作为参数，而不是依赖能够导入此模块来获取引用。这简化了单元测试，并且有朝一日可能更容易支持多个反应器（作为性能增强），尽管目前还不可能。

这样做的首选方法是什么？特别是，将它传递给协议的最佳方式是什么？（特别是当标准的 twisted.internet.protocol.Factory 就足够了。）

编辑：澄清一下，由于协议没有直接实例化，我想知道下面的方法是否是首选方法，或者是否有更好的方法允许访问协议中的反应器。

仅仅为了访问反应器而创建工厂类似乎有点愚蠢，因为想要访问反应器必须相当普遍。