IO多路複用

IO多路複用 -利用內置模塊select[Windows Linux]

• 循環每個被監聽的項目，看看是否有讀寫錯誤操做
• 因此隨着監聽項目的增多，效率將變差
• 服務器端

• select必須傳入三個參數分別是三個列表read_list, write_list, erro_list返回值是一個元祖對應傳入的參數

  #select幫助感知某個IO操做是否有變更
    #read開始被read
    #write開始被write
    #erro開始有erro
    #一但感知到就會返回響應的參數
  
  
    import socket
    from select import select
  
    sk = socket.socket()
    address = ('127.0.0.1', 8080)
    sk.bind(address)
    sk.setblocking(False)
    sk.listen() #監聽
  
    read_ls = [sk]  #將sk對象加入一個列表
  
    while 1:
        r_ls, w_ls, x_ls = select(read_ls, [], [])
        for i in r_ls:
            if i is sk:
                conn, addr = i.accept()
                read_ls.append(conn)
            else:
                ret = i.recv(1024)  #接收消息
                if ret == b'':
                    read_ls.remove(i)
                    i.close()
                    continue
                print(ret)
                i.send(b'byebye!')  #發送消息

• 客戶端 -起多線程的客戶端

  import socket
    from threading import Thread
  
    def func():
        sk = socket.socket()
        address = ('127.0.0.1', 8080)
        sk.connect(address)
        sk.send(b'hello')
        ret = sk.recv(1024)
        print(ret)
        sk.close()
  
    t_ls = []
    for i in range(10):
        t = Thread(target=func)
        t.start()

其餘相似的模塊

poll -[Linux]

• 和select機制基本上同樣
• 可是poll監聽的對象比select監聽上限多

epol -[Linux][Windows上沒有 ]

• 高端的
• 並非循環每個項目進行監聽
• 而是爲每個項目增長回調函數
• 有信號來直接進行回調函數，因此效率比循環高