非阻塞套接字实现并发处理

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()

 

以上是关于非阻塞套接字实现并发处理的主要内容,如果未能解决你的问题,请参考以下文章

高性能网络IO模型

如何使用非阻塞套接字正确处理发送/写入?

11 非阻塞套接字与IO多路复用(进阶)

Windows Sockets 非阻塞模式

Java并发编程实战 第15章 原子变量和非阻塞同步机制

非阻塞套接字与IO多路复用