javaboys

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

讀者范圍:

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

正文:

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

圖1:

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

?

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

?

圖2:

?

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

?

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

?

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

?

3. ????????本地文件讀/寫器

?

?

?

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

?

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

?

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

?

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

?

?

?

?

?

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

?

import java.io.*;

?

import java.net.*;

?

?

?

public class FileServer{

?

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

?

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

?

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

?

????????????? FileInputStream fos=new FileInputStream(file);

?

?????????????

?

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

?

????????????? 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ù)寫出網(wǎng)絡(luò)緩沖區(qū)

?

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

?

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

?

???????? ?????}

?

????????????? fos.close();

?

????????????? doc.close();

?

?????? }

?

}

?

?

?

客戶方實現(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");

?

?????????????

?

????????????? // 通過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ù)寫往文件

?

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

?

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

?

????????????? }

?

????????????? in.close();

?

????????????? raf.close();

?

?????? }

?

}

歸結(jié)以上代碼:

?

總結(jié):

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

?

Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=283322