from socket import *
from time import ctime

host = ''                 # HOST 变量是空白的，这是对 bind()方法的标识，表示它可以使用任何可用的地址。
port = 6789
bufsize = 1024            # 一次最多读取的字节数(缓冲区大小)
addr = (host, port)


# 所有套接字都是通过使用 socket.socket()函数来创建的。
tcpSocket = socket(AF_INET, SOCK_STREAM)
udpSocket = socket(AF_INET, SOCK_DGRAM)

tcpSocket.bind(addr)                      # 绑定服务器地址和端口
tcpSocket.listen(5)                       # 开始监听，并指定在拒绝连接之前，操作系统应该列队的最大挂起连接数量。该值至少为1，大部分应用程序设置为5就足够了。

while True:
  print('服务器正在等待连接, 端口号{} ...'.format(port))
  tcpClint, addr = tcpSocket.accept()
  print('收到连接:', addr)

  while True:
    try:
      data = tcpClint.recv(bufsize)
      if not data:
        break
      data = data.decode('gb2312')
      tcpClint.send('[{}] {}\r\n'.format(ctime(), data).encode('gb2312'))
    except:
      break

  tcpClint.close()
tcpSocket.close()