服务器实现的多种方法汇总

普通套接字方法（socket套接字）

from socket import socket
server = socket() 4 server.bind(('', 9999))
server.listen(10)

conn, addr = server.accept()
recv_date = conn.recv(1024)
if recv_date:
    print(recv_date)
    conn.send(recv_date)
else:
    conn.close()

 非阻塞套接字方法（非阻塞套接字）

from socket import socket
server = socket()
server.setblocking(False)
server.bind(('', 9999))
server.listen(100)

all_client = []
while True:
    try:
        conn, addr = server.accept()
        conn.setblocking(False)
        all_client.append(conn)
    except BlockingIOError:
        pass

    for conn in all_client:
        try:
            recv_date = conn.recv(1024)
            if recv_date:
                print(recv_date)
                conn.send(recv_date)
            else:
                conn.close()
                all_client.remove(conn)
        except BlockingIOError:
            pass

 IO多路复用epoll方法（IO多路复用epollselector实现服务器）

import socket
import selectors 
epoll_selector = selectors.EpollSelector() 
server = socket.socket()
server.bind(('', 9980))
server.listen(1000)

def recv(conn):
    recv_date= conn.recv(1024)
    if recv_date:
        print(recv_date.decode())
        conn.send(recv_date)
    else:
        epoll_selector.unregister(conn)  
        conn.close()

def accept(server1):
    conn, addr = server1.accept()
    epoll_selector.register(conn, selectors.EVENT_READ, recv)

epoll_selector.register(server, selectors.EVENT_READ, accept)

while True:
    events = epoll_selector.select()
    for key, mask in events:
        callable = key.data    
        sock = key.fileobj  
        callable(sock)

多进程方法（详解）

import multiprocessing
from socket import socket
server = socket()
server.bind(('', 9999))
server.listen(100)

def func(conn):
    while True:
        recv_date = conn.recv(1024)
        if recv_date:
            print(recv_date)
            conn.send(recv_date)
        else:
            conn.close()

while True:
    conn, addr = server.accept()
    m = multiprocessing.Process(target=func, args=(conn, ))
    m.start()

 线程方法

from socket import *
import threading

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

def func(conn):
    while True:
        recv_date = conn.recv(1024)
        if recv_date:
            print(recv_date)
            conn.send(recv_date)
        else:
            conn.close()

while True:
    conn, addr = server.accept()
    T = threading.Thread(target=func, args=(conn, ))
    T.start()

 进程池/线程池方法（方法介绍）

from socket import socket
from multiprocessing import Pool, cpu_count
from multiprocessing.pool import ThreadPool

def process_accept(server):         
    thread_pool = ThreadPool(n)    
    while True:
        conn, addr = server.accept()   
        thread_pool.apply_async(thread_recv, args=(conn, )) 

def thread_recv(conn):          
    while True:
        recv_date = conn.recv(1024).decode()
        if recv_date:
            print(recv_date)
            conn.send(recv_date.encode())
        else:
            conn.close()
            break

server = socket()
server.bind(('', 8899))
server.listen(200)

n = cpu_count()     
pool = Pool(n)      
for i in range(n):
    pool.apply_async(process_accept, args=(server, ))  
pool.close()
pool.join()

 gevent协程实现

from gevent import monkey; monkey.patch_socket()
from socket import socket
import gevent


server = socket()   
server.bind(('', 7788))
server.listen(1000)

def recv(conn):
    while True:
        recv_date = conn.recv(1024).decode()
        if recv_date:
            print(recv_date)
            conn.send(recv_date.encode())
        else:
            conn.close()

while True:
    conn, addr = server.accept()
    gevent.spawn(recv, conn)