udpechoserver.java

javaUdp java udp编程

//package chat;



import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.SocketException;

public class UDPEchoServer extends UDPServer {
	private String tem="";
	private boolean stopped = false;
  public final static int DEFAULT_PORT = 4007;

  public UDPEchoServer() throws SocketException {
    super(DEFAULT_PORT); 
  }

  public void halt() {
    this.stopped = true; 
  }
  
  public void respond(DatagramPacket packet) {
	  
	//  byte[] buffer = new byte[65507];
    //try {
      DatagramPacket outgoing = new DatagramPacket(packet.getData(),
      packet.getLength());
      try {
       Thread receiver = new Srv(ds);
       receiver.start();
      }catch (IOException e){
    	  System.err.println(e);
      }
      
  //    String s = new String(ds.receive(outgoing));
   //   ds.send(outgoing);
     // ds.receive(outgoing);
     /* while(tem!="bye"){
      String s = new String(packet.getData(), 0, packet.getLength());
      tem=s;
      System.out.println(s);*/
      
     try {
      BufferedReader userInput 
       = new BufferedReader(new InputStreamReader(System.in));
      while (true) {
        if (stopped) return;
        String theLine = userInput.readLine();
        if (theLine.equals(".")) break;
        byte[] data = theLine.getBytes();
        DatagramPacket output 
         = new DatagramPacket(data, data.length,packet.getAddress(),packet.getPort());
        ds.send(output);
        Thread.yield();
      }
    }  // end try
    catch (IOException ex) {
      System.err.println(ex);
    }
     }
     // Thread.yield();
  //  }
  //  catch (IOException ex) {
  //    System.err.println(ex);
  // }*/
    
  

  public static void main(String[] args) {
   try {
     UDPServer server = new UDPEchoServer();
     server.start();
   }
   catch (SocketException ex) {
     System.err.println(ex);
   }
 
  }

}