main.py 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. import time
  2. import sys
  3. from socket import *
  4. from recv import RECVSERVER
  5. from send import SENDSERVER
  6. # 服务配置
  7. HOST = '172.16.102.9'
  8. PORT = 10087
  9. ADDR = (HOST, PORT)
  10. ICED = {
  11. 'sdpSemantics': 'unified-plan',
  12. 'iceServers': [
  13. {
  14. 'urls': 'stun:81.70.80.219:3478',
  15. 'username': 'admin',
  16. 'credential': '123456'
  17. },
  18. {
  19. 'urls': 'turn:81.70.80.219:3478',
  20. 'username': 'admin',
  21. 'credential': '123456'
  22. },
  23. ]
  24. }
  25. if __name__ == '__main__':
  26. sock = socket(AF_INET, SOCK_STREAM)
  27. data = str.encode('test')
  28. state = sock.connect_ex(ADDR)
  29. if state == 0:
  30. print('服务器连接成功')
  31. # 发送
  32. sendd = SENDSERVER(sock, ICED)
  33. sendd.start()
  34. # 接收
  35. recvd = RECVSERVER(sock, ICED)
  36. recvd.start()
  37. else:
  38. print('服务器连接失败')
  39. sys.exit(0)
  40. while True:
  41. time.sleep(1)
  42. if not sendd.is_alive() or not recvd.is_alive():
  43. print("Client close")
  44. sys.exit(0)
  45. pass