| 12345678910111213141516171819202122232425262728293031323334353637383940 |
- # -*- coding: utf-8 -*-
- from socket import *
- from time import ctime
- from video import Video_Server
- # 服务配置
- HOST = '172.16.102.9'
- PORT = 10087
- BUFSIZE = 81920
- ADDR = (HOST, PORT)
- userList = []
- MAXCLIENT = 1
- FX = 0.5
- SPD = 0.125
- def loopServer(tcpSrvSock):
- # 服务监听
- global userList, MAXCLIENT
- while True:
- print('Waiting For Client Connection ...', ctime())
- tcpCliSock, addr = tcpSrvSock.accept() # 会阻塞
- print('NewUser', addr, ctime())
- print('UserListLenght:', len(userList))
- # 增加线程
- if tcpCliSock not in userList and len(userList) < MAXCLIENT:
- newClinet = Video_Server(
- userList, tcpCliSock, BUFSIZE, addr, SPD, FX)
- newClinet.start()
- else:
- # 不允许连接
- print('不允许连接')
- tcpCliSock.close()
- if __name__ == '__main__':
- tcpSrvSock = socket(AF_INET, SOCK_STREAM)
- tcpSrvSock.bind(ADDR)
- tcpSrvSock.listen(1)
- loopServer(tcpSrvSock)
|