home *** CD-ROM | disk | FTP | other *** search
/ MACD 4 / MACD4.iso / Internet / Java / networking / sockets / example / KKMultiServerThread.java < prev    next >
Encoding:
Java Source  |  1978-03-06  |  1.9 KB  |  56 lines
  1. /*
  2.  * Copyright (c) 1995, 1996 Sun Microsystems, Inc. All Rights Reserved.
  3.  *
  4.  * Permission to use, copy, modify, and distribute this software
  5.  * and its documentation for NON-COMMERCIAL purposes and without
  6.  * fee is hereby granted provided that this copyright notice
  7.  * appears in all copies. Please refer to the file "copyright.html"
  8.  * for further important copyright and licensing information.
  9.  *
  10.  * SUN MAKES NO REPRESENTATIONS OR WARRANTIES ABOUT THE SUITABILITY OF
  11.  * THE SOFTWARE, EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
  12.  * TO THE IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
  13.  * PARTICULAR PURPOSE, OR NON-INFRINGEMENT. SUN SHALL NOT BE LIABLE FOR
  14.  * ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING OR
  15.  * DISTRIBUTING THIS SOFTWARE OR ITS DERIVATIVES.
  16.  */
  17. import java.net.*;
  18. import java.io.*;
  19.  
  20. class KKMultiServerThread extends Thread {
  21.     Socket socket = null;
  22.  
  23.     KKMultiServerThread(Socket socket) {
  24.         super("KKMultiServerThread");
  25.         this.socket = socket;
  26.     }
  27.  
  28.     public void run() {
  29.         try {
  30.             DataInputStream is = new DataInputStream(
  31.                                   new BufferedInputStream(socket.getInputStream()));
  32.             PrintStream os = new PrintStream(
  33.                               new BufferedOutputStream(socket.getOutputStream(), 1024), false);
  34.             KKState kks = new KKState();
  35.             String inputLine, outputLine;
  36.  
  37.             outputLine = kks.processInput(null);
  38.             os.println(outputLine);
  39.             os.flush();
  40.  
  41.             while ((inputLine = is.readLine()) != null) {
  42.                 outputLine = kks.processInput(inputLine);
  43.                 os.println(outputLine);
  44.                 os.flush();
  45.                 if (outputLine.equals("Bye"))
  46.                     break;
  47.             }
  48.             os.close();
  49.             is.close();
  50.             socket.close();
  51.         } catch (IOException e) {
  52.             e.printStackTrace();
  53.         }
  54.     }
  55. }
  56.