Python中的Socket魔法：如何利用socket模块构建强大的网络通信

python 代码解读复制代码import socket

# 创建TCP套接字
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 绑定到指定地址和端口
server_socket.bind(('localhost', 9999))

# 开始监听，最大排队数量为5
server_socket.listen(5)
print('Server listening on port 9999...')

while True:
    # 接受客户端连接
    client_socket, addr = server_socket.accept()
    print(f'Got connection from {addr}')
    
    # 接收数据
    data = client_socket.recv(1024)
    if not data:
        break
    
    # 发送回复
    client_socket.send(data)
    
    # 关闭连接
    client_socket.close()

python 代码解读复制代码import socket

# 创建TCP套接字
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 连接到服务器
client_socket.connect(('localhost', 9999))

# 发送消息
message = 'Hello, Server!'
client_socket.sendall(message.encode())

# 接收回复
response = client_socket.recv(1024)
print(f'Received: {response.decode()}')

# 关闭连接
client_socket.close()

python 代码解读复制代码import socket
import threading

clients = []

def broadcast(message, client):
    for c in clients:
        if c != client:
            c.send(message)

def handle(client):
    while True:
        try:
            message = client.recv(1024)
            broadcast(message, client)
        except:
            index = clients.index(client)
            clients.remove(client)
            client.close()
            break

def receive():
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.bind(('localhost', 9999))
    server_socket.listen()

    while True:
        client, addr = server_socket.accept()
        print(f"Connected with {str(addr)}")
        
        clients.append(client)
        thread = threading.Thread(target=handle, args=(client,))
        thread.start()

if __name__ == "__main__":
    receive()

python 代码解读复制代码server_socket.setblocking(0)  # 设置为非阻塞

python 代码解读复制代码import select

inputs = [server_socket]
outputs = []

while inputs:
    readable, writable, exceptional = select.select(inputs, outputs, inputs)
    
    for s in readable:
        if s is server_socket:
            connection, client_address = s.accept()
            connection.setblocking(0)
            inputs.append(connection)
        else:
            data = s.recv(1024)
            if data:
                outputs.append(s)
            else:
                inputs.remove(s)
                if s in outputs:
                    outputs.remove(s)
                
    for s in writable:
        s.send(b'Hello, world!')
        outputs.remove(s)
        
    for s in exceptional:
        inputs.remove(s)
        if s in outputs:
            outputs.remove(s)