python網(wǎng)絡(luò)編程之多線(xiàn)程同時(shí)接受和發(fā)送

'''
模仿qq 同時(shí)可以發(fā)送信息和接受信息多線(xiàn)程
'''


from socket import *
from time import sleep
import threading

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

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


#負(fù)責(zé)發(fā)送數(shù)據(jù)
def sendData():
  #防止和上文同時(shí)輸入產(chǎn)生風(fēng)險(xiǎn) 所以發(fā)送數(shù)據(jù)暫停10秒后再運(yùn)行
  sleep(10)
  udpSendSocket = socket(AF_INET,SOCK_DGRAM)
  #用戶(hù)輸入接受方信息并存儲(chǔ)在 sendAddr 中
  sendIpAddr = input('請(qǐng)輸入接受方的ip地址：')
  sendPort = int(input('請(qǐng)輸入接受方的端口：'))
  sendAddr = (sendIpAddr,sendPort)


  while True:
    sendData = input('請(qǐng)輸入要發(fā)送的內(nèi)容：')
    udpSendSocket.sendto(sendData.encode(),sendAddr)


#負(fù)責(zé)多線(xiàn)程
def main():
  #多線(xiàn)程同時(shí)運(yùn)行兩個(gè)方法
  t1 = threading.Thread(target=recvData)
  t2 = threading.Thread(target=sendData)
  t1.start()
  t2.start()
  t1.join()
  t2.jion()


if __name__ == '__main__':
  main()