Java写的支持断点续传的FTP

http://crybaby2005.bokee.com/3148701.html

 

public class FileInfo {
	
	public String name;
	public String description;

	public FileInfo(String nm, String dscrp) {
		name = nm;
		description = dscrp;
	}
}

 

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.InterruptedIOException;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.StringTokenizer;
import java.util.Vector;

public class FTPSearch extends Thread {
	String _host;
	static final int PORT = 21;
	ServerSocket ss;
	Socket _ds;
	Socket _sc;
	PrintStream _out;
	String _hostAddress;
	BufferedReader _in;
	BufferedReader _dataIn;
	String _reply;
	protected StringBuffer _log = new StringBuffer(10000);
	Vector _result;
	String _user;
	String _pass;

	public FTPSearch(String ip, String user, String pass) {
		_host = ip;
		_user = user;
		_pass = pass;
		_result = new Vector();
	}

	public FTPSearch(String ip) {
		_host = ip;
		_user = "anonymous";
		_pass = "[e-mail]";
		_result = new Vector();
	}

	protected boolean login() throws UnknownHostException, IOException {
		boolean successful = false;
		StringBuffer reply = new StringBuffer();
		_sc = new Socket(_host, PORT);
		_hostAddress = _sc.getLocalAddress().getHostAddress().replace('.', ',');
		_sc.setSoTimeout(15000);
		_out = new PrintStream(_sc.getOutputStream(), true);
		_in = new BufferedReader(new InputStreamReader(_sc.getInputStream()));
		reply.append(readReply().trim());
		if (reply.toString().startsWith("220"))
			if (comm("USER " + _user))
				if (comm("PASS " + _pass))
					successful = true;
		comm("TYPE A");
		return successful;
	}

	protected String getCurrentDir() throws IOException {
		String currentDir = null;
		if (comm("PWD")) {
			StringTokenizer st = new StringTokenizer(_reply);
			st.nextToken();
			StringBuffer rtDir = new StringBuffer(st.nextToken());
			currentDir = rtDir.substring(1, rtDir.length() - 1);
		}
		return currentDir;
	}

	public void search() throws IOException, InterruptedException {
		try {
			for (int i = 0; i < 5; i++) {
				if (login())
					break;
				System.out.println("Wait 10 seconds to try again...");
				sleep(10000);
			}
			scan();
			logout();
		} catch (IOException ex) {

		} finally {
			PrintStream out = new PrintStream(new FileOutputStream("Log.txt"));
			out.println(_log);
			out.close();
			printResult("result.txt");
		}

	}

	protected void scan() throws IOException {
		Vector fileNames = new Vector();
		tellPort();
		comm("LIST -R");

		// Get data_connection's InputStream.
		try {
			_ds = ss.accept();
			System.out.println(ss.toString());
		} catch (IOException ex) {
			ss.close();
		}
		_dataIn = new BufferedReader(
				new InputStreamReader(_ds.getInputStream()));

		System.out.println("Scanning now.Please waiting......");
		// Read directory content
		try {
			String temp = "";
			do {
				temp = _dataIn.readLine();
				if (temp == null)
					break;
				fileNames.add(temp);

			} while (temp != null);
		} catch (InterruptedIOException ex) {
			System.out.println("Caught InterruptedIOException1:" + ex);
		}

		// Read end infomation
		try {
			do {
				String temp = _in.readLine();
				_log.append(temp + "r");
				System.out.println(temp);
			} while (_in.ready());
		} catch (InterruptedIOException ex) {
			System.out.println("Caught InterruptedIOException2:" + ex);
		}
		_result = fileNames;
	}

	public Vector getResult() {
		return _result;
	}

	public StringBuffer getLog() {
		return _log;
	}

