Java 网络文件传输

关键字: Java [/b]何双江 IO NET File[/b]

读者范围:[/b]
本文是一篇简短入门文章.本文假设读者对Java的IO系统和Java的网络系统有所了解.

正文:[/b]
关于文件传输的问题,实际也是一种IO读写的基本问题.对于网络而言也是一种IO读写问题.因此所谓网络的文件传输实际是两种IO问题的综合讨论.这里我们首先分析一个图示.然后围绕这个图示来讨论:





图1[/b]:
分析图1我们基本可以知道从服务器文件系统中通过流把文件中的数据写入到服务器的进程中,然后把进程中的数据通过网络IO系统传递到客户机,这个阶段,网络中的数据以字节流的形式保存.当该字节流被客户进程接受后,客户进程通过客户本地文件流写入客户本地的文件系统中.

根据以上分析,我们基本可以确定我所需要处理的问题了.首先我们需要可以对本地文件系统IO操作的操作接口,然后是一个可以对网络IO系统进行操作的操作接口,已经一个可以把数据包装成字节流的操作接口,他们分别可以提供客户和服务器两个进程进行读写的操作.如下图所示:



图2:[/b]
根据以上分析,我们可以把问题归结到对以下编程接口的需求上:
1. 字节包装器和字节解包器,
2. 网络传输器和网络接收器
3. 本地文件读/写器

而这些Java本身的API就已经提供.他们都被包装到java.io和java.net这两个包里,这里我提供一个基于TCP/IP的实现版本,使用基于连接的方式来完成工作.我们首先介绍几个相关的JDK中的类来完成以上任务,
1. DataOutputStream和DataInputStream实现类提供了上面的字节包装和解包器的实现
2. ServerSocket和Socekt提供了基于连接的网络传输和接受接口
3. File,FileInputStream和FileOutputStream提供了基本的本地文件输入输出接口.

服务器端实现代码:[/b]
import java.io.*;[/b]
import java.net.*;[/b]
[/b]
public class FileServer{[/b]
public static void main(String[] args)throws Exception{[/b]
//[/b]创建文件流用来读取文件中的数据[/b]
File file=new File("lishengjie.jpg");[/b]
FileInputStream fos=new FileInputStream(file);[/b]
[/b]
//[/b]创建网络服务器接受客户请求[/b]
ServerSocket ss=new ServerSocket(3108);[/b]
Socket client=ss.accept();[/b]
[/b]
//[/b]创建网络输出流并提供数据包装器[/b]
OutputStream netOut=client.getOutputStream();[/b]
OutputStream doc=new DataOutputStream(new BufferedOutputStream(netOut));[/b]
[/b]
//[/b]创建文件读取缓冲区[/b]
byte[] buf=new byte[2048];[/b]
int num=fos.read(buf);[/b]
while(num!=(-1)){//[/b]是否读完文件[/b]
doc.write(buf,0,num);//[/b]把文件数据写出网络缓冲区[/b]
doc.flush();//[/b]刷新缓冲区把数据写往客户端[/b]
num=fos.read(buf);//[/b]继续从文件中读取数据[/b]
}[/b]
fos.close();[/b]
doc.close();[/b]
}[/b]
}[/b]
[/b]
客户方实现代码:[/b]
import java.io.*;[/b]
import java.net.*;[/b]
[/b]
public class FileClient{[/b]
public static void main(String[] args)throws Exception{[/b]
//[/b]使用本地文件系统接受网络数据并存为新文件[/b]
File file=new File("newFile.jpg");[/b]
file.createNewFile();[/b]
RandomAccessFile raf=new RandomAccessFile(file,"rw");[/b]
[/b]
// [/b]通过Socket[/b]连接文件服务器[/b]
Socket server=new Socket(InetAddress.getLocalHost(),3108);[/b]
[/b]
//[/b]创建网络接受流接受服务器文件数据 [/b]
InputStream netIn=server.getInputStream();[/b]
InputStream in=new DataInputStream(new BufferedInputStream(netIn));[/b]
[/b]
//[/b]创建缓冲区缓冲网络数据[/b]
byte[] buf=new byte[2048];[/b]
int num=in.read(buf);[/b]
[/b]
while(num!=(-1)){//[/b]是否读完所有数据[/b]
raf.write(buf,0,num);//[/b]将数据写往文件[/b]
raf.skipBytes(num);//[/b]顺序写文件字节[/b]
num=in.read(buf);//[/b]继续从网络中读取文件[/b]
}[/b]
in.close();[/b]
raf.close();[/b]
}[/b]
}[/b]