正确的Android TCP实现方法（Wifi测试通过）

package bogo.client.com; import java.io.DataInputStream; import java.io.IOException; import java.io.PrintStream; import java.net.Socket; import java.net.UnknownHostException; import android.app.Activity; import android.os.Bundle; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.TextView; import android.widget.Toast; public class BogoclientActivity extends Activity { /* 服务器地址 */ private final String SERVER_HOST_IP = "192.168.43.1"; /* 服务器端口 */ private final int SERVER_HOST_PORT = 5000; private Button btnConnect; private Button btnSend; private EditText editSend; private EditText GIp; private EditText GPort; private TextView TextShow; private Socket socket; private PrintStream output; DataInputStream inputD; byte[] dataGet; private String Msg = "yes"; public void toastText(String message) { Toast.makeText(this, message, Toast.LENGTH_LONG).show(); } public void handleException(Exception e, String prefix) { e.printStackTrace(); toastText(prefix + e.toString()); } /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); initView(); MessageShow(); btnConnect.setOnClickListener(new Button.OnClickListener() { @Override public void onClick(View v) { initClientSocket(); } }); btnSend.setOnClickListener(new Button.OnClickListener() { @Override public void onClick(View v) { sendMessage(editSend.getText().toString()); } }); } public void initView() { btnConnect = (Button)findViewById(R.id.btnConnect); btnSend = (Button)findViewById(R.id.btnSend); editSend = (EditText)findViewById(R.id.sendMsg); GIp = (EditText)findViewById(R.id.getIp); GPort = (EditText)findViewById(R.id.getPort); TextShow = (TextView)findViewById(R.id.MegShow); btnSend.setEnabled(false); editSend.setEnabled(false); } public void closeSocket() { try { output.close(); socket.close(); } catch (IOException e) { handleException(e, "close exception: "); } } private void initClientSocket() { try { String ip = SERVER_HOST_IP; int port = SERVER_HOST_PORT; String temp; if( !GIp.getText().toString().equals("") && !GPort.getText().toString().equals("")) { ip = GIp.getText().toString(); temp = GPort.getText().toString(); port = Integer.valueOf(temp); toastText("Ip and Port Changed"); } SocketWork(ip, port); btnConnect.setEnabled(false); editSend.setEnabled(true); btnSend.setEnabled(true); toastText("SocketOk"); } catch (Exception e) { handleException(e, "unknown host exception: " + e.toString()); } } private void MessageShow() { TextShow.setText(Msg); } private void SocketWork(final String ip, final int port) { new Thread() { public void run() { try { socket = new Socket(ip, port); /* 获取输出流 */ output = new PrintStream(socket.getOutputStream(), true, "utf-8"); inputD = new DataInputStream(socket.getInputStream()); dataGet = new byte[10000]; int iRecive; for(int i = 0; i < dataGet.length; i++) { dataGet[i] = 0; } int length = inputD.read(dataGet); Msg = new String(dataGet, 0, length, "gb2312"); //toastText(Msg); }catch (UnknownHostException e) { //handleException(e, "unknown host exception: " + e.toString()); } catch (IOException e) { // handleException(e, "io exception: " + e.toString()); } } }.start(); } private void sendMessage(String msg) { output.print(msg); } }