ChatHandler.java

package com.godoro.androidclients;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

public class ChatHandler extends Thread {

  private ChatServer server;
  private BufferedReader reader;
  private BufferedWriter writer;

  public ChatHandler(ChatServer server, Socket socket) throws IOException {
    this.server = server;
    InputStream in = socket.getInputStream();
    InputStreamReader isr = new InputStreamReader(in);
    reader = new BufferedReader(isr);
    OutputStream out = socket.getOutputStream();
    OutputStreamWriter osw = new OutputStreamWriter(out);
    writer = new BufferedWriter(osw);
  }

  @Override
  public void run() {

    while (true) {
      try {
        String request = reader.readLine();
        System.out.println("İstemciden gelen: "+request);
        if(request!=null){
            server.send(this,request);
        }
      } catch (Exception e) {
        System.out.println("İstemci bağlantıyı kopardı");
        server.getHandlerList().remove(this);
        break;
      }
    }
  }

  public void send(String response) {
    try {
      writer.write(response+"\r\n");
      writer.flush();
      System.out.println("İstemciye gönderilen yanıt "+response);
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}