TCP - клиент Android + сервер Java

Question

Я реализовал на своем ПК сервер Java TCP, который будет принимать входящие сообщения, отправленные с устройства Android, на котором запущен клиент, также реализован. Сервер просто получает сообщения с устройства Android и отправляет ответ. Все работает нормально, пока я не попытаюсь отправить сообщение второе сообщение с устройства Android: тогда приложение вылетает!

Но я не знаю почему. Я использую кнопку для отправки ранее написанного сообщения.

Это серверный код нить (нить просто вызывается из главного пользования run()):

public class ServerThread extends Thread { 
     ServerSocket serverSocket; 

     public ServerThread() { 
     } 

     public void run() { 
      String incomingMsg; 

      try { 
       System.out.println("Starting socket thread..."); 

       serverSocket = new ServerSocket(21111); 

       System.out 
         .println("ServerSocket created, waiting for incomming connections..."); 

       Socket socket = serverSocket.accept(); 

       BufferedWriter out = new BufferedWriter(new OutputStreamWriter(
         socket.getOutputStream())); 
       BufferedReader in = new BufferedReader(new InputStreamReader(
         socket.getInputStream())); 

       while (true) { 
        // System.out.println("Connection accepted, reading..."); 

        while ((incomingMsg = in.readLine()) != null && socket.isConnected()) { 
         System.out.println("Message recieved: " + incomingMsg 
           + ". Answering..."); 

         // send a message 
         String outgoingMsg = "Message \"" + incomingMsg 
           + "\" recieved on server." 
           + System.getProperty("line.separator"); 
         out.write(outgoingMsg); 
         out.flush(); 

         System.out.println("Message sent: " + outgoingMsg); 
        } 

        if (socket.isConnected()) System.out.println("Socket still connected"); 
        else System.out.println("Socket not connected"); 
       } 

      } catch (Exception e) { 
       System.out.println("Error: " + e.getMessage()); 
       e.printStackTrace(); 
      } 

     } 
    } 

И это код клиента. Я использую AsyncTask:

public class MainActivity extends Activity { 
    private static final String TAG = "MainActivity"; 

    private Button sendButton; 
    private EditText messageText; 
    private String messageToSend; 
    private ClientSender clientSender; 
    private Context context; 
    private Socket socket; 

    private static String SERVER_IP = "192.168.1.129"; 

    @Override 
    protected void onCreate(Bundle savedInstanceState) { 
     super.onCreate(savedInstanceState); 
     setContentView(R.layout.activity_main); 

     messageText = (EditText) findViewById(R.id.editTextMessage); 
     sendButton = (Button) findViewById(R.id.sendButton); 
     context = this.getApplicationContext(); 
     clientSender = new ClientSender(context); 
     socket = null; 

     sendButton.setOnClickListener(new OnClickListener() { 

      @Override 
      public void onClick(View v) { 
       messageToSend = messageText.getText().toString() 
         + System.getProperty("line.separator"); 

       clientSender.execute(messageToSend); 

      } 
     }); 

    } 

    @Override 
    public boolean onCreateOptionsMenu(Menu menu) { 
     // Inflate the menu; this adds items to the action bar if it is present. 
     getMenuInflater().inflate(R.menu.activity_main, menu); 
     return true; 
    } 

    private class ClientSender extends AsyncTask<String, Void, Socket> { 
     private Socket socket; 
     private String answer; 
     private Context context; 
     private BufferedWriter out; 
     private BufferedReader in; 

     public ClientSender(Context context) { 
      this.context = context; 
      socket = null; 
      out = null; 
      in = null; 
     } 

     @Override 
     protected Socket doInBackground(String... params) { 
      try { 
       if (socket == null) { 
        socket = new Socket(SERVER_IP, 21111); 

        out = new BufferedWriter(
          new OutputStreamWriter(socket.getOutputStream())); 
        in = new BufferedReader(
          new InputStreamReader(socket.getInputStream())); 
       } 

       out.write(params[0]); 
       out.flush(); 

       answer = in.readLine() + System.getProperty("line.separator"); 

       return socket; 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 

      return socket; 
     } 

     protected void onPostExecute(Socket socket) { 
      if (socket != null) { 
       Toast.makeText(context, answer, Toast.LENGTH_LONG).show(); 

      } else { 
       Toast.makeText(context, "Can't connect to server!", 
         Toast.LENGTH_LONG).show(); 
      } 

     } 

    } 

} 

Я не знаю, что происходит, но я подозреваю, что может быть что-то не так с соединением сокета.

Answer 1

Измените кнопку onClick на вашей кнопке, чтобы каждый раз создавать новый ClientSender;

public void onClick(View v) { 
    messageToSend = messageText.getText().toString() + System.getProperty("line.separator"); 
    new ClientSender(Activity.this).execute(messageToSend); 
} 

Answer 2

Основываясь только на беглый взгляд, я думаю, вам нужно удалить строку:

clientSender = new ClientSender(context); 

из метода OnClick().