Java 網(wǎng)絡(luò)文件傳輸

作者: 何雙江

關(guān)鍵字: Java  何雙江  IO  NET  File

讀者范圍:

本文是一篇簡(jiǎn)短入門(mén)文章.本文假設(shè)讀者對(duì)Java的IO系統(tǒng)和Java的網(wǎng)絡(luò)系統(tǒng)有所了解.

正文:

關(guān)于文件傳輸?shù)膯?wèn)題,實(shí)際也是一種IO讀寫(xiě)的基本問(wèn)題.對(duì)于網(wǎng)絡(luò)而言也是一種IO讀寫(xiě)問(wèn)題.因此所謂網(wǎng)絡(luò)的文件傳輸實(shí)際是兩種IO問(wèn)題的綜合討論.這里我們首先分析一個(gè)圖示.然后圍繞這個(gè)圖示來(lái)討論:

圖1:

分析圖1我們基本可以知道從服務(wù)器文件系統(tǒng)中通過(guò)流把文件中的數(shù)據(jù)寫(xiě)入到服務(wù)器的進(jìn)程中,然后把進(jìn)程中的數(shù)據(jù)通過(guò)網(wǎng)絡(luò)IO系統(tǒng)傳遞到客戶(hù)機(jī),這個(gè)階段,網(wǎng)絡(luò)中的數(shù)據(jù)以字節(jié)流的形式保存.當(dāng)該字節(jié)流被客戶(hù)進(jìn)程接受后,客戶(hù)進(jìn)程通過(guò)客戶(hù)本地文件流寫(xiě)入客戶(hù)本地的文件系統(tǒng)中.

根據(jù)以上分析,我們基本可以確定我所需要處理的問(wèn)題了.首先我們需要可以對(duì)本地文件系統(tǒng)IO操作的操作接口,然后是一個(gè)可以對(duì)網(wǎng)絡(luò)IO系統(tǒng)進(jìn)行操作的操作接口,已經(jīng)一個(gè)可以把數(shù)據(jù)包裝成字節(jié)流的操作接口,他們分別可以提供客戶(hù)和服務(wù)器兩個(gè)進(jìn)程進(jìn)行讀寫(xiě)的操作.如下圖所示:

圖2:

根據(jù)以上分析,我們可以把問(wèn)題歸結(jié)到對(duì)以下編程接口的需求上:

1.         字節(jié)包裝器和字節(jié)解包器,

2.         網(wǎng)絡(luò)傳輸器和網(wǎng)絡(luò)接收器

3.         本地文件讀/寫(xiě)器

而這些Java本身的API就已經(jīng)提供.他們都被包裝到java.io和java.net這兩個(gè)包里,這里我提供一個(gè)基于TCP/IP的實(shí)現(xiàn)版本,使用基于連接的方式來(lái)完成工作.我們首先介紹幾個(gè)相關(guān)的JDK中的類(lèi)來(lái)完成以上任務(wù),

1.       DataOutputStream和DataInputStream實(shí)現(xiàn)類(lèi)提供了上面的字節(jié)包裝和解包器的實(shí)現(xiàn)

2.       ServerSocket和Socekt提供了基于連接的網(wǎng)絡(luò)傳輸和接受接口

3.       File,FileInputStream和FileOutputStream提供了基本的本地文件輸入輸出接口.

服務(wù)器端實(shí)現(xiàn)代碼:

import java.io.*;

import java.net.*;

public class FileServer{

       public static void main(String[] args)throws Exception{

              //創(chuàng)建文件流用來(lái)讀取文件中的數(shù)據(jù)

              File file=new File("lishengjie.jpg");

              FileInputStream fos=new FileInputStream(file);

              //創(chuàng)建網(wǎng)絡(luò)服務(wù)器接受客戶(hù)請(qǐng)求

              ServerSocket ss=new ServerSocket(3108);

              Socket client=ss.accept();

              //創(chuàng)建網(wǎng)絡(luò)輸出流并提供數(shù)據(jù)包裝器

              OutputStream netOut=client.getOutputStream();

              OutputStream doc=new DataOutputStream(new BufferedOutputStream(netOut));

              //創(chuàng)建文件讀取緩沖區(qū)

              byte[] buf=new byte[2048];

              int num=fos.read(buf);

              while(num!=(-1)){//是否讀完文件

                     doc.write(buf,0,num);//把文件數(shù)據(jù)寫(xiě)出網(wǎng)絡(luò)緩沖區(qū)

                     doc.flush();//刷新緩沖區(qū)把數(shù)據(jù)寫(xiě)往客戶(hù)端

                     num=fos.read(buf);//繼續(xù)從文件中讀取數(shù)據(jù)

              }

              fos.close();

              doc.close();

       }

}

客戶(hù)方實(shí)現(xiàn)代碼:

import java.io.*;

import java.net.*;

public class FileClient{

       public static void main(String[] args)throws Exception{

              //使用本地文件系統(tǒng)接受網(wǎng)絡(luò)數(shù)據(jù)并存為新文件

              File file=new File("newFile.jpg");

              file.createNewFile();

              RandomAccessFile raf=new RandomAccessFile(file,"rw");

              // 通過(guò)Socket連接文件服務(wù)器

              Socket server=new Socket(InetAddress.getLocalHost(),3108);

              //創(chuàng)建網(wǎng)絡(luò)接受流接受服務(wù)器文件數(shù)據(jù)

              InputStream netIn=server.getInputStream();

              InputStream in=new DataInputStream(new BufferedInputStream(netIn));

              //創(chuàng)建緩沖區(qū)緩沖網(wǎng)絡(luò)數(shù)據(jù)

              byte[] buf=new byte[2048];

              int num=in.read(buf);

              while(num!=(-1)){//是否讀完所有數(shù)據(jù)

                     raf.write(buf,0,num);//將數(shù)據(jù)寫(xiě)往文件

                     raf.skipBytes(num);//順序?qū)懳募止?jié)

                     num=in.read(buf);//繼續(xù)從網(wǎng)絡(luò)中讀取文件

              }

              in.close();

              raf.close();

       }

}

歸結(jié)以上代碼:

總結(jié):

       事實(shí)上java的開(kāi)發(fā)環(huán)境為我們提供大多數(shù)的編程接口,為我們簡(jiǎn)化了開(kāi)發(fā)工作量.我們通過(guò)java的IO接口所提供的文件,數(shù)據(jù)包裝器等接口非常方便的解決了我們上面的開(kāi)發(fā)工作量.同時(shí)在java的net接口所提供的套接字也使得基于連接的數(shù)據(jù)接受和發(fā)送成為非常容易的工作.