Ftp传输

package com.zy.ftp;

import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.util.ArrayList;
import java.util.StringTokenizer;

import sun.net.TelnetInputStream;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;

public class FTPConnectorBK {
private FtpClient ftpclient;
private String ipAddress;
private int ipPort;
private String userName;
private String PassWord;
   
public  FTPConnectorBK(){};
/** */
/**
* 构造函数
*
* @param ip
*            String 机器IP
* @param port
*            String 机器FTP端口号
* @param username
*            String FTP用户名
* @param password
*            String FTP密码
* @throws Exception
*/
public  FTPConnectorBK(String ip, int port, String username,
String password) throws Exception {

ipAddress = new String(ip);
ipPort = port;
// System.out.println("1......"+ftpclient.serverIsOpen());
ftpclient = new FtpClient(ipAddress, ipPort);
// ftpclient = new FtpClient();
System.out.println("2......" + ftpclient.serverIsOpen());
// ftpclient = new FtpClient(ipAddress);
userName = new String(username);
PassWord = new String(password);
}

/** */
/**
* 构造函数
*
* @param ip
*            String 机器IP，默认端口为21
* @param username
*            String FTP用户名
* @param password
*            String FTP密码
* @throws Exception
*/
public FTPConnectorBK(String ip, String username, String password)
throws Exception {
ipAddress = new String(ip);
ipPort = 21;
ftpclient = new FtpClient(ipAddress, ipPort);
// ftpclient = new FtpClient(ipAddress);
userName = new String(username);
PassWord = new String(password);
}

/** */
/**
* 登录FTP服务器
*
* @throws Exception
*/
public void login() throws Exception {
System.out.println("b......" + ftpclient.welcomeMsg);
System.out.println(userName);
System.out.println(PassWord);
ftpclient.login(userName, PassWord);
ftpclient.setConnectTimeout(30);
System.out.println("getReadTimeout..." + ftpclient.getReadTimeout());
System.out.println("getConnectTimeout..."
+ ftpclient.getConnectTimeout());
System.out.println("e......" + ftpclient.welcomeMsg);
}

/** */
/**
* 退出FTP服务器
*
* @throws Exception
*/
public void logout() throws Exception {
// 用ftpclient.closeServer()断开FTP出错时用下更语句退出
System.out.println("10......" + ftpclient.serverIsOpen());
ftpclient.sendServer("QUIT");
int reply = ftpclient.readServerResponse(); // 取得服务器的返回信息
System.out.println("reply...." + reply);
System.out.println("11......" + ftpclient.serverIsOpen());
ftpclient.closeServer();
System.out.println("12......" + ftpclient.serverIsOpen());

}

/** */
/**
* 在FTP服务器上建立指定的目录,当目录已经存在的情下不会影响目录下的文件,这样用以判断FTP
* 上传文件时保证目录的存在目录格式必须以"/"根目录开头
*
* @param pathList
*            String
* @throws Exception
*/
public void buildList(String pathList) throws Exception {
ftpclient.ascii();
StringTokenizer s = new StringTokenizer(pathList, "/"); // sign
int count = s.countTokens();
String pathName = "";
while (s.hasMoreElements()) {
pathName = pathName + "/" + (String) s.nextElement();
try {
ftpclient.sendServer("XMKD" + pathName + " ");
} catch (Exception e) {
e = null;
}
int reply = ftpclient.readServerResponse();
System.out.println(reply);
}
ftpclient.binary();
}

/** */
/**
* 取得指定目录下的所有文件名，不包括目录名称 分析nameList得到的输入流中的数，得到指定目录下的所有文件名
*
* @param fullPath
*            String
* @return ArrayList
* @throws Exception
*/
public ArrayList fileNames(String fullPath) throws Exception {
ftpclient.ascii(); // 注意，使用字符模式
ftpclient.cd("/freep");
// ftpclient.cdUp();
// TelnetInputStream list = ftpclient.nameList(fullPath);
TelnetInputStream list = ftpclient.list();

byte[] names = new byte[2048];
int bufsize = 0;
bufsize = list.read(names, 0, names.length); // 从流中读取
list.close();
ArrayList namesList = new ArrayList();
int i = 0;
int j = 0;
while (i < bufsize /**//* names.length */) {
// System.out.println(i);
// char bc = (char) names;
// System.out.println(i + " " + bc + " : " + (int) names);
// i = i + 1;
if (names[i] == 10) { // 字符模式为10，二进制模式为13
System.out.println("j...." + j);
// 文件名在数据中开始下标为j,i-j为文件名的长度,文件名在数据中的结束下标为i-1
// System.out.write(names, j, i - j);
// System.out.println(j + " " + i + " " + (i - j));
String tempName = new String(names, j, i - j);
namesList.add(tempName);
System.out.println(tempName);
// 处理代码处
// j = i + 2; // 上一次位置二进制模式
j = i + 1; // 上一次位置字符模式
}
i = i + 1;
}
return namesList;
}

/** */
/**
* 上传文件到FTP服务器,destination路径以FTP服务器的"/"开始，带文件名、
*  上传文件只能使用二进制模式，当文件存在时再次上传则会覆盖
*
* @param source
*            String
* @param destination
*            String
* @throws Exception
*/
public void upFile(String source, String destination) throws Exception {
System.out.println("ccccccccccccccccccccccc"+source);
buildList(destination.substring(0, destination.lastIndexOf("/")));
ftpclient.binary(); // 此行代码必须放在buildList之后  该命令可把传输格式设置为二进制格式。
TelnetOutputStream ftpOut = ftpclient.put(destination);
TelnetInputStream ftpIn = new TelnetInputStream(new FileInputStream(
source), true);
byte[] buf = new byte[204800];
int bufsize = 0;
while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) {
ftpOut.write(buf, 0, bufsize);
}
ftpIn.close();
ftpOut.close();

}

