【移动应用开发技术】android socket通信 创建线程接受 客户端

【移动应用开发技术】androidsocket通信创建线程接受客户端

//声明量

privateString

IPaddress="20";

privateint

port=50003;

privateHandlermhandler=null;

privateStringcc="";

private

TextViewreturnvalue;//

动态接收数据mhandler=newHandler(){

publicvoidhandleMessage(Messagemsg)

{

if(msg.what==1)

{

if(cc!=null||cc!="")

{

returnvalue.setText(cc);

cc=null;

}

}

super.handleMessage(msg);

}

};//启动相关线程

serverThreadthread=newserverThread();

thread.start();//创建并发送数据

byte[]buf=

{(byte)0x55,(byte)0xAA};

try{

socket=newSocket(this.IPaddress,this.port);

OutputStreamout=socket.getOutputStream();

OutputStreamWriterwriter=newOutputStreamWriter(out);

out.write(buf);

writer.flush();

Toast.makeText(PauseActivity.this,"成功",

Toast.LENGTH_SHORT).show();

}catch(UnknownHostExceptione){Toast.makeText(PauseActivity.this,"异常",

Toast.LENGTH_SHORT).show();

e.printStackTrace();

}catch(IOExceptione){

e.printStackTrace();

}//接受数据

publicclassserverThreadextendsThread

{

publicvoidrun(){

while(!Thread.currentThread().isInterrupted()){

if(socket==null)

{

try{

Thread.sleep(1000);

}catch(InterruptedExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

}

}else

{

try{

Thread.sleep(1000);

InputStreamips=socket.getInputStream();

InputStreamReader

in=newInputStreamReader(ips);

in.ready();

cc="";

for(inti=0;i<2;i++)

{

cc+=ips.read()+"-";

}

}catch(InterruptedExceptione){

e.printStackTrace();

}catch(IOExceptione){

e.printStackTrace();

}

Messagemsg=newMessage();