Простое Клиент-Серверное приложение

  import android.app.Activity;
        import android.os.Bundle;
        import android.view.Menu;
        import android.view.MenuItem;
        import android.view.View;
        import android.widget.*;
        import java.net.*;
        import java.io.*;
public class MyActivity extends Activity {
 
    private TextView Text2;
    private EditText Text1;
    public static Socket socket;
   // public final static String ip = "0";
    //public static final int SERVERPORT = 8080;
 
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        try{
            int port = 8080;
        InetAddress serverAddr = InetAddress.getByName("83.149.48.76");
        socket = new Socket(serverAddr, port);
        }catch(UnknownHostException e){}catch(IOException e){}
        int port = 8080;
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_my);
        Text1 = (EditText) findViewById(R.id.editText);
        Text2 = (TextView) findViewById(R.id.textView2);
        final Button button1 = (Button) findViewById(R.id.button);
        button1.setOnClickListener(new View.OnClickListener(){
            public void onClick(View v){
                try{
                Text2.setText("!");
                String Str = Text1.getText().toString();
                Text2.setText(Text1.getText().toString());
                PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
                out.println(Str); }
             catch (UnknownHostException e) {
 
            } catch (IOException e) {
 
            } catch (Exception e) {
 
            }
 
        }
 
        });
    }
 
 
    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.my, menu);
        return true;
    }
 
    @Override
    public boolean onOptionsItemSelected(MenuItem item) {
        int id = item.getItemId();
        if (id == R.id.action_settings) {
            return true;
        }
        return super.onOptionsItemSelected(item);
    }
}

package server;
import java.net.*;
import java.io.*;
 
public class ServerMain {
static int ConQ=0;   
public static final int PORT = 8080;
   ServerThread Ar[] = new ServerThread [2]; 
   public ServerMain(){ // инициализируем 
    for(int j = 0;j<2;j++)
        Ar[j] = new ServerThread();
   
   }
   public static void main(String[] args) throws IOException{
      ServerSocket s = new ServerSocket(PORT);
 
      System.out.println("Server Started");
      try {
         while (true) {
            // Блокируется до возникновения нового соединения:
            Socket socket = s.accept();
            if(socket != null) System.out.println("Первый подключен");
           // Socket socket2 = s.accept();
           // if(socket2 != null) System.out.println("второй подключен");
            try { 
               /* план костыль
               делаем два потока для каждого подключения
               считываем с первого потока, передаем во временные переменные класса MainServer 
               далее во второй поток,передаем данные и их отсылаем по адресу потока.  
               принимаем новые данные
               */ 
               new ServerThread(socket);
               System.out.println("CONQ"); 
               ConQ++;
               System.out.println(ConQ);
            }
            catch (IOException e) {
               socket.close();
           //    socket2.close();
            }
         }
      }
      finally {
         s.close();
      }
   }
} // /:~

import java.io.*;
import java.net.*;
// нужно как-то сделать так, чтобы сервер занимал один порт.
public class ServerThread extends Thread{
   private Socket socket;
   private Socket socket2;
   private BufferedReader in;
   private PrintWriter out;
   public ServerThread(Socket s) throws IOException {
       socket = s;
      in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
      out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket2
            .getOutputStream())), true);
      start();
   }
 
    ServerThread() {
        
    }
   
   public void run() {
      try {
         String str = in.readLine(); 
         System.out.println("Echoing: " + str);
         out.println(str);
         str = String.valueOf(ServerMain.ConQ);
         out.println(str);
         
             
         System.out.println("now startin cycle" );
         while (true){             
           str = in.readLine();
            if (str.equals("END"))
               break;
            System.out.println("Echoing: " + str);
            out.println(str);
         }
         System.out.println("closing...");
      }
      catch (IOException e) {
         System.err.println("IO Exception");
      }
      finally {
         try {
            socket.close();
         }
         catch (IOException e) {
            System.err.println("Socket not closed");
         }
      }
   }
   
   }