一开始我们建立TCP连接, 传入主机地址, 端口, 协议工厂对象作为参数,随后reactor.run挂起运行。
下面我们看看ClientFactory基类,因为我们自定义的协议工厂EchoClientFactory派生自它。源码:
class ClientFactory(Factory): """A Protocol factory for clients. This can be used together with the various connectXXX methods in reactors. """ def startedConnecting(self, connector): """Called when a connection has been started. You can call connector.stopConnecting() to stop the connection attempt. @param connector: a Connector object. """ def clientConnectionFailed(self, connector, reason): """Called when a connection has failed to connect. It may be useful to call connector.connect() - this will reconnect. @type reason: L{twisted.python.failure.Failure} """ def clientConnectionLost(self, connector, reason): """Called when an established connection is lost. It may be useful to call connector.connect() - this will reconnect. @type reason: L{twisted.python.failure.Failure} """
同样的,我们自定义的EchoClientFactory不过就是实现了基类中没有实现的函数,其中最重要的还是buildProtocol, 它为我们生成一个协议,下面看下我们自定义的协议类Echo, 基类源代码与上面的是一样的.
客户端的协议函数与服务器端的协议函数是一样的,在这里就不多说。
客户端的twisted模块讲完了,随后我们创建了一个线程去和服务器端通信, 并且定时发送, 当然,在这里我们为了以防万一,需要判断是否已经与服务器取得了连接,随后才发送消息.
大概讲了下基础部分,所有的代码都是来自《python高效开发实战》里的代码,在这里也向大家推荐这本书,学习twisted还有两个不错的教程,在最后我会发百度网盘共享。之所以写这篇基础的,就是为了能够理解高效开发实战里的最后一个项目: 用Twisted开发跨平台物联网消息网关。因为第一次实习就接触到了物联网通信,在工作时,滚了一遍项目的源代码(java写的,但我毕竟也是学了C#, .net两年的人, 看懂项目源码没压力, mvc orm都是与.net中的EF, MVC差不多, 不过就是语法有点不同),正好和书上的这个项目差不多,书上将服务器与客户端的通信协议指令都讲得很清楚。因此这是一本不容错过的好书, 也是学习, 精通twisted的最好途径
最后就是运行测试:
服务器端:
客户端:
twisted教程PDF文档可以到Linux公社资源站下载:
------------------------------------------分割线------------------------------------------
具体下载目录在 /2017年资料/7月/18日/Python 网络框架Twisted基础学习及详细讲解/
------------------------------------------分割线------------------------------------------