public Receiver() { try{ //创建udp包以接受数据。 packet = new DatagramPacke(recvBuf,recvBuf.length);
//创建接受方的udp端口以接收数据 socket = new DatagramSocket(7002); } catch(Exception e){} }
public void run() { try { while(true){ //接受数据 socket.receive(packet);
ByteArrayInputStream byteStream = new ByteArrayInputStream(recvBuf); ObjectInputStream is = new ObjectInputStream(new BufferedInputStream(byteStram)); Object o = is.readObject(); msg = (Message)o; is.close();