senderthread.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.*;
import java.io.DataInputStream;
public class SenderThread extends Thread {
  private InetAddress server;
  private DatagramSocket socket;
  private boolean stopped=false;
  private int port;
  public SenderThread(InetAddress ia,int port)throws SocketException{
    this.server =ia;
    this.socket =new DatagramSocket();
    this.port =port;
  }
  public void halt(){
    this.stopped =true;
  }
  public DatagramSocket getSocket(){
    return this.socket ;
  }
  public void run(){
      try{
      System.out.println("请输入发送的信息,每次一行回车表示，exit结束：");
      BufferedReader userInput=new BufferedReader(new InputStreamReader(System.in));
      while(true){
        if(stopped) return;
        String theLine=userInput.readLine();
        if(theLine.equals("exit")) break;
        byte[] data=theLine.getBytes();
        DatagramPacket output=new DatagramPacket(data,data.length,server,port);
        socket.send(output);
        Thread.yield();
      }
    }
    catch(IOException e){
      System.err.println(e);
    }
  }
}