android 安卓手机与电脑socket通信

package net.testSocket; import java.io.*; import java.net.InetSocketAddress; import java.net.Socket; import java.net.UnknownHostException; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.SocketChannel; import java.nio.charset.Charset; import java.util.Random; import android.annotation.SuppressLint; import android.app.Activity; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.util.Log; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.TextView; public class TestSocket extends Activity { private TextView text1; private Button but1; private EditText edit1,Edip,Edport; private final String DEBUG_TAG="mySocketAct"; Socket socket=null; static String content =""; private Selector selector = null; private Charset charset = Charset.forName("GBK"); private SocketChannel sc = null; private Handler handler; @SuppressLint("HandlerLeak") public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); text1=(TextView)findViewById(R.id.text1); but1=(Button)findViewById(R.id.but1); edit1=(EditText)findViewById(R.id.edit1); Edip=(EditText)findViewById(R.id.ip); Edport=(EditText)findViewById(R.id.port); but1.setOnClickListener(new Button.OnClickListener() { @Override public void onClick(View v) { String mesg=edit1.getText().toString()+"\r\n"; edit1.setText(""); Log.e("dddd", "sent id"); try { sendData(mesg); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); }catch(Exception e) { Log.e(DEBUG_TAG,e.toString()); } new Thread(new Runnable(){ public void run() { try { while (selector.select() > 0) { for (SelectionKey sk : selector.selectedKeys()) { selector.selectedKeys().remove(sk); if (sk.isReadable()) { content =""; SocketChannel sc = (SocketChannel)sk.channel(); ByteBuffer buff = ByteBuffer.allocate(1024); while(sc.read(buff) > 0) { sc.read(buff); buff.flip(); content += charset.decode(buff); } Message m=handler.obtainMessage(); m.what=0x11; handler.sendMessage(m); sk.interestOps(SelectionKey.OP_READ); } } } } catch (IOException ex) { ex.printStackTrace(); } } }).start(); } }); handler=new Handler(){ @Override public void handleMessage(Message msg){ if(msg.what==0x11){ text1.setText(content); } super.handleMessage(msg); } }; } public void sendData(String string)throws IOException { selector = Selector.open(); String ip=Edip.getText().toString(); String port=Edport.getText().toString(); int pt=Integer.parseInt(port); InetSocketAddress isa = new InetSocketAddress(ip, pt); sc = SocketChannel.open(isa); sc.configureBlocking(false); sc.register(selector, SelectionKey.OP_READ); sc.write(charset.encode(string)); } }