#!/usr/bin/evn python
"""
這是一個Socket+多進(jìn)程的例子（聊天服務(wù)端）
"""
import socket
import threading
# 處理中文數(shù)據(jù)用的
encoding = "GBK"
def HKServer(client, addr):
 """
 與客戶端時實通訊函數(shù)
 加入encoding是為了處理輸入中文數(shù)據(jù)
 client 客戶socket
 addr  客戶address
 """
 # 通知已有的每個客戶，有新的成員加入
 for c in clients: c.send(bytes("[%s]加入\r\n" % addr[1], encoding))
 # 接受客戶端數(shù)據(jù)
 say = b""
 while True:
  data = client.recv(1024)
  if not data: break
  # 如果不是回車鍵
  if data != b'\r\n':
   say += data #.encode(encoding)
   continue
  # 把客戶端發(fā)來的內(nèi)容發(fā)給所有的客戶端
  for c in clients:
   c.send(bytes("[%s]:%s\r\n" % (addr[1], say.decode(encoding)), encoding))
  # 內(nèi)容歸\x0
  say = b""
 # 客戶離開后，從客戶列表中移隊當(dāng)前客戶，關(guān)閉socket連接
 clients.remove(client)
 client.close()
 # 通知已有的每個客戶，有成員離開
 for c in clients: c.send(bytes("[%s]離開\r\n" % addr[1], encoding))
# 客戶端列表
clients = []
# 設(shè)置IP地址與端口
HOST = ''
PORT = 9999
# 初始化socket
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 綁定IP地址與端口
s.bind((HOST, PORT))
# 開始監(jiān)聽
s.listen(1)
# 循環(huán)等待
while True:
 # 接受客戶
 client, addr = s.accept()
 # 啟動新的進(jìn)程與客戶通信
 thread = threading.Thread(target=HKServer, args=(client, addr))
 thread.start()
 # 記錄新的客戶
 clients.append(client)