python實(shí)現(xiàn)socket+threading處理多連接的方法

import socket # 導(dǎo)入 socket 模塊
from threading import Thread
 
ADDRESS = ('127.0.0.1', 8712) # 綁定地址
 
g_socket_server = None # 負(fù)責(zé)監(jiān)聽的socket
 
g_conn_pool = [] # 連接池

def init():
  """
  初始化服務(wù)端
  """
  global g_socket_server
  g_socket_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 創(chuàng)建 socket 對(duì)象
  g_socket_server.bind(ADDRESS)
  g_socket_server.listen(5) # 最大等待數(shù)（有很多人理解為最大連接數(shù)，其實(shí)是錯(cuò)誤的）
  print("服務(wù)端已啟動(dòng)，等待客戶端連接...")

def accept_client():
  """
  接收新連接
  """
  while True:
    client, _ = g_socket_server.accept() # 阻塞，等待客戶端連接
    # 加入連接池
    g_conn_pool.append(client)
    # 給每個(gè)客戶端創(chuàng)建一個(gè)獨(dú)立的線程進(jìn)行管理
    thread = Thread(target=message_handle, args=(client,))
    # 設(shè)置成守護(hù)線程
    thread.setDaemon(True)
    thread.start()
 
 
def message_handle(client):
  """
  消息處理
  """
  client.sendall("連接服務(wù)器成功!".encode(encoding='utf8'))
  while True:
    bytes = client.recv(1024)
    print("客戶端消息:", bytes.decode(encoding='utf8'))
    if len(bytes) == 0:
      client.close()
      # 刪除連接
      g_conn_pool.remove(client)
      print("有一個(gè)客戶端下線了。")
      break

if __name__ == '__main__':
  init()
  # 新開一個(gè)線程，用于接收新連接
  thread = Thread(target=accept_client)
  thread.setDaemon(True)
  thread.start()
  # 主線程邏輯
  while True:
    cmd = input("""--------------------------
輸入1:查看當(dāng)前在線人數(shù)
輸入2:給指定客戶端發(fā)送消息
輸入3:關(guān)閉服務(wù)端
""")
    if cmd == '1':
      print("--------------------------")
      print("當(dāng)前在線人數(shù)：", len(g_conn_pool))
    elif cmd == '2':
      print("--------------------------")
      index, msg = input("請(qǐng)輸入“索引,消息”的形式：").split(",")
      g_conn_pool[int(index)].sendall(msg.encode(encoding='utf8'))
    elif cmd == '3':
      exit()

import socket # 導(dǎo)入 socket 模塊
 
s = socket.socket() # 創(chuàng)建 socket 對(duì)象
s.connect(('127.0.0.1', 8712))
print(s.recv(1024).decode(encoding='utf8'))
s.send("連接了".encode('utf8'))
print(s.recv(1024).decode(encoding='utf8'))
input("")