PC客戶端與Android服務(wù)端的Socket同步通信

1、PC客戶端與An droid服務(wù)端的Socket同步通信(USB) 收藏需求：1. 一個(gè)an droid端的service后臺(tái)運(yùn)行的程序，作為socket的服務(wù)器端；用于接收Pc clie nt 端發(fā)來(lái)的命令，來(lái)處理數(shù)據(jù)后，把結(jié)果發(fā)給PC clie nt2. PC端程序，作為socket的客戶端，用于給an droid手機(jī)端發(fā)操作命令難點(diǎn)分析：1. 手機(jī)一定要有adb模式，即插上 USB線時(shí)馬上提示的對(duì)話框選adb。好多對(duì)手機(jī)的操作都可以用adb直接作。不過(guò)，我發(fā)現(xiàn)LG GW880就沒(méi)有，要去下載個(gè)2. android 默認(rèn)手機(jī)端的 IP 為 “127.0.0.1”3. 要想聯(lián)通PC與an d

2、roid手機(jī)的sokcet，一定要用adb forward來(lái)作下端口轉(zhuǎn)發(fā)才能連 上 socket.view pla in copy to clipboardpri nt?Run time.getR un time().exec("adb forward tcp:12580 tcp:10086");Thread.sleep(3000);Run time.getR un time().exec("adb forward tcp:12580 tcp:10086");Thread.sleep(3000);4. a ndroid端的service程序In stal

3、l到手機(jī)上容易，但是還要有方法來(lái)從PC的clie nt端來(lái)啟動(dòng)手機(jī)上的 service，這個(gè)辦法可以通過(guò) PC端adb命令來(lái)發(fā)一個(gè) Broastcast ，手機(jī) 端再寫個(gè)接收 BroastcastReceive來(lái)接收這個(gè) Broastcast，在這個(gè) BroastcastReceive來(lái)啟動(dòng) servicepc端命令：view pla in copy to clipboardpri nt?Run time.getR un time().exec("adb shell am broadcast -a NotifyServiceStart");Run time.getR un

4、time().exec("adb shell am broadcast -a NotifyServiceStart");an droid 端的代碼:ServiceBroadcastReceiver.javaview pla in copy to clipboardpri nt?package com.otheri.service;import an droid.c onten t.BroadcastReceiver;import an droid.c onten t.C on text;import an droid.c onten t.I ntent;import an

