# 導(dǎo)入模塊
import socket
import threading


# 接收消息
def recv(client_socket, ip_port):
  while True:
    client_text = client_socket.recv(1024)
    # 如果接收的消息長度不為0，則將其解碼輸出
    if client_text:
      print("[客戶端消息]", ip_port, ":", client_text.decode("gbk"))
      # 給客戶端響應(yīng)
      client_socket.send("收到\n".encode())
    # 當(dāng)客戶端斷開連接時，會一直發(fā)送''空字符串，所以長度為0已下線
    else:
      print("客戶端", ip_port, "已下線")
      client_socket.close()
      break


# 程序主入口
def main():
  # 創(chuàng)建TCP套接字
  tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  # 設(shè)置端口復(fù)用
  tcp_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
  # 綁定端口
  tcp_socket.bind(("", 8080))
  # 設(shè)置為被動監(jiān)聽狀態(tài)，128表示最大連接數(shù)
  tcp_socket.listen(128)
  while True:
    # 等待客戶端連接
    client_socket, ip_port = tcp_socket.accept()
    print("[新客戶端]:", ip_port, "已連接")
    # 有客戶端連接后，創(chuàng)建一個線程將客戶端套接字，IP端口傳入recv函數(shù)，
    t1 = threading.Thread(target=recv, args=(client_socket, ip_port))
    # 設(shè)置線程守護
    t1.setDaemon(True)
    # 啟動線程
    t1.start()


if __name__ == '__main__':
  main()