多線程處理Socket并發

server

            
              #!/usr/bin/env python
import socket
import threading

server = socket.socket()
server.bind(('', 9999))
server.listen(5)


def readThread(conn, addr):
    """
    創建一個新的線程，負責和一個客戶端通訊
    :param conn:
    :param addr:
    :return:
    """
    while True:
        data = conn.recv(1024)
        if data:
            print('{}:{}'.format(addr, data))
        else:
            print("客戶端{}已關閉".format(addr))
            break
    conn.close()


while True:
    print('------主線程，等待客戶端連接------')
    conn, addr = server.accept()
    print('創建一個新的線程，和客戶端{}通訊'.format(addr))
    # 創建一個子線程，負責消息收發
    client = threading.Thread(target=readThread, args=(conn, addr))
    # 啟動線程
    client.start()


            
          

client

            
              #!/usr/bin/env python
# -*- coding: utf-8 -*-
import socket

# 創建套接字
s = socket.socket()
# 連接套接字，ip和端口必須是服務器上的
s.connect(('127.0.0.1', 9999))
while True:
    data = input("輸入發送消息:")
    if 'q' == data:
        s.close()
        break
    s.send(data.encode())
    # print('接受服務器返回的消息：', s.recv(1024))
# s.close()


            
          

多進程處理Socket并發

server

            
              #!/usr/bin/env python
# -*- coding: utf-8 -*-

import socket
import threading
import multiprocessing

server = socket.socket()
server.bind(('', 9999))
server.listen(5)


def readProcess(conn, addr):
    """
    創建一個新的線程，負責和一個客戶端通訊
    :param conn:
    :param addr:
    :return:
    """
    while True:
        data = conn.recv(1024)
        if data:
            print('{}:{}'.format(addr, data))
        else:
            print("客戶端{}已關閉".format(addr))
            break
    conn.close()


while True:
    print('------主線程，等待客戶端連接------')
    conn, addr = server.accept()
    print('創建一個新的進程，和客戶端{}通訊'.format(addr))
    # 創建一個子進程
    p = multiprocessing.Process(target=readProcess, args=(conn, addr))
    p.start()


            
          

?

參考：https://blog.csdn.net/lianjiaokeji/article/details/83095187

?