receiverthread.java

利用UDP实现网络聊天室

package udpecho;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */
import java.net.*;
import java.io.*;
public class ReceiverThread extends Thread {
  DatagramSocket socket;
  private boolean stopped=false;
  public ReceiverThread(DatagramSocket ds)throws SocketException {
    this.socket =ds;
  }
  public void halt(){
    this.stopped=true;
  }
  public void run(){
    byte[] buffer=new byte[65507];
    while(true){
      if(stopped) return;
      DatagramPacket dp=new DatagramPacket(buffer,buffer.length);
      try{
        socket.receive(dp);
        String s=new String(dp.getData(),0,dp.getLength());
        System.out.println("服务器返回收到的信息是：");
        System.out.println(s);
        System.out.println("***************************");
        Thread.yield();
      }
      catch(IOException e){
        System.err.println(e);
      }
    }
  }
}