[系统运维] python socket 对阻塞模式，使用多线程进行读写分离

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 系统运维 -> python socket 对阻塞模式，使用多线程进行读写分离 -> 正文阅读

[系统运维]python socket 对阻塞模式，使用多线程进行读写分离

server.py

import socket
import time
import threading

sock = socket.socket()
sock.bind(('127.0.0.1', 9006))
sock.listen()


def socket_recv_handle(client_socket):
    while True:
        r = client_socket.recv(1024)
        print(client_socket.getpeername())
        print('recv: ', r)


def socket_send_handle(client_socket):
    cnt = 1
    while True:
        print(cnt)
        client_socket.send(b'server %d' % cnt)
        cnt += 1
        print('send: ', client_socket.getpeername())
        time.sleep(1)


while True:
    client_sock, client_addr = sock.accept()
    # 使用多线程，对阻塞式socket进行读写分离，避免读取时候一直被阻塞
    threading.Thread(target=socket_send_handle, args=(client_sock,)).start()
    threading.Thread(target=socket_recv_handle, args=(client_sock,)).start()

client01.py

import socket
import time

sock = socket.socket()
sock.connect(('127.0.0.1', 9006))
cnt = 1
while True:
    print(sock.recv(1024))
    sock.send(b'client 01, cnt %d' % cnt)
    cnt += 1
    print(cnt)
    time.sleep(1)

client02.py

import socket
import time

sock = socket.socket()
sock.connect(('127.0.0.1', 9006))
cnt = 1
while True:
    print(sock.recv(1024))
    sock.send(b'client 02, cnt %d' % cnt)
    cnt += 1
    print(cnt)
    time.sleep(3)