epoll并发

epoll仅限Linux或Unix系统（服务器）。

片面讲epoll并发原理：1.数据共享（内存映射（mmap）技术），即client_socket_list和操作系统共享，省去拷贝fb给操作系统的时间

　　　　　　　　　　           2.事件监听（基于事件的就绪通知方式），不再是一直遍历客户端套接字列表来得知哪个套接字有数据，而是哪个套接字有数据直接传给操作系统。

epoll实现http服务器：

import socket
import re
import select


def service_client(client_socket, requests):
    """为这个客户端返回数据"""
    # 1.接收浏览器发送过来的请求
    # request = client_socket.recv(1024).decode('utf-8')
    # 将浏览器请求的头部信息，根据换行拆分成一个列表
    headers = requests.splitlines()
    # print(headers[0])   # GET /XXX/XXXX HTTP/1.1
    ret = re.match(r'[^/]+(/[^ ]*)', headers[0])
    # print(ret.group())
    file_name = ''
    if ret:
        # 符合正则的值为GET /XXX/XXX和/XXX/XXX 取后面这个group(1)
        file_name = ret.group(1)
        # 如果浏览器请求的是127.0.0.1(也就是只有一个/)，那么让浏览器显示主页(index.html)
        if file_name == '/':
            file_name = '/index.html'

    # 2.返回http格式的数据给浏览器
    try:
        f = open('jQuery响应式网站导航菜单'+file_name, 'rb')
    except:
        # 如果浏览器访问的页面不存在，则返回404
        response = "HTTP/1.1 404 
"
        response += 'Content-Type: text/html;charset=utf-8
'
        response += '
'
        response += "您所访问的地址或文件不存在"
        # 发送网页的headers
        client_socket.send(response.encode('utf-8'))
    else:
        # 2.1 准备发送给浏览器的header
        html_content = f.read()
        f.close()
        response = "HTTP/1.1 200 OK
"
        response += 'Content-Type: text/html;charset=utf-8
'
        response += 'Content-Length: %d
' % len(html_content)
        response += '
'
        # 发送网页的headers
        client_socket.send(response.encode('utf-8'))

        # 发送网页的body
        client_socket.send(html_content)

    # 关闭套接字
    # client_socket.close()


def main():
    """用来完成整体的控制"""
    # 1.创建套接字
    tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

    # 2.绑定
    tcp_server_socket.bind(('', 7788))

    # 3.设置为被动监听
    tcp_server_socket.listen(128)
    tcp_server_socket.setblocking(False)  # 将套接字变为非堵塞

    # 创建一个epoll对象
    epl = select.epoll()

    # 将监听套接字对应的fd注册到epoll中
    epl.register(tcp_server_socket.fileno(), select.EPOLLIN)

    fd_evevt_dict = dict()
    while True:
        # 默认会堵塞，直到os检测到数据到来，通过事件通知方式告诉这个程序，此时才会借堵塞
        # [(fd,event), (fd, event)...]
        # fd:套接字对应的文件描述符，evevt:这个文件描述符到底是什么事件
        fd_evevt_list = epl.poll()
        for fd, event in fd_evevt_list:
            if fd == tcp_server_socket.fileno():
                # 4.等待客户端连接
                new_socket, client_adress = tcp_server_socket.accept()
                epl.register(new_socket.fileno(), select.EPOLLIN)
                fd_evevt_dict[new_socket.fileno()] = new_socket
            # 除了监听套接字，剩下的都是客户端套接字
            elif event == select.EPOLLIN:
                # 判断已经链接的客户是否有数据发送过来
                client_socket = fd_evevt_dict[fd]
                recv_data = client_socket.recv(1024).decode('utf-8')
                if recv_data:
                    service_client(client_socket, recv_data)
                else:
                    client_socket.close()
                    epl.unregister(fd)
                    del fd_evevt_dict[fd]

    # 关闭监听套接字
    tcp_server_socket.close()


if __name__ == '__main__':
    main()

具体epoll详解参照：https://blog.csdn.net/xiajun07061225/article/details/9250579