多人聊天室 (多線程 || epoll)

使用多線程缺點很明顯，服務器爲每一個客戶開一個線程，每一個線程都阻塞等待讀
客戶端須要兩個線程，一個用來讀，一個用來寫。
epoll的代碼還在研究中
https://github.com/jwzh222/epoll
能夠參考這個
順便一提windows下沒有epoll,只有Linux支持。

import socket
import threading
socket_list = []
s = socket.socket()
s.bind(('127.0.0.1', 8888))
s.listen()
def read_client(s):
    try:
        # 接收客戶端的數據
        return s.recv(2048).decode('utf-8')
    except:
        # 如有異常，說明鏈接失敗，則刪除該socket
        print(str(addr) + ' Left!')
        socket_list.remove(s)
def socket_target(s):
    try:
        while True:
            content = read_client(s)
            if content is None:
                break
            else:
                print(content)
            # 將一個客戶端發送過來的數據廣播給其餘客戶端
                for client in socket_list:
                    client.send((str(addr) + ' say: ' + content).encode('utf-8'))
    except:
        print('Error!')
while True:
    conn, addr = s.accept()
    # 每當有客戶鏈接後，就將其加到socket列表中
    socket_list.append(conn)
    print(str(addr) + ' Joined!')
    # 每當有客戶鏈接後，就啓動一個線程爲其服務
    threading.Thread(target=socket_target, args=(conn,)).start()

import socket
import threading
s = socket.socket()
s.connect(('10.34.22.166', 8888))

def read_server(s):
    while True:
        # 子線程負責從服務端接受數據並打印
        content = s.recv(2048).decode('utf-8')
        print(content)

threading.Thread(target=read_server, args=(s,)).start()     

while True:
    line = input('')
    if line == 'exit':
        break
 # 主線程負責將用戶輸入的數據發送到socket中
    s.send(line.encode('utf-8'))