Twisted教程：构建TCP Finger服务器

4星 · 超过85%的资源需积分: 18 153 浏览量更新于2024-07-26 收藏 1.66MB PDF 举报

"这篇文档是关于Twisted框架的教程，名为‘啄木鸟twisted.pdf’，主要介绍了如何从零开始构建一个简单的TCP finger服务。教程由一系列逐步递增的功能实现构成，通过不同的示例逐步展示Twisted框架的使用方法。" 在Python的网络编程领域，Twisted是一个强大的事件驱动的网络编程库，它支持多种协议，如TCP、UDP、HTTP、FTP等，并提供了异步I/O模型，使得开发者能够高效地处理并发连接。文档的"拒绝连接"部分，可能是介绍如何设置服务器在接收到连接请求时拒绝服务，这通常用于测试或者配置阶段，确保服务器在不期望的条件下不会接受任何连接。接下来，文档提到了"反应器(Reactor)"，这是Twisted中的核心组件，负责处理I/O事件，调度任务并管理网络连接。反应器是事件驱动模型的心脏，它监听并响应各种事件，如连接建立、数据传输和连接关闭。 "什么也不做(DoNothing)"和"断开连接(DropConnections)"的章节，可能讲解了如何设置服务器在接收到连接后，不执行任何操作或者立即关闭连接，这对于理解Twisted的网络交互机制非常基础。 "读用户名，断开连接(ReadUsername,DropConnections)"和"读用户名，输出错误信息，断开连接(ReadUsername,OutputError,Drop Connections)"则可能涉及到了更具体的业务逻辑，服务器会尝试读取客户端发送的用户名，并根据读取结果做出不同响应，例如返回错误信息。 "从一个空的工厂(Factory)中输出(OutputFromEmptyFactory)"和"从一个非空的工厂(Factory)中输出(OutputfromNon-emptyFactory)"这部分，Factory是Twisted中用于创建协议实例的类，通常包含一些配置信息。空工厂可能指的是没有预设行为的简单工厂，而非空工厂则可能包含了具体的业务逻辑或数据。 "使用Deferreds(UseDeferreds)"是Twisted的一个重要特性， Deferreds是一种异步编程工具，用于处理回调和错误处理，使得在复杂的异步代码中可以更好地控制流程。 "在本地运行'finger'(Run 'finger' Locally)"可能是讲解如何使用Twisted实现一个本地的finger服务，finger服务通常用于获取远程用户的系统信息。 "从web上读取信息(ReadStatusfromtheWeb)"则涉及到网络数据获取，可能是讲解如何通过Twisted从网页中抓取信息。 "使用Application对象(UseApplication)"和"twistd(twisted)"部分可能涉及到Twisted的应用程序生命周期管理和命令行工具twistd，它是用来启动和管理Twisted服务的。最后，"twistedTUT01 Finger演化:创建一个简单的finger服务"整个教程以一个实际的finger服务为例，展示了从简单的拒绝连接到复杂的数据交互，逐步演化的过程，帮助读者深入理解Twisted框架的使用。这个教程对于初学者来说是一份很好的指南，它以实际的项目开发为线索，逐步介绍了Twisted的各种功能和用法，有助于读者掌握网络编程和异步编程的核心概念。

twistedTUT02 - Woodpecker.org.cn Wiki for CPUG http://wiki.woodpecker.org.cn/moin/twistedTUT02?action=print

第8页共10页 2008-4-9 23:54

40 self.users[user] = status

41 self.call = reactor.callLater(30, self._read)

42 def getUser(self, user):

43 return defer.succeed(self.users.get(user, "No such user"))

44 def getFingerFactory(self):

45 f = protocol.ServerFactory()

46 f.protocol, f.getUser = FingerProtocol, self.getUser

47 return f

48 def getResource(self):

49 r = resource.Resource()

50 r.getChild = (lambda path, request:

51 static.

Data('<h1>%s</h1><p>%s</p>' %

52 tuple(map(cgi.escape,

53 [path,self.users.get(path,

54 "No such user <p/> usage: site/user")])),

55 'text/html'))

56 return r

58 def getIRCBot(self, nickname):

59 f = protocol.ReconnectingClientFactory()

60 f.protocol,f.nickname,f.getUser =

IRCReplyBot,nickname,self.getUser

61 return f

63 application = service.Application('finger', uid=1, gid=1)

64 f = FingerService('/etc/users')

65 serviceCollection = service.IServiceCollection(application)

66 internet.TCPServer(79, f.getFingerFactory()

67 ).setServiceParent(serviceCollection)

68 internet.TCPServer(8000, server.Site(f.getResource())

69 ).setServiceParent(serviceCollection)

70 internet.TCPClient('irc.freenode.org', 6667,

f.getIRCBot('fingerbot')

71 ).setServiceParent(serviceCollection)

源程序

- listings/finger/finger16.py

7. 添加 XML-RPC 支持 (Add XML-RPC Support)

在 twisted 中，只是把对 XML-RPC 支持当作另外一个资源来处理。这个资源通过

render() 方法仍然可以支持 GET 访问，但这个方法一般都预留为一个还没有实现的

接口函数。注意：有可能会从 XML-RPC 方法中返回延期对象。当然，客户端是只

有等到这个延期对象被触发才会获得应答的。

