版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/JustWantToFly/article/details/88085192
1.Twisted采用基于事件的方法处理通信
2.创建自定义协议:
(1).使用Twisted自带的工厂-模块twisted.internet.protocol中的Factory类
(2).编写自定义协议时,将模块twisted.internet.protocol中的protocol作为超类
(3).调用时间处理程序connectionMade处理新连接
(4).调用connectionLost处理连接中断
(5).使用self.transport.write方法向客户端发送数据
(6).调用处理程序dataReceived接收客户端发送的数据
Twisted服务器端代码
#Python开发学习笔记:使用Twisted创建简单服务器
#导入Twisted相关包
from twisted.internet import reactor
from twisted.internet.protocol import Protocol,Factory
#编写自定义协议类;括号中的Protocol代表SimpleLogger继承至该类
class SimpleLogger(Protocol):
#定义方法用于处理到来的新连接
def connectionMade(self):
#self.transport:可用write方法发送数据,client中包含客户端的地址
print('Got connection from',self.transport.client)
self.transport.write(bytes("Thank you for connecting","utf-8"))
#定义方法接收客户端的数据
def dataReceived(self,data):
print("接收数据")
print(str(data,'utf-8'))
#定义方法用于处理连接中断;参数为调用改方法对象的本身,以及中断原因
def connectionLost(self,reason):
print(self.transport.client," disconnected")
#实例化工厂类
factory=Factory()
#通过设置Factory的protocol属性来通知工厂使用什么协议与客户端通信
#SimpleLogger是自定义的一个协议
factory.protocol=SimpleLogger
#调用模块reactor中的listenTCP方法监听端口
reactor.listenTCP(1234,factory)
#启动服务器
reactor.run()
客户端代码
扫描二维码关注公众号,回复:
5394397 查看本文章
#Python开发学习笔记:Python开发最简单的客户端
#导入套接字包
import socket
#实例化套接字
s=socket.socket()
#获取本机地址(由于是在同一台电脑上测试因此客户端的IP地址使用本机地址)
#如果服务器在外网,则host应该为服务器地址
host=socket.gethostname()
print(host)
port=1234
#连接服务器
s.connect((host,port))
#send方法发送需要在recv方法之前,否则服务端不能接收到消息
s.send(bytes("我是客户端,服务器你好!",'utf-8'))
#使用套接字的recv属性获取服务器返回的信息
print(s.recv(1024))
#尝试给服务器发送消息
s.close()