ChatClient.java

package com.godoro.androidclients;

import android.util.Log;

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.net.UnknownHostException;

public class ChatClient extends Thread {

  private Socket socket;
  private BufferedReader reader;
  private BufferedWriter writer;
  private ChatActivity activity;

  public ChatClient(String host, int port) throws UnknownHostException, IOException {
    socket = new Socket(host, port);
    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);
  }

    public ChatActivity getActivity() {
        return activity;
    }

    public void setActivity(ChatActivity activity) {
        this.activity = activity;
    }

    @Override
  public void run() {
    Log.i("GodoroAndroid","İstemci çalışıyor");
    while (true) {
      try {
        Log.i("GodoroAndroid","Sunucudan yanıt okunuyor");
        String response = reader.readLine();
        Log.i("GodoroAndroid","Sunucudan gelen yanıt: " + response+" ");
        if(activity!=null){
           activity.responseReceived(response);
        }
      } catch (Exception e) {
        Log.e("GodoroAndroid","İstemci okuma yanlışlığı",e);
      }
    }
  }

  public void send(String request) {
    try {
        if(request!=null && !request.trim().equals("")){
            writer.write(request + "\r\n");
            writer.flush();
        }

    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  public static void main(String[] args) throws UnknownHostException, IOException {
    String host = "localhost";
    int port = 9999;
    ChatClient client = new ChatClient(host, port);
    client.start();
    InputStreamReader isr = new InputStreamReader(System.in);
    BufferedReader reader = new BufferedReader(isr);
    System.out.println("İstemci başlatıldı. Kapı "+port);
    while (true) {
     
      String message = reader.readLine();
      if (!message.equals("exit")) {

        client.send(message);
        System.out.println("Sunucuya gönderildi " + message);
      } else {
        System.exit(0);
      }
    }

  }
}