TCP - Android客户端+ Java服务器

Question

我已经实现了在我的PC上运行的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

基于只是快看，我猜你需要删除的行：从您的onClick（）方法

clientSender = new ClientSender(context); 

。