	public static Vector parse() throws FileNotFoundException, IOException {
		Vector result = new Vector();
		FileInputStream fileIn = new FileInputStream("result.txt");
		BufferedReader fReader = new BufferedReader(new InputStreamReader(
				fileIn));
		// int size=fileIn.available();
		// System.out.println(String.valueOf(size));
		String dir = "/";
		System.out.println("Parsing now.Please wait......");
		while (fReader.ready()) {
			String temp = fReader.readLine();
			StringTokenizer tt = new StringTokenizer(temp);

			if (tt.countTokens() == 1) {
				if (temp.startsWith("/"))
					dir = temp.replace(':', ' ').trim() + "/";
				else
					dir = "/" + temp.replace(':', ' ').trim() + "/"; // parseResult
																		// .add(
																		// dir);
																		// continue
																		// ;
			}
			if ((!temp.equals(""))
					&& (temp.startsWith("-") || temp.startsWith("b")
							|| temp.startsWith("c") || temp.startsWith("l"))) {
				for (int i = 0; i < 4; i++)
					tt.nextToken();
				String description = "";
				for (int i = 0; i < 4; i++)
					description = description + tt.nextToken() + " ";
				String cont = "";
				do {
					cont = cont + tt.nextToken() + " ";
				} while (tt.hasMoreTokens());
				result.add(new FileInfo(dir + cont.trim(), description.trim()));
				continue;
			} else if (temp.startsWith("d")) {
				for (int i = 0; i < 4; i++)
					tt.nextToken();
				String description = "";
				for (int i = 0; i < 4; i++)
					description = description + tt.nextToken() + " ";
				String cont = "";
				do {
					cont = cont + tt.nextToken() + " ";
				} while (tt.hasMoreTokens());
				result.add(new FileInfo(dir + cont.trim() + "/", description
						.trim()));
				continue;
			} else if (temp.equals("")) {
				continue;
			}
		}
		return result;
	}

	protected void logout() throws IOException {
		comm("QUIT");
	}

	protected void printResult(String resultFile) throws IOException {
		PrintStream out = new PrintStream(new FileOutputStream(resultFile));
		int len = _result.size();
		for (int i = 0; i < len; i++) {
			out.println(_result.elementAt(i));
		}
		out.close();
	}

	protected boolean comm(String command) throws IOException {
		boolean success = false;
		_out.println(command);
		System.out.println("<COMMAND>" + command);
		_log.append("<COMMAND>" + command + "r");
		_reply = readReply();
		if (command.startsWith("USER")) {
			success = _reply.startsWith("331") ? true : false;
		} else if (command.startsWith("PASS")) {
			success = _reply.startsWith("230") ? true : false;
			try {
				readReply();
			} catch (InterruptedIOException ex) {
			}
		} else if (command.equals("TYPE A")) {
			success = _reply.startsWith("200") ? true : false;
		} else if (command.startsWith("PORT")) {
			success = _reply.startsWith("200") ? true : false;
		} else if (command.startsWith("LIST")) {
			success = _reply.startsWith("150") ? true : false;
		} else if (command.startsWith("NLST")) {
			success = _reply.startsWith("150") ? true : false;
		} else if (command.equals("PWD")) {
			success = _reply.startsWith("257") ? true : false;
		} else if (command.startsWith("STAT")) {
			success = _reply.startsWith("211") ? true : false;
		} else if (command.equals("SYST")) {
			success = _reply.startsWith("215") ? true : false;
		} else if (command.startsWith("SITE")) {
			success = _reply.startsWith("214") ? true : false;
		} else if (command.equals("QUIT")) {
			success = _reply.startsWith("221") ? true : false;
		}
		return success;
	}

	public static void printVector(Vector vct) {
		int size = vct.size();
		for (int i = 0; i < size; i++) {
			System.out.println(vct.elementAt(i));
		}
	}

	protected String readReply() throws IOException, InterruptedIOException {
		StringBuffer reply = new StringBuffer();
		do {
			reply.append(_in.readLine() + "r");
		} while (_in.ready());
		System.out.println(reply);
		_log.append(reply);
		_reply = reply.toString();
		return _reply;
	}

	private int getDataPort() {
		int port = _sc.getLocalPort() + 1;
		return port;
	}

	private void tellPort() throws IOException {

		try {
			int port = getDataPort();
			System.out.println("Get data port:" + port);
			int x = (int) Math.round((port / 256) - 0.5);
			int y = port - x * 256;
			try {
				ss = new ServerSocket(port);
			} catch (IOException ex) {
				System.out
						.println("IOException in Method tellPort() in Class ftpc--"
								+ ex);
			}
			comm("PORT " + _hostAddress + "," + x + "," + y);
		} finally {

		}
	}

	public static void main(String arg[]) {
		try {
			FTPSearch client = new FTPSearch("202.114.2.2");
			client.search();
			client.parse();
		} catch (Exception ex) {
			System.out.println(ex);
		}
	}

}

 

public class demo {
	public static void main(String arg[]) {
		try {
			FTPSearch client = new FTPSearch("192.168.0.1");
			client.search();
			java.util.Vector temp = client.parse();
			int size = temp.size();
			for (int i = 0; i < size; i++) {
				FileInfo ttt = ((FileInfo) temp.elementAt(i));
				System.out.println(ttt.name + " " + ttt.description);
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
	}
}

 

评论

1 楼 a_lee 2012-12-06  

lz有完整的Demo吗？