安卓手机socket通信（服务器和客户端）

package com.example.androidsockettest;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;import android.net.wifi.WifiInfo;import android.net.wifi.WifiManager;import android.os.Bundle;import android.os.Handler;import android.os.Message;import android.app.Activity;import android.content.Context;import android.view.Menu;import android.widget.TextView;public class MainActivity extends Activity { public static ServerSocket serverSocket = null; public static TextView mTextView, textView1;  private String IP = "";  String buffer = ""; public static Handler mHandler = new Handler() { @Override public void handleMessage(android.os.Message msg) {  if (msg.what==0x11) {  Bundle bundle = msg.getData();  mTextView.append("client"+bundle.getString("msg")+"/n");  } }; }; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); mTextView = (TextView) findViewById(R.id.textsss); textView1 = (TextView) findViewById(R.id.textView1); IP = getlocalip(); textView1.setText("IP addresss:"+IP); new Thread() {  public void run() {  Bundle bundle = new Bundle();  bundle.clear();  OutputStream output;  String str = "通信成功";  try {   serverSocket = new ServerSocket(30000);   while (true) {   Message msg = new Message();   msg.what = 0x11;   try {    Socket socket = serverSocket.accept();    output = socket.getOutputStream();    output.write(str.getBytes("UTF-8"));    output.flush();    socket.shutdownOutput();    //mHandler.sendEmptyMessage(0);    BufferedReader bff = new BufferedReader(new InputStreamReader(socket.getInputStream()));    String line = null;    buffer = "";    while ((line = bff.readLine())!=null) {    buffer = line + buffer;    }    bundle.putString("msg", buffer.toString());    msg.setData(bundle);    mHandler.sendMessage(msg);    bff.close();    output.close();    socket.close();   } catch (IOException e) {    e.printStackTrace();   }   }  } catch (IOException e1) {   // TODO Auto-generated catch block   e1.printStackTrace();  }  }; }.start(); } private String getlocalip(){     WifiManager wifiManager = (WifiManager)getSystemService(Context.WIFI_SERVICE);       WifiInfo wifiInfo = wifiManager.getConnectionInfo();       int ipAddress = wifiInfo.getIpAddress();      // Log.d(Tag, "int ip "+ipAddress);      if(ipAddress==0)return null;      return ((ipAddress & 0xff)+"."+(ipAddress>>8 & 0xff)+"."         +(ipAddress>>16 & 0xff)+"."+(ipAddress>>24 & 0xff));    }  } 

package com.example.andoroidclient;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.InetSocketAddress;import java.net.Socket;import java.net.SocketTimeoutException;import android.os.Bundle;import android.os.Handler;import android.os.Message;import android.app.Activity;import android.view.Menu;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import android.widget.EditText;import android.widget.TextView;public class MainActivity extends Activity { Socket socket = null; String buffer = ""; TextView txt1; Button send; EditText ed1; String geted1; public Handler myHandler = new Handler() { @Override public void handleMessage(Message msg) {  if (msg.what == 0x11) {  Bundle bundle = msg.getData();  txt1.append("server:" + bundle.getString("msg") + "/n");  } } }; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); txt1 = (TextView) findViewById(R.id.txt1); send = (Button) findViewById(R.id.send); ed1 = (EditText) findViewById(R.id.ed1); new MyThread("建立连接").start(); send.setOnClickListener(new OnClickListener() {  @Override  public void onClick(View v) {  geted1 = ed1.getText().toString();  txt1.append("client:" + geted1 + "/n");  // 启动线程 向服务器发送和接收信息  new MyThread(geted1).start();  } }); } class MyThread extends Thread { public String txt1; public MyThread(String str) {  txt1 = str; } @Override public void run() {  // 定义消息  Message msg = new Message();  msg.what = 0x11;  Bundle bundle = new Bundle();  bundle.clear();  try {  // 连接服务器 并设置连接超时为5秒  socket = new Socket();  socket.connect(new InetSocketAddress("172.20.226.11", 30000), 1000);  // 获取输入输出流  OutputStream ou = socket.getOutputStream();  BufferedReader bff = new BufferedReader(new InputStreamReader(socket.getInputStream()));  // 读取发来服务器信息  String line = null;  buffer = "";  while ((line = bff.readLine()) != null) {   buffer = line + buffer;  }  // 向服务器发送信息  ou.write(txt1.getBytes("gbk"));  ou.flush();  bundle.putString("msg", buffer.toString());  msg.setData(bundle);  // 发送消息 修改UI线程中的组件  myHandler.sendMessage(msg);  // 关闭各种输入输出流  bff.close();  ou.close();  socket.close();  } catch (SocketTimeoutException aa) {  // 连接超时 在UI界面显示消息  bundle.putString("msg", "服务器连接失败！请检查网络是否打开");  msg.setData(bundle);  // 发送消息 修改UI线程中的组件  myHandler.sendMessage(msg);  } catch (IOException e) {  e.printStackTrace();  } } }}