Source code: org/zazof/jtegServer/ClientConnection.java

   package org.zazof.jtegServer;
   
   import java.net.*;
   import java.util.*;
   import java.io.*;
   import org.apache.log4j.Category;
   
   /**
    * This class is a socket connection to a client teg/jteg application
   */
  
  public class ClientConnection implements Runnable{
  
    public ClientConnection(Socket clientSocket, ConnectionController controller) throws IOException{
      $socket = clientSocket;
      $player = new Player(this);
      $controller = controller;
      $out = new BufferedWriter(new OutputStreamWriter($socket.getOutputStream()));
      $in = new BufferedReader(new InputStreamReader($socket.getInputStream()));
      $thread = new Thread(this);
      $thread.start();
      log.info("created ClientConnection from IP " + $socket.getInetAddress());
    }
  
    public void run(){
      String input;
      StringTokenizer st;
      String message;
      try{
        while(true){
          // this call can block
          input = read();  
          log.debug("read from " + $player.getName() + ", message: " + input);
          // check if the client closed his connection
          if (input == null){
            log.info("Client closed his connection");
            throw new IOException();
          }
          // a client can send more than 1 message, each message is separated by a ";"
          st = new StringTokenizer(input, ";");
          while(st.hasMoreTokens()){
            message = st.nextToken();
            if (message.indexOf("null") != -1){
              log.debug("Received message containing null: " + message);
            }else{
              $controller.processMessage(message, $player);
            }
          }
          st = null;
        }
      }
      catch (IOException exc){
        // we close the connection and inform the ConnectionController
        try{
          $socket.close();
          $controller.removeConnection(this);
        }
        catch (IOException ioExc){
          // the conenction close gave troubles
          $controller.removeConnection(this); 
        }
      }
    }
  
    /**
     * reads a message from the client
     * blocking call
     */
    public String read() throws IOException{
      return $in.readLine();
    }
  
    /**
     * sends a message to the client
     */
    public void write(String message){
      try{
        $out.write(message);
        $out.newLine();
        $out.flush();
        log.debug("write to " + $player.getName() + ", message: " + message);
      }
      catch (IOException exc){
        $controller.removeConnection(this);
      }
    }
  
    private BufferedWriter $out;
    private BufferedReader $in;
    private Socket $socket;
    private Thread $thread;
    private ConnectionController $controller;
    private static final boolean $debug = true;
    private Player $player;
  
    static Category log = Category.getInstance("network");
  }