echoserverthread.java

java实现的简单客户端与服务器端的通讯

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

public class EchoServerThread extends Thread {
    Socket clientSocket = null;
    PrintWriter out = null;
    BufferedReader in = null;
    BufferedReader filein=null;
    protected boolean moreQuotes = true;


    public EchoServerThread(Socket socket) {
        super("EchoServerThread");
        this.clientSocket = socket;
        try {
            filein = new BufferedReader(new FileReader("aa.txt"));
        } catch (FileNotFoundException e) {
            System.err.println("file is not exist");
        }
    }

    public void run() {
      try {

        out = new PrintWriter(clientSocket.getOutputStream(), true);
        in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));



        String fromUser;
       fromUser= in.readLine();

        while (fromUser!=null) {


          String dString = null;
          dString = getNextQuote();
          out.println(dString);
        }

        out.close();
        in.close();
        clientSocket.close();

       } catch (IOException e) {
          System.err.println("Accept failed.");
          System.exit(1);
       }
    }
    protected String getNextQuote() {
       String returnValue = null;
       try {
           if ((returnValue = filein.readLine()) == null) {
               filein.close();
               moreQuotes = false;
               returnValue = "Bye.";
           }
       } catch (IOException e) {
           returnValue = "IOException occurred in server.";
       }
       return returnValue;
   }
}