python-1802-和卓 15:12:36

1……

from threading import Thread

class SenderThread(Thread):   

                  def__init__(self,socket,destaddress,d estport):        

  Thread.__init__(self)                                      self.socket = socket                                          self.dest_address = destaddress           self.dest_port = destport    

def run(self):        

    while True:              

        msg = input("我说:")  #键盘输入                        self.socket.sendto(msg.encode(),(self.dest_address,self.dest_port))

2……

from threading import

Thread class ReceiverThread(Thread): 接收线程     def __init__(self,socket):              Thread.__init__(self)         self.socket = socket     

def run(self):        

    while True:            

        msg,addr = self.s.recvfrom(1024)               print(addr,"说:",msg.decode())

3……

import socket

from chat_sender import SenderThread

from chat_receiver import ReceiverThread

s = socket.socket(type=socket.SOCK_DGRAM)  #实例化支持UDP协议的socket对象 s.bind(("localhost",8888)) SenderThread(socket,"localhost",6666).start() #启动发送线程 ReceiverThread(s).start() #启动接收线程