多線程處理Socket并發(fā)

server

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

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


def readThread(conn, addr):
    """
    創(chuàng)建一個(gè)新的線程，負(fù)責(zé)和一個(gè)客戶端通訊
    :param conn:
    :param addr:
    :return:
    """
    while True:
        data = conn.recv(1024)
        if data:
            print('{}:{}'.format(addr, data))
        else:
            print("客戶端{(lán)}已關(guān)閉".format(addr))
            break
    conn.close()


while True:
    print('------主線程，等待客戶端連接------')
    conn, addr = server.accept()
    print('創(chuàng)建一個(gè)新的線程，和客戶端{(lán)}通訊'.format(addr))
    # 創(chuàng)建一個(gè)子線程，負(fù)責(zé)消息收發(fā)
    client = threading.Thread(target=readThread, args=(conn, addr))
    # 啟動(dòng)線程
    client.start()


            
          

client

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

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


            
          

多進(jìn)程處理Socket并發(fā)

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):
    """
    創(chuàng)建一個(gè)新的線程，負(fù)責(zé)和一個(gè)客戶端通訊
    :param conn:
    :param addr:
    :return:
    """
    while True:
        data = conn.recv(1024)
        if data:
            print('{}:{}'.format(addr, data))
        else:
            print("客戶端{(lán)}已關(guān)閉".format(addr))
            break
    conn.close()


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


            
          

?

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

?