python - Twisted 中的新传输和读取器类型

Question

我正在尝试向 Twisted 添加一个新的传输，它将从流中读取数据——tail -f 方式的文件，或者从管道中读取数据，但我遇到了一些问题采用 Twisted 架构。

我已经准备好了传输本身(实现ITransport)——它处理所有文件打开。我已经准备好流功能/延迟。我现在怎么把它放在一起？我想将新数据报告回某些协议(protocol)的 dataReceived()。

我当然可以创建一个新对象，它将设置具有适当回调的 I/O 监视器，在 reactor 关闭时注册一个回调(以关闭文件/协议(protocol))并手动启动一切 - 但是“正确的方法”？我可以使用更好的抽象吗？我见过 reactor.connectWith()，但它并没有真正提供太多的抽象...

另外 - 我应该如何将数据从我的阅读器传递到协议(protocol)？ ITransport 没有为它定义任何接口(interface)，尽管它看起来完全是传输的责任。

Answer 1

听起来您基本上已经知道如何执行此操作了。您可能对 twisted.internet.fdesc.readFromFD 感兴趣，但它只有几行，而且没有做任何特别复杂的事情(不过，你不必维护几行)。除此之外 - 是的，在这种情况下你必须进行 I/O 监控，因为 select/poll/epoll 不支持常规文件描述符(它们总是被报告为就绪，而不是你想要的)。

在 Twisted ( http://twistedmatrix.com/trac/ticket/972 ) 中支持 inotify 已经完成了一些工作，但这还没有完成，所以它现在不会直接对你有用(除非你想帮助完成它然后使用它) .假设您只是使用基于时间的轮询，那么 react 堆中的大部分内容不会对您有太大帮助，因为该代码专注于使用系统提供的就绪 API(即 select/poll/epoll)来触发事件.

不过，对于管壳，您应该能够使用并受益于 IReactorFDSet的方法 - addReader等

您的基于时间的轮询传输可能仍会受益于实现 ITransport - 虽然我不确定你会如何实现 write对于 tail -f - 像交通工具。您肯定会受益于通过 IProtocol 传输数据接口(interface)，因为这简化了代码重用。 IProtocol.dataReceived这正是您希望从阅读器 传递数据的方式(我认为这与您的传输 相同，不是吗？)。这未在 ITransport 上定义因为它是您在其他不是传输的对象上调用的方法。

reactor.connectWith可能不会给你买任何东西。正如您所说，这不是什么抽象；我会说这更像是一个错误。 :)

不要太担心无法直接向 react 堆添加方法。接受 react 器作为参数的自由函数同样易于使用。

对于关机回调，addReader实际上应该让你完成大部分工作。关闭时 react 堆中的任何阅读器都会有 connectionLost调用它(IFileDescriptor 的一部分)。您应该实现此操作以清理文件和协议(protocol)。