In Twisted, XML-RPC support is handled just as though it was another resource. That

resource will still support GET calls normally through render(), but that is usually left

unimplemented. Note that it is possible to return deferreds from XML-RPC methods. The

client, of course, will not get the answer until the deferred is triggered.

切换行号显示

# 从文件读取资料，发布到 web、IRC、XML-RPC

twistedTUT02 - Woodpecker.org.cn Wiki for CPUG http://wiki.woodpecker.org.cn/moin/twistedTUT02?action=print

第9页共10页 2008-4-9 23:54

2 # Read from file, announce on the web, irc, xml-rpc

3 from twisted.application import internet, service

4 from twisted.internet import protocol, reactor, defer

5 from twisted.protocols import basic, irc

6 from twisted.web import resource, server, static, xmlrpc

7 import cgi

8 class FingerProtocol(basic.LineReceiver):

9 def lineReceived(self, user):

10 self.factory.getUser(user

11 ).addErrback(lambda _: "Internal error in server"

12 ).addCallback(lambda m:

13 (self.transport.write(m+"\r\n"),

14 self.transport

.loseConnection()))

15 class FingerSetterProtocol(basic.LineReceiver):

16 def connectionMade(self): self.lines = []

17 def lineReceived(self, line): self.lines.append(line)

18 def connectionLost(self,reason):

self.factory.setUser(*self.lines[:2])

19 class IRCReplyBot(irc.IRCClient):

20 def connectionMade(self):

21 self.nickname = self.factory.nickname

22 irc.IRCClient.connectionMade(self)

23 def privmsg(self, user, channel,

msg):

24 user = user.split('!')[0]

25 if self.nickname.lower() == channel.lower():

26 self.factory.getUser(msg

27 ).addErrback(lambda _: "Internal error in server"

28 ).addCallback(lambda m: irc.IRCClient.msg(self, user,

msg+': '+m))

30 class FingerService(service.Service):

31 def __init__(self, filename):

32 self.filename = filename

33 self._read()

34 def _read(self):

35 self.users =

{}

36 for line in file(self.filename):

37 user, status = line.split(':', 1)

38 user = user.strip()

39 status = status.strip()

40 self.users[user] = status

41 self.call = reactor.callLater(30, self._read)

42 def getUser(self, user):

43 return defer.succeed(self.users.get(user, "No such user"))

44 def getFingerFactory(self):

45 f = protocol.ServerFactory()

46 f.protocol,

f.getUser = FingerProtocol, self.getUser

47 return f

48 def getResource(self):

49 r = resource.Resource()

twistedTUT03 - Woodpecker.org.cn Wiki for CPUG http://wiki.woodpecker.org.cn/moin/twistedTUT03?action=print

第1页共4页 2008-4-9 23:54

介绍(Introduction)

编写可读代码(Write Readable Code)1.

twistedTUT03

Finger演化：整理finger代码

The Evolution of Finger: cleaning up the finger code

-- dreamingk [2004-08-09

02:09:38]

1. 介绍(Introduction)

这是Twisted教程《Twisted入门 - Finger

演化》的第三部分。

This is the third part of the Twisted tutorial Twisted from Scratch, or The Evolution of

Finger.

在本节教程中，我们将整理代码，以便让它更接近可读和可扩展的风格。

In this section of the tutorial, we'll clean up our code so that it is closer to a readable and

extendable style.

1.1. 编写可读代码(Write Readable Code)

Application的上一个版本有许多的伎俩。我们避开了子类化，不支持在web上的用户

列表之类的事情，和去掉所有的空行 -- 所有这些是为了让程序更短。这里我们将后

退一步，子类化(更自然地说是一个子类)可以做一些接受多行的工作来处理它们，

等等此类事情。这里显示了一种开发Twisted应用的更好的风格，尽管在前一阶段中

的伎俩有时可以用在被丢弃的原型中。

The last version of the application had a lot of hacks. We avoided sub-classing, didn't

support things like user listings over the web, and removed all blank lines -- all in the

interest of code which is shorter. Here we take a step back, subclass what is more naturally

a subclass, make things which should take multiple lines take them, etc. This shows a

much better style of developing Twisted applications, though the hacks in the previous

stages are sometimes used in throw-away prototypes.

Toggle line numbers

1 # Do everything properly

2 from twisted.application import internet, service

3 from twisted.internet import protocol, reactor, defer

4 from twisted.protocols import basic, irc

5 from twisted.web import resource, server, static, xmlrpc

6 import cgi

8 def catchError(err):

9 return "Internal error in server"

11 class FingerProtocol(basic.LineReceiver):

13 def lineReceived(self, user):

14 d = self.factory.getUser(user)

15 d.addErrback(catchError)

剩余242页未读，继续阅读

kondye

粉丝: 0

Twisted教程：构建TCP Finger服务器

网站啄木鸟5.9破解版（内有破解文件）

twisted网络通信模型

Twisted 17.9.0

expert Twisted.pdf

Python高效开发实战 Django Tornado Flask Twisted.pdf

The Twisted Documentation.pdf

twisted.internet.task与即时通讯：任务调度在Twisted.words的应用

【Twisted.application与Twisted.internet协同原理】：深入探讨协同工作

twisted.python.failure.Failure twisted.internet.error.ConnectionDone: Connection was closed cleanly.

Twisted.Network.Programming

最新资源