echoserverthread.java

Java程序设计技巧与开发实例附书源代码。

import java.io.*;
import java.net.*;

public class EchoServerThread extends Thread
{  private Socket connection;
   public EchoServerThread(Socket _connection)
   {  connection = _connection;
      start();
   }
   public void run()
   {  try
      {  DataInputStream  in  = new DataInputStream(
                                   connection.getInputStream());
         DataOutputStream out = new DataOutputStream(
                                   connection.getOutputStream());
         String line = new String("");
         while (!line.equalsIgnoreCase(".QUIT"))
         {  line = in.readUTF();
            System.out.println("Echoing: " + line);
            out.writeUTF(line);
         }
         in.close(); out.close(); connection.close();
         System.out.println("Connection closed.");
      }
      catch(IOException ioe)
      {  System.out.println("Connection closed unexpectedly."); }
   }
}