/** */
/**
* JSP中的流上传到FTP服务器, 上传文件只能使用二进制模式，当文件存在时再次上传则会覆盖 字节数组做为文件的输入流,此方法适用于JSP中通过
* request输入流来直接上传文件在RequestUpload类中调用了此方法， destination路径以FTP服务器的"/"开始，带文件名
*
* @param sourceData
*            byte[]
* @param destination
*            String
* @throws Exception
*/
public void upFile(byte[] sourceData, String destination) throws Exception {
buildList(destination.substring(0, destination.lastIndexOf(" / ")));
ftpclient.binary(); // 此行代码必须放在buildList之后 一定要使用二进制模式
TelnetOutputStream ftpOut = ftpclient.put(destination);  //以写方式打开一输出流，通过这一输出流把文件filename传送到远程计算机。
ftpOut.write(sourceData, 0, sourceData.length);
// ftpOut.flush();
ftpOut.close();
}

/** */
/**
* 从FTP文件服务器上下载文件SourceFileName，到本地destinationFileName 所有的文件名中都要求包括完整的路径名在内
*
* @param SourceFileName
*            String
* @param destinationFileName
*            String
* @throws Exception
*/
public void downFile(String SourceFileName, String destinationFileName)
throws Exception {
ftpclient.binary(); // 一定要使用二进制模式
TelnetInputStream ftpIn = ftpclient.get(SourceFileName);
byte[] buf = new byte[204800];
int bufsize = 0;
FileOutputStream ftpOut = new FileOutputStream(destinationFileName);
while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) {
ftpOut.write(buf, 0, bufsize);
}
ftpOut.close();
ftpIn.close();
}

