PC客戶端與Android服務端的Socket同步通信教學資料

1、Good is good, but better carries it.精益求精，善益求善。PC客戶端與Android服務端的Socket同步通信-PC客戶端與Android服務端的Socket同步通信（USB）收藏需求：1.一個android端的service后臺運行的程序，作為socket的服務器端;用于接收Pcclient端發(fā)來的命令，來處理數(shù)據(jù)后，把結果發(fā)給PCclient2.PC端程序，作為socket的客戶端，用于給android手機端發(fā)操作命令難點分析：1.手機一定要有adb模式，即插上USB線時馬上提示的對話框選adb。好多對手機的操作都可以用adb直接作。不過，我發(fā)現(xiàn)LGGW

2、880就沒有，要去下載個2.android默認手機端的IP為“”3.要想聯(lián)通PC與android手機的sokcet，一定要用adbforward來作下端口轉發(fā)才能連上socket.viewplaincopytoclipboardprint?Runtime.getRuntime().exec(adbforwardtcp:12580tcp:10086);Thread.sleep(3000);Runtime.getRuntime().exec(adbforwardtcp:12580tcp:10086);Thread.sleep(3000);4.android端的service程序Install到手機

3、上容易，但是還要有方法來從PC的client端來啟動手機上的service，這個辦法可以通過PC端adb命令來發(fā)一個Broastcast，手機端再寫個接收BroastcastReceive來接收這個Broastcast，在這個BroastcastReceive來啟動servicepc端命令：viewplaincopytoclipboardprint?Runtime.getRuntime().exec(adbshellambroadcast-aNotifyServiceStart);Runtime.getRuntime().exec(adbshellambroadcast-aNotifyServ

4、iceStart);android端的代碼:ServiceBroadcastReceiver.javaviewplaincopytoclipboardprint?packagecom.otheri.service;importandroid.content.BroadcastReceiver;importandroid.content.Context;importandroid.content.Intent;importandroid.util.Log;publicclassServiceBroadcastReceiverextendsBroadcastReceiverprivatestati

