用于Java中文件传输的FTP客户端服务器模型

上述问题的答案是：

FTP客户端：

import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.net.Socket;public class FileClient {    public static void main(String[] args) throws Exception {        long start = System.currentTimeMillis();        // localhost for testing        Socket sock = new Socket("127.0.0.1", 13267);        System.out.println("Connecting...");        InputStream is = sock.getInputStream();        // receive file        new FileClient().receiveFile(is);        OutputStream os = sock.getOutputStream();        //new FileClient().send(os);        long end = System.currentTimeMillis();        System.out.println(end - start);        sock.close();    }    public void send(OutputStream os) throws Exception {        // sendfile        File myFile = new File("/home/nilesh/opt/eclipse/about.html");        byte[] mybytearray = new byte[(int) myFile.length() + 1];        FileInputStream fis = new FileInputStream(myFile);        BufferedInputStream bis = new BufferedInputStream(fis);        bis.read(mybytearray, 0, mybytearray.length);        System.out.println("Sending...");        os.write(mybytearray, 0, mybytearray.length);        os.flush();    }    public void receiveFile(InputStream is) throws Exception {        int filesize = 6022386;        int bytesRead;        int current = 0;        byte[] mybytearray = new byte[filesize];        FileOutputStream fos = new FileOutputStream("def");        BufferedOutputStream bos = new BufferedOutputStream(fos);        bytesRead = is.read(mybytearray, 0, mybytearray.length);        current = bytesRead;        do { bytesRead = is.read(mybytearray, current,         (mybytearray.length - current)); if (bytesRead >= 0)     current += bytesRead;        } while (bytesRead > -1);        bos.write(mybytearray, 0, current);        bos.flush();        bos.close();    }}

FTP服务器：

import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;public class FileServer {    public static void main(String[] args) throws Exception {        // create socket        ServerSocket servsock = new ServerSocket(13267);        while (true) { System.out.println("Waiting..."); Socket sock = servsock.accept(); System.out.println("Accepted connection : " + sock); OutputStream os = sock.getOutputStream(); //new FileServer().send(os); InputStream is = sock.getInputStream(); new FileServer().receiveFile(is); sock.close();        }    }    public void send(OutputStream os) throws Exception {        // sendfile        File myFile = new File("/home/nilesh/opt/eclipse/about.html");        byte[] mybytearray = new byte[(int) myFile.length() + 1];        FileInputStream fis = new FileInputStream(myFile);        BufferedInputStream bis = new BufferedInputStream(fis);        bis.read(mybytearray, 0, mybytearray.length);        System.out.println("Sending...");        os.write(mybytearray, 0, mybytearray.length);        os.flush();    }    public void receiveFile(InputStream is) throws Exception {        int filesize = 6022386;        int bytesRead;        int current = 0;        byte[] mybytearray = new byte[filesize];        FileOutputStream fos = new FileOutputStream("def");        BufferedOutputStream bos = new BufferedOutputStream(fos);        bytesRead = is.read(mybytearray, 0, mybytearray.length);        current = bytesRead;        do { bytesRead = is.read(mybytearray, current,         (mybytearray.length - current)); if (bytesRead >= 0)     current += bytesRead;        } while (bytesRead > -1);        bos.write(mybytearray, 0, current);        bos.flush();        bos.close();    }}