python網絡編程之多線程同時接受和發送

'''
模仿qq 同時可以發送信息和接受信息多線程
'''


from socket import *
from time import sleep
import threading

# 負責接收數據
def recvData():
  udpRecvSocket = socket(AF_INET,SOCK_DGRAM)
  # 默認使用8080端口
  myRecvPort = 8080
  bindAddr = ('',8080)
  #try為了防止端口被占用 如果被占用有一次的修改機會 反正系統就被崩潰
  try:
    #綁定地址
    udpRecvSocket.bind(bindAddr)
  #端口被占用后的修改
  except OSError:
    myRecvPort = int(input("請輸入本機接受端口端口："))
    bindAddr = ('',myRecvPort)
    udpRecvSocket.bind(bindAddr)
  #socket模塊中自帶的方法 用來獲取用戶名和ip地址
  myIpAddr = gethostbyname(getfqdn(gethostname()))
  #打印本機ip地址和所用的端口
  print("本機ip地址為[{}]，接受數據的端口為[{}]".format(myIpAddr,myRecvPort))

  #防止受到的消息部分丟失而引發的異常問題
  while True:
    try:
      recvData = udpRecvSocket.recvfrom(1024) #最大字節數為1024
      #recvData = recvData.decode('GB2312')
      print('對方電腦輸出的內容是：{}'.format(recvData))
    except error as e:
      print(e)


#負責發送數據
def sendData():
  #防止和上文同時輸入產生風險 所以發送數據暫停10秒后再運行
  sleep(10)
  udpSendSocket = socket(AF_INET,SOCK_DGRAM)
  #用戶輸入接受方信息并存儲在 sendAddr 中
  sendIpAddr = input('請輸入接受方的ip地址：')
  sendPort = int(input('請輸入接受方的端口：'))
  sendAddr = (sendIpAddr,sendPort)


  while True:
    sendData = input('請輸入要發送的內容：')
    udpSendSocket.sendto(sendData.encode(),sendAddr)


#負責多線程
def main():
  #多線程同時運行兩個方法
  t1 = threading.Thread(target=recvData)
  t2 = threading.Thread(target=sendData)
  t1.start()
  t2.start()
  t1.join()
  t2.jion()


if __name__ == '__main__':
  main()