Python实现socket非阻塞通讯功能示例
本文实例讲述了Python实现socket非阻塞通讯功能。分享给大家供大家参考,具体如下:
非阻塞需要多线程编程
服务端
方式1:使用threading库实现多线程
基本方法和单进程基本写法一致,将收发部分封装为函数以便开启其他线程:
importsocket importtime importthreading defhandle_socket(conn,addr): whileTrue: data=conn.recv(1024) print(data.decode('utf-8')) time.sleep(3) send_data='gotit' conn.send(send_data.encode('utf-8')) conn.close()
基本设置和调用部分:绑定,监听,接受连接:
if__name__=='__main__': s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) s.bind(('0.0.0.0',8888)) s.listen() whileTrue: conn,addr=s.accept() client_thread=threading.Thread(target=handle_socket,args=[conn,addr]) client_thread.start()
方式2:通过继承StreamRequestHandler库实现多线程
收发部分写到handle方法中:
importsocketserver fromsocketserverimportStreamRequestHandler importtime classMyHandler(StreamRequestHandler): defhandle(self): #addr=self.request.getpeername() #print('getconnectionfrom',addr) #self.wfile.write('hello,thankforyourconnection'.encode()) whileTrue: datarecv=self.request.recv(1024) ifnotdatarecv: break time.sleep(3) print(datarecv.decode()) self.request.send("gotit".encode())
开启
myserver=socketserver.ThreadingTCPServer(('127.0.0.1',8888),MyHandler) myserver.serve_forever()
客户端
客户端:
importsocket conn=socket.socket(socket.AF_INET,socket.SOCK_STREAM) conn.connect(('127.0.0.1',8888)) whileTrue: conn.send('hello'.encode()) data=conn.recv(1024) print(data.decode())
更多关于Python相关内容可查看本站专题:《PythonSocket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。