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（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。