main.py 1.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. # -*- coding: utf-8 -*-
  2. from socket import *
  3. from time import ctime
  4. from video import Video_Server
  5. # 服务配置
  6. HOST = '172.16.102.9'
  7. PORT = 10087
  8. BUFSIZE = 81920
  9. ADDR = (HOST, PORT)
  10. userList = []
  11. MAXCLIENT = 1
  12. FX = 0.5
  13. SPD = 0.125
  14. def loopServer(tcpSrvSock):
  15. # 服务监听
  16. global userList, MAXCLIENT
  17. while True:
  18. print('Waiting For Client Connection ...', ctime())
  19. tcpCliSock, addr = tcpSrvSock.accept() # 会阻塞
  20. print('NewUser', addr, ctime())
  21. print('UserListLenght:', len(userList))
  22. # 增加线程
  23. if tcpCliSock not in userList and len(userList) < MAXCLIENT:
  24. newClinet = Video_Server(
  25. userList, tcpCliSock, BUFSIZE, addr, SPD, FX)
  26. newClinet.start()
  27. else:
  28. # 不允许连接
  29. print('不允许连接')
  30. tcpCliSock.close()
  31. if __name__ == '__main__':
  32. tcpSrvSock = socket(AF_INET, SOCK_STREAM)
  33. tcpSrvSock.bind(ADDR)
  34. tcpSrvSock.listen(1)
  35. loopServer(tcpSrvSock)