非阻塞套接字实现并发处理
Posted gluneko
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了非阻塞套接字实现并发处理相关的知识,希望对你有一定的参考价值。
服务端
import socket server = socket.socket() server.setblocking(False) server.bind((‘0.0.0.0‘,8080)) server.listen(1000) all_connection = []#所有连接的客户端,用集合比列表更快 while True: try: connection,remote_address = server.accept()#非阻塞对等连接套接字生成 connection.setblocking(False)#connection是新生成的,也需要设置成非阻塞 all_connection.append(connection) except BlockingIOError: pass to_handler = [connection for connection in all_connection] for connection in to_handler: try: recv_data = connection.recv(1024) if recv_data: print(recv_data) connection.send(recv_data) else: connection.close() all_connection.remove(connection)#如果这个客户已经处理完毕,就移除 except BlockingIOError: pass
客户端
import socket host = ‘192.168.215.128‘ port = 8080 client = socket.socket() client.connect((host,port)) # client.send(b‘haha‘) msg = input(‘-->‘) client.send(msg.encode(‘utf-8‘)) recv_data = client.recv(1024) print(recv_data.decode(‘utf-8‘)) client.close()
以上是关于非阻塞套接字实现并发处理的主要内容,如果未能解决你的问题,请参考以下文章