5、droid.util.Log;public class ServiceBroadcastReceiver exte nds BroadcastReceiver private static Stri ng START_ACTION = "NotifyServiceStart"private static Stri ng STOP_ACTION = "NotifyServiceStop"Overridepublic void on Receive(C on text con text, Intent intent) Log.d(androidService

6、.TAG , Thread.currentThread().getName() + ">"+ "ServiceBroadcastReceiver on Receive");String action = inten t.getAct ion();if (START_ACTION.equalslg noreCase(actio n) con text.startService (new Inten t(c on text, an droidService.class);Log.d(androidService.TAG , Thread.current

7、Thread().getName() + ">"+ "ServiceBroadcastReceiver on Receive start en d"); else if (STOP_ACTION.equalslg no reCase(actio n) con text.stopService (new Inten t(c on text, an droidService.class);Log.d(androidService.TAG , Thread.currentThread().getName() + ">"+ &qu

8、ot;ServiceBroadcastReceiver on Receive stop en d");package com.otheri.service;import an droid.c onten t.BroadcastReceiver;import an droid.c onten t.C on text;import an droid.c onten t.I ntent;import an droid.util.Log;public class ServiceBroadcastReceiver exte nds BroadcastReceiver private stati

9、c Stri ng START_ACTION = "NotifyServiceStart"private static Stri ng STOP_ACTION = "NotifyServiceStop"Overridepublic void on Receive(C on text con text, Intent intent) Log.d(androidService.TAG , Thread.currentThread().getName() + ">"+ "ServiceBroadcastReceiver on

10、 Receive");String action = inten t.getAct ion();if (START_ACTION.equalslg noreCase(actio n) con text.startService (new Inten t(c on text, an droidService.class);Log.d(androidService.TAG , Thread.currentThread().getName() + ">"+ "ServiceBroadcastReceiver on Receive start en d&q

11、uot;); else if (STOP_ACTION.equalsIg noreCase(actio n) con text.stopService (new Inten t(c on text, an droidService.class);Log.d(androidService.TAG , Thread.currentThread().getName() + ">"+ "ServiceBroadcastReceiver on Receive stop en d");5. 由于是USB連接，所以socket就可以設(shè)計(jì)為一但連接就一直聯(lián)通，即在

12、new socket和開完out,in流后，就用個(gè) while(true)來(lái)循環(huán)PC端和an droid端的讀和寫an droid的代碼：view pla in copy to clipboardpri nt?public void run() Log.d(androidService.TAG , Thread.currentThread().getName() + ">"+ "a clie nt has conn ected to server!");BufferedOutputStream out;BufferedI nputStream in

13、;try /* PC端發(fā)來(lái)的數(shù)據(jù) msg */Stri ng currCMD =""out = new BufferedOutputStream(clie nt.getOutputStream();in = new BufferedI nputStream(clie nt.getl nputStream();/ testSocket(); 測(cè)試 socket 方法an droidService.ioThreadFlag = true;while (an droidService.ioThreadFlag) try if (!clie nt.isCo nn ected() b

14、reak;/*接收PC發(fā)來(lái)的數(shù)據(jù)*/Log.v(androidService.TAG , Thread.currentThread().getName()+ "->" + "will read”)；/*讀操作命令*/currCMD = readCMDFromSocket(i n);Log.v(androidService.TAG , Thread.currentThread().getName()+ "->" + "*currCMD = " + currCMD);/*根據(jù)命令分別處理數(shù)據(jù)*/if (currCMD

15、.equals("1") out.write("OK".getBytes();out.flush(); else if (currCMD.equals("2") out.write("OK".getBytes();out.flush(); else if (currCMD.equals("3") out.write("OK".getBytes();out.flush(); else if (currCMD.equals("4") /*準(zhǔn)備接收文件數(shù)據(jù)*/t

16、ry out.write("service receive OK".getBytes();out.flush(); catch (IOExceptio n e) e.pri ntStackTrace();件數(shù)據(jù)*/*接收文件數(shù)據(jù)，4字節(jié)文件長(zhǎng)度，4字節(jié)文件格式，其后是文byte filele ngth = new byte4;byte fileformat = new byte4;byte filebytes = n ull;/*從socket流中讀取完整文件數(shù)據(jù)*/filebytes = receiveFileFromSocket( in, out, filele ngt

17、h,fileformat);/ Log.v(Service139.TAG , "receive data =" + new/ Stri ng(filebytes);try /*生成文件*/File file = FileHelper. newFile("R0013340.JPG");FileHelper.writeFile(file, filebytes, 0,filebytes .len gth); catch (IOExceptio n e) e.pri ntStackTrace(); else if (currCMD.equals("ex

18、it") catch (Exceptio n e) / try / out.write("error".getBytes("utf-8");/ out.flush();/ catch (IOException e1) / e1.pri ntStackTrace();/ Log.e(a ndroidService.TAG, Thread.curre ntThread().getName() + "->" + "read write error111111");out.close();in. close

19、(); catch (Excepti on e) Log.e(androidService.TAG , Thread.currentThread().getName()+ "->" + "read write error222222");e.pri ntStackTrace(); fin ally try if (clie nt != n ull) Log.v(androidService.TAG , Thread.currentThread().getName() + "->" + "clie nt.close

20、()");clie nt.close(); catch (IOExceptio n e) Log.e(androidService.TAG , Thread.currentThread().getName()+ "->" + "read write error333333");e.pri ntStackTrace();public void run() Log.d(androidService.TAG , Thread.currentThread().getName() + ">"+ "a clie n

21、t has conn ected to server!");BufferedOutputStream out;BufferedI nputStream in;try /* PC端發(fā)來(lái)的數(shù)據(jù) msg */Stri ng currCMD =""out = new BufferedOutputStream(clie nt.getOutputStream();in = new BufferedI nputStream(clie nt.getl nputStream();/ testSocket(); 測(cè)試 socket 方法an droidService.ioThread

22、Flag = true;while (an droidService.ioThreadFlag) try if (!clie nt.isCo nn ected() break;/*接收PC發(fā)來(lái)的數(shù)據(jù)*/Log.v(androidService.TAG , Thread.currentThread().getName()+ "->" + "will read.");/*讀操作命令*/currCMD = readCMDFromSocket(i n);Log.v(androidService.TAG , Thread.currentThread().ge

23、tName()+ "->" + "*currCMD = " + currCMD);/*根據(jù)命令分別處理數(shù)據(jù)*/if (currCMD.equals("1") out.write("OK".getBytes();out.flush(); else if (currCMD.equals("2") out.write("OK".getBytes();out.flush(); else if (currCMD.equals("3") out.write(&q

24、uot;OK".getBytes();out.flush(); else if (currCMD.equals("4") /*準(zhǔn)備接收文件數(shù)據(jù)*/try out.write("service receive OK".getBytes();out.flush(); catch (IOExceptio n e) e.pri ntStackTrace();件數(shù)據(jù)*/*接收文件數(shù)據(jù)，4字節(jié)文件長(zhǎng)度，4字節(jié)文件格式，其后是文byte filele ngth = new byte4;byte fileformat = new byte4;byte file

25、bytes = n ull;/*從socket流中讀取完整文件數(shù)據(jù)*/filebytes = receiveFileFromSocket(i n, out, filele ngth,fileformat);/ Log.v(Service139.TAG , "receive data =" + new/ Stri ng(filebytes);try /*生成文件*/File file = FileHelper. newFile("R0013340.JPG");FileHelper.writeFile(file, filebytes, 0, filebyte

26、sen gth); catch (IOExceptio n e) e.pri ntStackTrace(); else if (currCMD.equals("exit") catch (Excepti on e) / try / out.write("error".getBytes("utf-8");/ out.flush();/ catch (IOException e1) / e1.pri ntStackTrace();/ Log.e(androidService.TAG , Thread.currentThread().get

27、Name() + "->" + "read write error111111");out.close();in .close(); catch (Excepti on e) Log.e(androidService.TAG , Thread.currentThread().getName()+ "->" + "read write error222222");e.pri ntStackTrace(); fin ally try if (clie nt != n ull) Log.v(androidSe

28、rvice.TAG , Thread.currentThread().getName()+ "->" + "clie nt.close()");clie nt.close(); catch (IOExceptio n e) Log.e(a ndroidService.TAG, Thread.curre ntThread().getName()+ "->" + "read write error333333");e.pri ntStackTrace();6. 如果是在PC端和an droid端的讀寫操作來(lái)

29、 while(true)循環(huán)，這樣socket流的結(jié)尾不好 判斷，不能用“1”來(lái)判斷，因?yàn)?1”是只有在socket關(guān)閉時(shí)才作為判斷結(jié)尾。7. socket在out.write(bytes);時(shí)，要是數(shù)據(jù)太大時(shí)，超過(guò)socket的緩存，socket自動(dòng)分包發(fā)送，所以對(duì)方就一定要用循環(huán)來(lái)多次讀。最好的辦法就是服務(wù)器和客戶端協(xié)議好，比如發(fā)文件時(shí)，先寫過(guò)來(lái)一個(gè)要發(fā)送的文件的大小，然后再發(fā)送文件；對(duì)方用這個(gè)大小，來(lái)循環(huán)讀取數(shù)據(jù)。an droid端接收數(shù)據(jù)的代碼： view pla in copy to clipboardpri nt?*功能：從socket流中讀取完整文件數(shù)據(jù)* InputStream

30、 in : socket 輸入流* byte filelength:流的前4個(gè)字節(jié)存儲(chǔ)要轉(zhuǎn)送的文件的字節(jié)數(shù).apk)* byte fileformat :流的前5-8字節(jié)存儲(chǔ)要轉(zhuǎn)送的文件的格式(如public static byte receiveFileFromSocket( In putStream in.Outputstream out, byte filele ngth, byte fileformat) byte filebytes = n ull;文件數(shù)據(jù)try int filelen = MyUtil.bytesTolnt(filelength);/文件長(zhǎng)度從 4 字節(jié) byte

31、轉(zhuǎn)成 IntStri ng strtmp = "read file len gth ok:" + filele n; out.write(strtmp.getBytes("utf-8");out.flush();filebytes = new bytefilele n;int pos = 0;int rcvLe n = 0;while (rcvLe n = in. read(filebytes, pos, filele n - pos) > 0) pos += rcvLe n;Log.v(androidService.TAG , Thread.cu

32、rrentThread().getName() + "->" + "read file OK:file size=" + filebytes.le ngth);out.write("read file ok".getBytes("utf-8");out.flush(); catch (Excepti on e) Log.v(androidService.TAG , Thread.currentThread().getName()+ ">"+ "receiveFileFrom

33、Socket error");e.pri ntStackTrace(); retur n filebytes;*功能：從socket流中讀取完整文件數(shù)據(jù)* InputStream in : socket 輸入流* byte filelength:流的前4個(gè)字節(jié)存儲(chǔ)要轉(zhuǎn)送的文件的字節(jié)數(shù)*.apk)* byte fileformat :流的前5-8字節(jié)存儲(chǔ)要轉(zhuǎn)送的文件的格式(如*public static byte receiveFileFromSocket(l nputStream in,OutputStream out, byte filele ngth, byte fileform

34、at) byte filebytes = n ull;文件數(shù)據(jù)try int filelen = MyUtil.bytesTolnt(filelength);/文件長(zhǎng)度從 4 字節(jié) byte轉(zhuǎn)成 IntStri ng strtmp = "read file len gth ok:" + filele n;out.write(strtmp.getBytes("utf-8");out.flush();filebytes = new bytefilele n;int pos = 0;int rcvLe n = 0;while (rcvLe n = in. re

35、ad(filebytes, pos, filele n - pos) > 0) pos += rcvLe n;Log.v(androidService.TAG , Thread.currentThread().getName() + "->" + "read file OK:file size=" + filebytes.le ngth);out.write("read file ok".getBytes("utf-8"); out.flush(); catch (Excepti on e) Log.v

36、(androidService.TAG , Thread.currentThread().getName()+ "->" + "receiveFileFromSocket error");e.pri ntStackTrace();retur n filebytes;socket的最重要的機(jī)制就是讀寫采用的是阻塞的方式，如果客戶端作為命令發(fā)起者，服 務(wù)器端作為接收者的話，只有當(dāng)客戶端 client用out.writer()寫到輸出流里后，即流中有數(shù)據(jù) service的read才會(huì)執(zhí)行，不然就會(huì)一直停在read()那里等數(shù)據(jù)。9還要讓服務(wù)器端可以同時(shí)連

37、接多個(gè)client，即服務(wù)器端用new thread()來(lái)作數(shù)據(jù)讀取操作。源碼：客戶端(pc端)：testPcClie nt.javaview pla in copy to clipboardpri nt?import java.io.Bufferedl nputStream;import java.io.BufferedOutputStream;import java.io.BufferedReader;import java.io.ByteArrayOutputStream;import java.i o.I OExcepti on;import java.i o.ln putStream

38、;import java.i o.ln putStreamReader;import java .n et.I netAddress;import java .n et.Socket;import java. net.U nknownH ostExceptio n;public class testPcClie nt * param args* throws In terruptedExcepti on*/public static void main( Stri ng args) throws In terruptedExceptio n try Run time.getR un time(

39、).exec("adb shell am broadcast -a NotifyServiceStop");Thread.sleep(3000);Run time.getR un time().exec("adb forward tcp:12580 tcp:10086");Thread.sleep(3000);Run time.getR un time().exec("adb shell am broadcast -a NotifyServiceStart");Thread.sleep(3000); catch (IOExceptio

40、n e3) e3.pri ntStackTrace();Socket socket = nu II;try In etAddress serverAddr = n ull; serverAddr = In etAddress.getByName("127.0.0.1"); System.out.pri ntl n( "TCP 1111" + "C: Co nn ecti ng."); socket = new Socket(serverAddr, 12580);String str = "hi,wufe nglon g&qu

41、ot;System.out.pri ntl n( "TCP 221122" + "C:RECEIVE");BufferedOutputStream out = new BufferedOutputStream(socket .getOutputStream();BufferedI nputStream in = new BufferedI nputStream(socket.getI nputStream();BufferedReader br = new BufferedReader( new In putStreamReader(System.i n

42、);boolea n flag = true;while (flag) System.out.print("請(qǐng)輸入16的數(shù)字，退出輸入exit:"); Stri ng strWord = br.readL in e(); 從控制臺(tái)輸入 16 if (strWord.equals("1") out.write("1".getBytes();out.flush();System.out.pri ntln ("1 finish sending the data"); Stri ng strFormsocket = rea

43、dFromSocket(i n); System.out.pri ntln ("the data sent by server is:r n"+ strFormsocket);System.out.pri ntln (”= "); else if (strWord.equals("2") out.write("2".getBytes();out.flush();System.out.pri ntln ("2 finish sending the data"); Stri ng strFormsocket

44、= readFromSocket(i n); System.out.pri ntln ("the data sent by server is:r n"+ strFormsocket);System.out.pri ntln (”= "); else if (strWord.equals("3") out.write("3".getBytes();out.flush();System.out.pri ntln ("3 finish sending the data"); Stri ng strFormso

45、cket = readFromSocket(i n); System.out.pri ntln ("the data sent by server is:r n"+ strFormsocket);System.out.pri ntln (”= =")； else if (strWord.equals("4") /*發(fā)送命令*/out.write("4".getBytes();out.flush();System.out.println("send file finish sending the CMD :"

46、;);/*服務(wù)器反饋：準(zhǔn)備接收*/Stri ng strFormsocket = readFromSocket(i n);System.out.println("service ready receice data:UPDA TE_CONTACTS:"+ strFormsocket);byte filebytes = FileHelper.readFileCR0013340.JPG");System.out.pri ntl n("file size=" + filebytes .len gth);/*將整數(shù)轉(zhuǎn)成4字節(jié)byte數(shù)組*/byte f

47、ilele ngth = new byte4;filele ngth = tools.i ntToByte(filebytes.le ngth);/*將.apk字符串轉(zhuǎn)成4字節(jié)byte數(shù)組*/byte fileformat = nu II; fileformat = ".apk".getBytes();System.out.pri ntln ("fileformat len gth=" + fileformat.le ngth);/*字節(jié)流中前4字節(jié)為文件長(zhǎng)度，4字節(jié)文件格式，以后是文件流*/ /*注意如果write里的byte超過(guò)socket的緩存，系

48、統(tǒng)自動(dòng)分包寫過(guò) 去，所以對(duì)方要循環(huán)寫完*/out.write(filele ngth);out.flush();Stri ng strok1 = readFromSocket(i n);System.out.pri ntl n("service receive filele ngth :" + strok1);/ out.write(fileformat);/ out.flush();/ String strok2 = readFromSocket(i n);/ System.out.pri ntl n("service receive fileformat :&

49、quot; +/ strok2);System.out.pri ntln ("write data to an droid");out.write(filebytes);out.flush();System.out.pri ntln("*");/*服務(wù)器反饋：接收成功*/String strread = readFromSocket(i n);System.out.pri ntln (” send data success:" + strread);System.out.printin (”); else if (strWord.equalsI

50、g no reCase("EXIT") out.write("EXIT".getBytes();out.flush();System.out.pri ntln ("EXIT finish sending the data");Stri ng strFormsocket = readFromSocket(i n); System.out.pri ntln ("the data sent by server is:r n" + strFormsocket);flag = false;System.out.pri ntl

51、n("=： ="); catch (UnknownH ostExcepti on e1) System.out.pri ntln ("TCP 331133" + "ERROR:" + e1.toStri ng(); catch (Excepti on e2) System.out.pri ntln( "TCP 441144" + "ERROR:" + e2.toStri ng(); fin ally try if (socket != n ull) socket.close(); System.

52、out.pri ntln ("socket.close()"); catch (IOExceptio n e) System.out.pri ntln( "TCP 5555" + "ERROR:" + e.toStri ng();/*從InputStream流中讀數(shù)據(jù) */public static String readFromSocket(I nputStream in) int MAX_BUFFER_BYTES = 4000;Stri ng msg =""byte tempbuffer = new byteM

53、AX_BUFFER_BYTES;try int nu mReadedBytes = in. read(tempbuffer, 0, tempbufferen gth); msg = new Strin g(tempbuffer, 0, nu mReadedBytes, "utf-8");tempbuffer = nu II; catch (Excepti on e) e.pri ntStackTrace();/ Log.v(Service139.TAG , "msg=" + msg); return msg;import java.io.Buffered

54、l nputStream;import java.io.BufferedOutputStream;import java.io.BufferedReader;import java.io.ByteArrayOutputStream;import java.i o.I OExcepti on;import java.i o.ln putStream;import java.i o.ln putStreamReader;import java .n et.I netAddress;import java .n et.Socket;import java. net.U nknownH ostExce

55、ptio n;public class testPcClie nt /* param args* throws In terruptedExcepti on*/public static void main( Stri ng args) throws In terruptedExceptio n try Run time.getR un time().exec("adb shell am broadcast -a NotifyServiceStop");Thread.sleep(3000);Run time.getRu ntime().exec("adb forw

56、ard tcp:12580 tcp:10086"); Thread.sleep(3000);Run time.getR un time().exec("adb shell am broadcast -a NotifyServiceStart"); Thread.sleep(3000); catch (IOException e3) e3.pri ntStackTrace();Socket socket = n ull;try In etAddress serverAddr = n ull;serverAddr = In etAddress.getByName(&q

57、uot;127.0.0.1");System.out.pri ntl n( "TCP 1111" + "C: Co nn ecti ng.");socket = new Socket(serverAddr, 12580);String str = "hi,wufe nglon g"System.out.pri ntl n( "TCP 221122" + "C:RECEIVE");BufferedOutputStream out = new BufferedOutputStream(so

58、cket .getOutputStream();Bufferedl nputStream in = new BufferedI nputStream(socket.getI nputStream();BufferedReader br = new BufferedReader( new In putStreamReader( System.i n);boolea n flag = true;while (flag) System.out.print(”請(qǐng)輸入16的數(shù)字，退出輸入exit:");Stri ng strWord = br.readL in e(); 從控制臺(tái)輸入 16if

59、 (strWord.equals("1") out.write("1".getBytes();out.flush();System.out.pri ntln ("1 finish sending the data");Stri ng strFormsocket = readFromSocket(i n);System.out.pri ntln ("the data sent by server is:r n"+ strFormsocket);System.out.println( "=")； else if (strWord.equals("2") out.write("2".getBytes();out.flush();System.out.pri ntln ("2 finish sending the data");Stri ng strFormsocket = readFromSocket(i n);System.out.pri ntln ("the