Android通过Socket(TCP/IP)与PC通讯

这个简单的例子将演示应用Java实现客户端与服务器端传输文件的方法。

服务器端源代码：

01.import
java.net.*;

02.import
java.io.*;

03.

04.public
class
FileServer {

05.
public
static void
main (String [] args ) throws IOException {

06. // create socket

07.
ServerSocket servsock = new
ServerSocket(13267);

08.
while
(true) {

09. System.out.println("Waiting...");

10.

11. Socket sock = servsock.accept();

12.
System.out.println("Accepted connection : "
+ sock);

13.

14. // sendfile

15.
File myFile = new
File ("source.pdf");

16.
byte [] mybytearray = new
byte [(int)myFile.length()];

17.
FileInputStream fis = new
FileInputStream(myFile);

18.
BufferedInputStream bis = new
BufferedInputStream(fis);

19. bis.read(mybytearray,0,mybytearray.length);

20. OutputStream os = sock.getOutputStream();

21. System.out.println("Sending...");

22. os.write(mybytearray,0,mybytearray.length);

23. os.flush();

24. sock.close();

25. }

26. }

27.}

客户端源代码：

01.import
java.net.*;

02.import
java.io.*;

03.

04.public
class
FileClient{

05.
public
static void
main (String [] args ) throws IOException {

06.
int filesize=6022386; // filesize temporary hardcoded

07.

08.
long start = System.currentTimeMillis();

09.
int bytesRead;

10.
int current = 0;

11. // localhost for testing

12.
Socket sock = new
Socket("127.0.0.1",13267);

13. System.out.println("Connecting...");

14.

15. // receive file

16.
byte [] mybytearray = new
byte [filesize];

17. InputStream is = sock.getInputStream();

18.
FileOutputStream fos = new
FileOutputStream("source-copy.pdf");

19.
BufferedOutputStream bos = new
BufferedOutputStream(fos);

20. bytesRead = is.read(mybytearray,0,mybytearray.length);

21. current = bytesRead;

22.

23. // thanks to A. Cádiz for the bug fix

24.
do {

25. bytesRead =

26. is.read(mybytearray, current, (mybytearray.length-current));

27. if(bytesRead >= 0) current += bytesRead;

28. } while(bytesRead > -1);

29.

30.
bos.write(mybytearray, 0
, current);

31. bos.flush();

32.
long end = System.currentTimeMillis();

33. System.out.println(end-start);

34. bos.close();

35. sock.close();

36. }

37.}