/** */
/**
* 从FTP文件服务器上下载文件，输出到字节数组中
*
* @param SourceFileName
*            String
* @return byte[]
* @throws Exception
*/
public byte[] downFile(String SourceFileName) throws Exception {
ftpclient.binary(); // 一定要使用二进制模式
TelnetInputStream ftpIn = ftpclient.get(SourceFileName);
ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
byte[] buf = new byte[204800];
int bufsize = 0;

while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) {
byteOut.write(buf, 0, bufsize);
}
byte[] return_arraybyte = byteOut.toByteArray();
byteOut.close();
ftpIn.close();
return return_arraybyte;
}
/** */
/**
* 调用示例 FtpUpfile fUp = new FtpUpfile("192.150.189.22", 21, "admin",
* "admin"); fUp.login(); fUp.buildList("/adfadsg/sfsdfd/cc"); String
* destination = "/test.zip"; fUp.upFile("C:\Documents and
* Settings\Administrator\My Documents\sample.zip",destination); ArrayList
* filename = fUp.fileNames("/"); for (int i = 0; i < filename.size(); i++) {
* System.out.println(filename.get(i).toString()); } fUp.logout();
*
* @param args
*            String[]
* @throws Exception
*/
public static void main(String[] args) throws Exception {
// FTPConnectorBK fUp = new FTPConnectorBK( "192.168.1.230" , 21 ,
// "admin" , "sanco_freep" );
//Ftp端口号 一般都是21
FTPConnectorBK fUp = new FTPConnectorBK("10.113.58.113", 21, "zhu","zy");
System.out.println("fUp......" + fUp.ftpclient.serverIsOpen());
fUp.login();

System.out.println("login()......" + fUp.ftpclient.serverIsOpen());
// fUp.fileNames("/freep");
System.out.println("1......begin");
//上传到Ftp方法
fUp.upFile("D:/项目文档/阿布达日铁矿.doc", "/阿布达日铁矿.doc");//第一个参数文件的位置 ， 第2个参数文件上传后的名字
//在ftp上下载下来
//fUp.downFile("/阿布达日铁矿.doc", "D:/阿布达日铁矿.doc");

System.out.println("1......end");

String ss = fUp.ftpclient.pwd();//该命令可显示远程系统上的目录状态。
System.out.println("ss......" + ss);
System.out.println("option......" + fUp.ftpclient.serverIsOpen());
// fUp.deleteFile();
// 建立文件目录
// fUp.buildList("/adfadsg/sfsdfd/cc");

// String destination = "/test/SetupDJ.rar";
// fUp.upFile(
// "C:\Documents and Settings\Administrator\My Documents\SetupDJ.rar",
// destination);
// ArrayList filename = fUp.fileNames("/");
// for (int i = 0; i < filename.size(); i++) {
// System.out.println(filename.get(i).toString());
// }
//
// fUp.downFile("/sample.zip", "d:\sample.zip");

// 文件上传
// FileInputStream fin = new FileInputStream(
// "d://37.jpg" );
// byte [] data = new byte [ 20480000 ];
// fin.read(data, 0 , data.length);

fUp.logout();
System.out.println("fUp.logout()......" + fUp.ftpclient.serverIsOpen());
System.out.println(" 程序运行完成！ ");
/**//*
* FTP远程命令列表 USER PORT RETR ALLO DELE SITE XMKD CDUP FEAT PASS PASV
* STOR REST CWD STAT RMD XCUP OPTS ACCT TYPE APPE RNFR XCWD HELP
* XRMD STOU AUTH REIN STRU SMNT RNTO LIST NOOP PWD SIZE PBSZ QUIT
* MODE SYST ABOR NLST MKD XPWD MDTM PROT
*/
/**//*
* 在服务器上执行命令,如果用sendServer来执行远程命令(不能执行本地FTP命令)的话，所有FTP命令都要加上
* ftpclient.sendServer("XMKD /test/bb "); //执行服务器上的FTP命令
* ftpclient.readServerResponse一定要在sendServer后调用
* nameList("/test")获取指目录下的文件列表 XMKD建立目录，当目录存在的情况下再次创建目录时报错 XRMD删除目录
* DELE删除文件
*/
}

public void deleteFile() throws Exception {
ftpclient.ascii();
ftpclient.sendServer("DELE " + "/freep/jpg/37.jpg" + " ");
int reply = ftpclient.readServerResponse();
System.out.println(reply);
}

}