python epoll實現異步socket

一、同步和異步：

在程序執行中，同步運行意味着等待調用的函數、線程、子進程等的返回結果后繼續處理；異步指不等待當下的返回結果，直接運行主進程下面的程序，等到有返回結果時，通知主進程處理。有點高效。

二、epoll實現異步網絡通信：

首先epoll只支持linux下的python。

服務端實現epoll異步的主要流程就是如下代碼，講解將在代碼里面書寫：

# -*- coding:utf -*-

import socket
import select
'''
需要用到的lib文件：
socket、select
'''
if __name__ == "__main__":
    server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)#IP地址端口復用
    ipaddress = "127.0.0.1"
    port = 33445
    address = (ipaddress,port)
    serverfd = server.fileno()
    server.bind(address)
    serverdict = {}
    serverdict[serverfd] = server
    epoll = select.epoll()#創建epoll對象
    epoll.register(serverfd,select.EPOLLIN)#注冊消息類型（輸入）
    server.listen(5)
    while True:
        events = epoll.poll(1)#創建事件隊列
        for fileno,event in events:
            if fileno == serverfd:
                (client,address) = socket.accept()
                print "<-----",client,"----",address,"----->"
                client.setblocking(0)
                epoll.register(client.fileno(),select.EPOLLIN)#注冊事件隊列
                serverdict[client.fileno()] = client
            elif event & select.EPOLLIN:#當有事件時候處理
                print "client:",fileno
                data = serverdict[fileno].recv(4096)
                print data
                

核心步驟如下：

#創建epoll
epoll = select.epoll()
#注冊事件隊列
epoll.register(socketname.filefd,select.EPOLLIN)#EPOLLIN是事件類型
#創建事件隊列：
events = epoll.poll(1)
#事件隊列的數據結構：
#（文件對象描述符，事件消息）
#檢測事件 進行處理：
for (fd,event) in events:
    if event & select.EPOLLIN:
        do_somethings()
#常用事件類型：
'''
EPOLLIN    Available for read
EPOLLOUT    Available for write
EPOLLPRI    Urgent data for read
EPOLLERR    Error condition happened on the assoc. fd
EPOLLHUP    Hang up happened on the assoc. fd
EPOLLET    Set Edge Trigger behavior, the default is Level Trigger behavior
EPOLLONESHOT    Set one-shot behavior. After one event is pulled out, the fd is internally disabled
EPOLLRDNORM    Equivalent to EPOLLIN
EPOLLRDBAND    Priority data band can be read.
EPOLLWRNORM    Equivalent to EPOLLOUT
EPOLLWRBAND    Priority data may be written.
EPOLLMSG    Ignored.
'''

其他常用的函數：

epoll.close()
epoll.fileno()#返回epoll對象的文件描述符
epoll.fromfd(fd)#從給定對象創建一個epoll對象
epoll.modify(fd,eventmask)#修改文件文件描述對象的epoll事件類型
epoll.unregister(fd)取消注冊
epoll.poll(timeout=xxx,maxevents=xxx)#參數均為非必填項