5、cStringSTART_ACTION=NotifyServiceStart;privatestaticStringSTOP_ACTION=NotifyServiceStop;OverridepublicvoidonReceive(Contextcontext,Intentintent)Log.d(androidService.TAG,Thread.currentThread().getName()+-+ServiceBroadcastReceiveronReceive);Stringaction=intent.getAction();if(START_ACTION.equalsIgnoreC

6、ase(action)context.startService(newIntent(context,androidService.class);Log.d(androidService.TAG,Thread.currentThread().getName()+-+ServiceBroadcastReceiveronReceivestartend);elseif(STOP_ACTION.equalsIgnoreCase(action)context.stopService(newIntent(context,androidService.class);Log.d(androidService.T

7、AG,Thread.currentThread().getName()+-+ServiceBroadcastReceiveronReceivestopend);packagecom.otheri.service;importandroid.content.BroadcastReceiver;importandroid.content.Context;importandroid.content.Intent;importandroid.util.Log;publicclassServiceBroadcastReceiverextendsBroadcastReceiverprivatestatic

8、StringSTART_ACTION=NotifyServiceStart;privatestaticStringSTOP_ACTION=NotifyServiceStop;OverridepublicvoidonReceive(Contextcontext,Intentintent)Log.d(androidService.TAG,Thread.currentThread().getName()+-+ServiceBroadcastReceiveronReceive);Stringaction=intent.getAction();if(START_ACTION.equalsIgnoreCa

9、se(action)context.startService(newIntent(context,androidService.class);Log.d(androidService.TAG,Thread.currentThread().getName()+-+ServiceBroadcastReceiveronReceivestartend);elseif(STOP_ACTION.equalsIgnoreCase(action)context.stopService(newIntent(context,androidService.class);Log.d(androidService.TA

10、G,Thread.currentThread().getName()+-+ServiceBroadcastReceiveronReceivestopend);5.由于是USB連接，所以socket就可以設計為一但連接就一直聯(lián)通，即在newsocket和開完out,in流后，就用個while(true)來循環(huán)PC端和android端的讀和寫android的代碼：viewplaincopytoclipboardprint?publicvoidrun()Log.d(androidService.TAG,Thread.currentThread().getName()+-+aclienthasconn

11、ectedtoserver!);BufferedOutputStreamout;BufferedInputStreamin;try/*PC端發(fā)來的數(shù)據(jù)msg*/StringcurrCMD=;out=newBufferedOutputStream(client.getOutputStream();in=newBufferedInputStream(client.getInputStream();/testSocket();/測試socket方法androidService.ioThreadFlag=true;while(androidService.ioThreadFlag)tryif(!cli

12、ent.isConnected()break;/*接收PC發(fā)來的數(shù)據(jù)*/Log.v(androidService.TAG,Thread.currentThread().getName()+-+willread.);/*讀操作命令*/currCMD=readCMDFromSocket(in);Log.v(androidService.TAG,Thread.currentThread().getName()+-+*currCMD=+currCMD);/*根據(jù)命令分別處理數(shù)據(jù)*/if(currCMD.equals(1)out.write(OK.getBytes();out.flush();elsei

13、f(currCMD.equals(2)out.write(OK.getBytes();out.flush();elseif(currCMD.equals(3)out.write(OK.getBytes();out.flush();elseif(currCMD.equals(4)/*準備接收文件數(shù)據(jù)*/tryout.write(servicereceiveOK.getBytes();out.flush();catch(IOExceptione)e.printStackTrace();/*接收文件數(shù)據(jù)，4字節(jié)文件長度，4字節(jié)文件格式，其后是文件數(shù)據(jù)*/bytefilelength=newbyte4

14、;bytefileformat=newbyte4;bytefilebytes=null;/*從socket流中讀取完整文件數(shù)據(jù)*/filebytes=receiveFileFromSocket(in,out,filelength,fileformat);/Log.v(Service139.TAG,receivedata=+new/String(filebytes);try/*生成文件*/Filefile=FileHelper.newFile(R0013340.JPG);FileHelper.writeFile(file,filebytes,0,filebytes.length);catch(I

15、OExceptione)e.printStackTrace();elseif(currCMD.equals(exit)catch(Exceptione)/try/out.write(error.getBytes(utf-8);/out.flush();/catch(IOExceptione1)/e1.printStackTrace();/Log.e(androidService.TAG,Thread.currentThread().getName()+-+readwriteerror111111);out.close();in.close();catch(Exceptione)Log.e(an

16、droidService.TAG,Thread.currentThread().getName()+-+readwriteerror222222);e.printStackTrace();finallytryif(client!=null)Log.v(androidService.TAG,Thread.currentThread().getName()+-+client.close();client.close();catch(IOExceptione)Log.e(androidService.TAG,Thread.currentThread().getName()+-+readwriteer

17、ror333333);e.printStackTrace();publicvoidrun()Log.d(androidService.TAG,Thread.currentThread().getName()+-+aclienthasconnectedtoserver!);BufferedOutputStreamout;BufferedInputStreamin;try/*PC端發(fā)來的數(shù)據(jù)msg*/StringcurrCMD=;out=newBufferedOutputStream(client.getOutputStream();in=newBufferedInputStream(client

18、.getInputStream();/testSocket();/測試socket方法androidService.ioThreadFlag=true;while(androidService.ioThreadFlag)tryif(!client.isConnected()break;/*接收PC發(fā)來的數(shù)據(jù)*/Log.v(androidService.TAG,Thread.currentThread().getName()+-+willread.);/*讀操作命令*/currCMD=readCMDFromSocket(in);Log.v(androidService.TAG,Thread.cu

19、rrentThread().getName()+-+*currCMD=+currCMD);/*根據(jù)命令分別處理數(shù)據(jù)*/if(currCMD.equals(1)out.write(OK.getBytes();out.flush();elseif(currCMD.equals(2)out.write(OK.getBytes();out.flush();elseif(currCMD.equals(3)out.write(OK.getBytes();out.flush();elseif(currCMD.equals(4)/*準備接收文件數(shù)據(jù)*/tryout.write(servicereceiveOK

20、.getBytes();out.flush();catch(IOExceptione)e.printStackTrace();/*接收文件數(shù)據(jù)，4字節(jié)文件長度，4字節(jié)文件格式，其后是文件數(shù)據(jù)*/bytefilelength=newbyte4;bytefileformat=newbyte4;bytefilebytes=null;/*從socket流中讀取完整文件數(shù)據(jù)*/filebytes=receiveFileFromSocket(in,out,filelength,fileformat);/Log.v(Service139.TAG,receivedata=+new/String(filebyt

21、es);try/*生成文件*/Filefile=FileHelper.newFile(R0013340.JPG);FileHelper.writeFile(file,filebytes,0,filebytes.length);catch(IOExceptione)e.printStackTrace();elseif(currCMD.equals(exit)catch(Exceptione)/try/out.write(error.getBytes(utf-8);/out.flush();/catch(IOExceptione1)/e1.printStackTrace();/Log.e(andr

22、oidService.TAG,Thread.currentThread().getName()+-+readwriteerror111111);out.close();in.close();catch(Exceptione)Log.e(androidService.TAG,Thread.currentThread().getName()+-+readwriteerror222222);e.printStackTrace();finallytryif(client!=null)Log.v(androidService.TAG,Thread.currentThread().getName()+-+

23、client.close();client.close();catch(IOExceptione)Log.e(androidService.TAG,Thread.currentThread().getName()+-+readwriteerror333333);e.printStackTrace();6.如果是在PC端和android端的讀寫操作來while(true)循環(huán)，這樣socket流的結尾不好判斷，不能用“-1”來判斷，因為“-1”是只有在socket關閉時才作為判斷結尾。7.socket在out.write(bytes);時，要是數(shù)據(jù)太大時，超過socket的緩存，socket自動

24、分包發(fā)送，所以對方就一定要用循環(huán)來多次讀。最好的辦法就是服務器和客戶端協(xié)議好，比如發(fā)文件時，先寫過來一個要發(fā)送的文件的大小，然后再發(fā)送文件;對方用這個大小，來循環(huán)讀取數(shù)據(jù)。android端接收數(shù)據(jù)的代碼:viewplaincopytoclipboardprint?/*功能：從socket流中讀取完整文件數(shù)據(jù)*InputStreamin：socket輸入流*bytefilelength:流的前4個字節(jié)存儲要轉送的文件的字節(jié)數(shù)*bytefileformat：流的前5-8字節(jié)存儲要轉送的文件的格式（如.apk）*/publicstaticbytereceiveFileFromSocket(Input

25、Streamin,OutputStreamout,bytefilelength,bytefileformat)bytefilebytes=null;/文件數(shù)據(jù)tryintfilelen=MyUtil.bytesToInt(filelength);/文件長度從4字節(jié)byte轉成IntStringstrtmp=readfilelengthok:+filelen;out.write(strtmp.getBytes(utf-8);out.flush();filebytes=newbytefilelen;intpos=0;intrcvLen=0;while(rcvLen=in.read(filebyte

26、s,pos,filelen-pos)0)pos+=rcvLen;Log.v(androidService.TAG,Thread.currentThread().getName()+-+readfileOK:filesize=+filebytes.length);out.write(readfileok.getBytes(utf-8);out.flush();catch(Exceptione)Log.v(androidService.TAG,Thread.currentThread().getName()+-+receiveFileFromSocketerror);e.printStackTra

27、ce();returnfilebytes;/*功能：從socket流中讀取完整文件數(shù)據(jù)*InputStreamin：socket輸入流*bytefilelength:流的前4個字節(jié)存儲要轉送的文件的字節(jié)數(shù)*bytefileformat：流的前5-8字節(jié)存儲要轉送的文件的格式（如.apk）*/publicstaticbytereceiveFileFromSocket(InputStreamin,OutputStreamout,bytefilelength,bytefileformat)bytefilebytes=null;/文件數(shù)據(jù)tryintfilelen=MyUtil.bytesToInt(

28、filelength);/文件長度從4字節(jié)byte轉成IntStringstrtmp=readfilelengthok:+filelen;out.write(strtmp.getBytes(utf-8);out.flush();filebytes=newbytefilelen;intpos=0;intrcvLen=0;while(rcvLen=in.read(filebytes,pos,filelen-pos)0)pos+=rcvLen;Log.v(androidService.TAG,Thread.currentThread().getName()+-+readfileOK:filesize

29、=+filebytes.length);out.write(readfileok.getBytes(utf-8);out.flush();catch(Exceptione)Log.v(androidService.TAG,Thread.currentThread().getName()+-+receiveFileFromSocketerror);e.printStackTrace();returnfilebytes;8.socket的最重要的機制就是讀寫采用的是阻塞的方式，如果客戶端作為命令發(fā)起者，服務器端作為接收者的話，只有當客戶端client用out.writer()寫到輸出流里后，即流中

30、有數(shù)據(jù)service的read才會執(zhí)行，不然就會一直停在read()那里等數(shù)據(jù)。9.還要讓服務器端可以同時連接多個client，即服務器端用newthread()來作數(shù)據(jù)讀取操作。源碼：客戶端（pc端）：testPcClient.javaviewplaincopytoclipboardprint?importjava.io.BufferedInputStream;importjava.io.BufferedOutputStream;importjava.io.BufferedReader;importjava.io.ByteArrayOutputStream;importjava.io.IOE

31、xception;importjava.io.InputStream;importjava.io.InputStreamReader;.InetAddress;.Socket;.UnknownHostException;publicclasstestPcClient/*paramargs*throwsInterruptedException*/publicstaticvoidmain(Stringargs)throwsInterruptedExceptiontryRuntime.getRuntime().exec(adbshellambroadcast-aNotifyServiceStop);

32、Thread.sleep(3000);Runtime.getRuntime().exec(adbforwardtcp:12580tcp:10086);Thread.sleep(3000);Runtime.getRuntime().exec(adbshellambroadcast-aNotifyServiceStart);Thread.sleep(3000);catch(IOExceptione3)e3.printStackTrace();Socketsocket=null;tryInetAddressserverAddr=null;serverAddr=InetAddress.getByNam

33、e();System.out.println(TCP1111+C:Connecting.);socket=newSocket(serverAddr,12580);Stringstr=hi,wufenglong;System.out.println(TCP221122+C:RECEIVE);BufferedOutputStreamout=newBufferedOutputStream(socket.getOutputStream();BufferedInputStreamin=newBufferedInputStream(socket.getInputStream();BufferedReade

34、rbr=newBufferedReader(newInputStreamReader(System.in);booleanflag=true;while(flag)System.out.print(請輸入16的數(shù)字,退出輸入exit：);StringstrWord=br.readLine();/從控制臺輸入16if(strWord.equals(1)out.write(1.getBytes();out.flush();System.out.println(1finishsendingthedata);StringstrFormsocket=readFromSocket(in);System.o

35、ut.println(thedatasentbyserveris:rn+strFormsocket);System.out.println(=);elseif(strWord.equals(2)out.write(2.getBytes();out.flush();System.out.println(2finishsendingthedata);StringstrFormsocket=readFromSocket(in);System.out.println(thedatasentbyserveris:rn+strFormsocket);System.out.println(=);elseif

36、(strWord.equals(3)out.write(3.getBytes();out.flush();System.out.println(3finishsendingthedata);StringstrFormsocket=readFromSocket(in);System.out.println(thedatasentbyserveris:rn+strFormsocket);System.out.println(=);elseif(strWord.equals(4)/*發(fā)送命令*/out.write(4.getBytes();out.flush();System.out.println

37、(sendfilefinishsendingtheCMD：);/*服務器反饋：準備接收*/StringstrFormsocket=readFromSocket(in);System.out.println(servicereadyreceicedata:UPDATE_CONTACTS:+strFormsocket);bytefilebytes=FileHelper.readFile(R0013340.JPG);System.out.println(filesize=+filebytes.length);/*將整數(shù)轉成4字節(jié)byte數(shù)組*/bytefilelength=newbyte4;file

38、length=ToByte(filebytes.length);/*將.apk字符串轉成4字節(jié)byte數(shù)組*/bytefileformat=null;fileformat=.apk.getBytes();System.out.println(fileformatlength=+fileformat.length);/*字節(jié)流中前4字節(jié)為文件長度，4字節(jié)文件格式，以后是文件流*/*注意如果write里的byte超過socket的緩存，系統(tǒng)自動分包寫過去，所以對方要循環(huán)寫完*/out.write(filelength);out.flush();Stringstrok1=readFromSocket

39、(in);System.out.println(servicereceivefilelength:+strok1);/out.write(fileformat);/out.flush();/Stringstrok2=readFromSocket(in);/System.out.println(servicereceivefileformat:+/strok2);System.out.println(writedatatoandroid);out.write(filebytes);out.flush();System.out.println(*);/*服務器反饋：接收成功*/Stringstrr

40、ead=readFromSocket(in);System.out.println(senddatasuccess:+strread);System.out.println(=);elseif(strWord.equalsIgnoreCase(EXIT)out.write(EXIT.getBytes();out.flush();System.out.println(EXITfinishsendingthedata);StringstrFormsocket=readFromSocket(in);System.out.println(thedatasentbyserveris:rn+strForm

41、socket);flag=false;System.out.println(=);catch(UnknownHostExceptione1)System.out.println(TCP331133+ERROR:+e1.toString();catch(Exceptione2)System.out.println(TCP441144+ERROR:+e2.toString();finallytryif(socket!=null)socket.close();System.out.println(socket.close();catch(IOExceptione)System.out.println

42、(TCP5555+ERROR:+e.toString();/*從InputStream流中讀數(shù)據(jù)*/publicstaticStringreadFromSocket(InputStreamin)intMAX_BUFFER_BYTES=4000;Stringmsg=;bytetempbuffer=newbyteMAX_BUFFER_BYTES;tryintnumReadedBytes=in.read(tempbuffer,0,tempbuffer.length);msg=newString(tempbuffer,0,numReadedBytes,utf-8);tempbuffer=null;ca

43、tch(Exceptione)e.printStackTrace();/Log.v(Service139.TAG,msg=+msg);returnmsg;importjava.io.BufferedInputStream;importjava.io.BufferedOutputStream;importjava.io.BufferedReader;importjava.io.ByteArrayOutputStream;importjava.io.IOException;importjava.io.InputStream;importjava.io.InputStreamReader;.Inet

44、Address;.Socket;.UnknownHostException;publicclasstestPcClient/*paramargs*throwsInterruptedException*/publicstaticvoidmain(Stringargs)throwsInterruptedExceptiontryRuntime.getRuntime().exec(adbshellambroadcast-aNotifyServiceStop);Thread.sleep(3000);Runtime.getRuntime().exec(adbforwardtcp:12580tcp:1008

45、6);Thread.sleep(3000);Runtime.getRuntime().exec(adbshellambroadcast-aNotifyServiceStart);Thread.sleep(3000);catch(IOExceptione3)e3.printStackTrace();Socketsocket=null;tryInetAddressserverAddr=null;serverAddr=InetAddress.getByName();System.out.println(TCP1111+C:Connecting.);socket=newSocket(serverAdd

46、r,12580);Stringstr=hi,wufenglong;System.out.println(TCP221122+C:RECEIVE);BufferedOutputStreamout=newBufferedOutputStream(socket.getOutputStream();BufferedInputStreamin=newBufferedInputStream(socket.getInputStream();BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in);booleanflag=true;w

47、hile(flag)System.out.print(請輸入16的數(shù)字,退出輸入exit：);StringstrWord=br.readLine();/從控制臺輸入16if(strWord.equals(1)out.write(1.getBytes();out.flush();System.out.println(1finishsendingthedata);StringstrFormsocket=readFromSocket(in);System.out.println(thedatasentbyserveris:rn+strFormsocket);System.out.println(=)

48、;elseif(strWord.equals(2)out.write(2.getBytes();out.flush();System.out.println(2finishsendingthedata);StringstrFormsocket=readFromSocket(in);System.out.println(thedatasentbyserveris:rn+strFormsocket);System.out.println(=);elseif(strWord.equals(3)out.write(3.getBytes();out.flush();System.out.println(

49、3finishsendingthedata);StringstrFormsocket=readFromSocket(in);System.out.println(thedatasentbyserveris:rn+strFormsocket);System.out.println(=);elseif(strWord.equals(4)/*發(fā)送命令*/out.write(4.getBytes();out.flush();System.out.println(sendfilefinishsendingtheCMD：);/*服務器反饋：準備接收*/StringstrFormsocket=readFro

50、mSocket(in);System.out.println(servicereadyreceicedata:UPDATE_CONTACTS:+strFormsocket);bytefilebytes=FileHelper.readFile(R0013340.JPG);System.out.println(filesize=+filebytes.length);/*將整數(shù)轉成4字節(jié)byte數(shù)組*/bytefilelength=newbyte4;filelength=ToByte(filebytes.length);/*將.apk字符串轉成4字節(jié)byte數(shù)組*/bytefileformat=nu

51、ll;fileformat=.apk.getBytes();System.out.println(fileformatlength=+fileformat.length);/*字節(jié)流中前4字節(jié)為文件長度，4字節(jié)文件格式，以后是文件流*/*注意如果write里的byte超過socket的緩存，系統(tǒng)自動分包寫過去，所以對方要循環(huán)寫完*/out.write(filelength);out.flush();Stringstrok1=readFromSocket(in);System.out.println(servicereceivefilelength:+strok1);/out.write(fil

52、eformat);/out.flush();/Stringstrok2=readFromSocket(in);/System.out.println(servicereceivefileformat:+/strok2);System.out.println(writedatatoandroid);out.write(filebytes);out.flush();System.out.println(*);/*服務器反饋：接收成功*/Stringstrread=readFromSocket(in);System.out.println(senddatasuccess:+strread);Syst

53、em.out.println(=);elseif(strWord.equalsIgnoreCase(EXIT)out.write(EXIT.getBytes();out.flush();System.out.println(EXITfinishsendingthedata);StringstrFormsocket=readFromSocket(in);System.out.println(thedatasentbyserveris:rn+strFormsocket);flag=false;System.out.println(=);catch(UnknownHostExceptione1)Sy

54、stem.out.println(TCP331133+ERROR:+e1.toString();catch(Exceptione2)System.out.println(TCP441144+ERROR:+e2.toString();finallytryif(socket!=null)socket.close();System.out.println(socket.close();catch(IOExceptione)System.out.println(TCP5555+ERROR:+e.toString();/*從InputStream流中讀數(shù)據(jù)*/publicstaticStringread

55、FromSocket(InputStreamin)intMAX_BUFFER_BYTES=4000;Stringmsg=;bytetempbuffer=newbyteMAX_BUFFER_BYTES;tryintnumReadedBytes=in.read(tempbuffer,0,tempbuffer.length);msg=newString(tempbuffer,0,numReadedBytes,utf-8);tempbuffer=null;catch(Exceptione)e.printStackTrace();/Log.v(Service139.TAG,msg=+msg);retur

56、nmsg;android服務器端：主類androidService.javaviewplaincopytoclipboardprint?packagecom.otheri.service;importjava.io.File;importjava.io.IOException;.ServerSocket;.Socket;importandroid.app.Service;importandroid.content.BroadcastReceiver;importandroid.content.Context;importandroid.content.Intent;importandroid.

57、content.IntentFilter;importandroid.os.IBinder;importandroid.util.Log;/*設置：android手機*/publicclassandroidServiceextendsServicepublicstaticfinalStringTAG=TAG;publicstaticBooleanmainThreadFlag=true;publicstaticBooleanioThreadFlag=true;ServerSocketserverSocket=null;finalintSERVER_PORT=10086;FiletestFile;

58、privatesysBroadcastReceiversysBR;OverridepublicvoidonCreate()super.onCreate();Log.v(TAG,Thread.currentThread().getName()+-+onCreate);/*創(chuàng)建內(nèi)部類sysBroadcastReceiver并注冊registerReceiver*/sysRegisterReceiver();newThread()publicvoidrun()doListen();.start();privatevoiddoListen()Log.d(TAG,Thread.currentThread

59、().getName()+-+doListen()START);serverSocket=null;tryLog.d(TAG,Thread.currentThread().getName()+-+doListen()newserverSocket);serverSocket=newServerSocket(SERVER_PORT);booleanmainThreadFlag=true;while(mainThreadFlag)Log.d(TAG,Thread.currentThread().getName()+-+doListen()listen);Socketclient=serverSoc

60、ket.accept();newThread(newThreadReadWriterIOSocket(this,client).start();catch(IOExceptione1)Log.v(androidService.TAG,Thread.currentThread().getName()+-+newserverSocketerror);e1.printStackTrace();/*創(chuàng)建內(nèi)部類sysBroadcastReceiver并注冊registerReceiver*/privatevoidsysRegisterReceiver()Log.v(TAG,Thread.currentT