复制代码代码如下:
importar java.io.ByteArrayInputStream;
importar java.io.FileOutputStream;
importar java.io.IOException;
importar java.net.SocketException;
importar java.text.SimpleDateFormat;
importar java.util.Date;
importe org.apache.commons.io.IOUtils;
importar org.apache.commons.net.ftp.FTPClient;
/**
*nome da classe:FTPFileTransmit<BR>
*descrição da turma: por favor escreva sua descrição <BR>
* Observação: <BR>
* @versão 1.00 9/8/2011
*/
classe pública FTPFileTransmit {
string privada ftpPath;
private String ftpName;
string privada ftpPassword;
private String ftpServerIP;
public FTPFileTransmit() {
this.ftpPath = "xxx/xxx/";
this.ftpName = "nome";
this.ftpPassword = "passar";
this.ftpServerIP = "192.168.0.xx";
}
/**
* Nome do método: saveInFTP <BR>
* Descrição: 把文件存储在FTP上 <BR>
* Observação: <BR>
* @param FolderName por exemplo"xxx/xxx/"
* @param FileName por exemplo "thefilename"
* @param data byte[]数组
* @return booleano<BR>
*/
public boolean saveInFTP (String FolderName, String FileName, byte[] dados) {
sinalizador booleano = falso;
//创建FTP客户端
FTPClient ftpClient = new FTPClient();
// 输入流用于读取文件
// FileInputStream fis = null;
ByteArrayInputStream bis = null;
tentar {
// 如果FolderName e FileName都不符合基本要求, 那么就没有必要进行ftp操作
if (NomeDaPasta! = Nulo
&& FolderName.compareTo("") != 0
&& NomeDoArquivo! = Nulo
&& NomeDoArquivo.compareTo("") != 0) {
// 建立FTP连接
ftpClient.connect(this.ftpServerIP);
// 如果登录成功后, 才进行创建输入流
if (ftpClient.login(this.ftpName, this.ftpPassword)) {
// Arquivo srcClientFile = new File("C:/ParseXML.xml");
// 实例化输入流
// fis = new FileInputStream(srcClientFile);
if (ftpClient.changeWorkingDirectory(FolderName)) {
// byte[]写入到输入流中, 实例化
bis = novo ByteArrayInputStream(dados);
// 设置缓冲
ftpClient.setBufferSize(1024);
// 设置文件类型(二进制类型)
if (ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE)) {
flag = ftpClient.storeFile (Nome do arquivo, bis);
}
}
}
}
} catch (SocketException e) {
e.printStackTrace();
bandeira = falso;
} catch (IOException e) {
e.printStackTrace();
bandeira = falso;
} catch (Exceção e) {
e.printStackTrace();
bandeira = falso;
} finalmente {
tentar {
// 关闭输入流
IOUtils.closeQuietly(bis);
// 关闭连接
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
}
}
bandeira de retorno;
}
/**
* Nome do método: getFromFTP <BR>
* Descrição: 从FTP上读取文件 <BR>
* Observação: <BR>
* @return booleano<BR>
*/
public booleano getFromFTP () {
sinalizador booleano = falso;
//创建FTP客户端
FTPClient ftpClient = new FTPClient();
// 输出流用于输出文件
FileOutputStream fos = null;
tentar {
// 建立FTP连接
ftpClient.connect(this.ftpServerIP);
// 如果登录成功后, 才进行创建输出流
if (ftpClient.login(this.ftpName, this.ftpPassword)) {
// FTP文件
String distineFile = "/nome/xxx/xxx/xxx文件";
// 实例化输出流
fos = novo FileOutputStream("C:/ParseXML_InFTP.xml");
// 设置缓冲
ftpClient.setBufferSize(1024);
// 设置文件类型(二进制类型)
if (ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE)) {
ftpClient.retrieveFile(distinationFile, fos);
bandeira = verdadeiro;
}
}
} catch (SocketException e) {
e.printStackTrace();
bandeira = falso;
} catch (IOException e) {
e.printStackTrace();
bandeira = falso;
} catch (Exceção e) {
e.printStackTrace();
bandeira = falso;
} finalmente {
tentar {
// 关闭输出流
IOUtils.closeQuietly(fos);
// 关闭连接
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
}
}
bandeira de retorno;
}
public boolean createDirectory() {
sinalizador booleano = falso;
//创建FTP客户端
FTPClient ftpClient = new FTPClient();
tentar {
// 建立FTP连接
ftpClient.connect(this.ftpServerIP);
// 如果登录成功后, 才进行操作
if (ftpClient.login(this.ftpName, this.ftpPassword)) {
// 切换文件路径, 到FTP上的"NNDD3"文件夹下
if (this.ftpPath != null && this.ftpPath.compareTo("") != 0
&& ftpClient.changeWorkingDirectory(this.ftpPath)) {
SimpleDateFormat f = new SimpleDateFormat("aaaaMMdd");
String time = f.format(new Date());
String FolderName = hora + "_ReTransmit";
ftpClient.makeDirectory(NomeDaPasta);
bandeira = verdadeiro;
}
}
} catch (SocketException e) {
e.printStackTrace();
bandeira = falso;
} catch (IOException e) {
e.printStackTrace();
bandeira = falso;
} catch (Exceção e) {
e.printStackTrace();
bandeira = falso;
} finalmente {
tentar {
// 关闭连接
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
}
}
bandeira de retorno;
}
public String[] getAllFolderNames() {
//创建FTP客户端
FTPClient ftpClient = new FTPClient();
tentar {
// 建立FTP连接
ftpClient.connect(this.ftpServerIP);
// 如果登录成功后, 才进行操作
if (ftpClient.login(this.ftpName, this.ftpPassword)) {
// 切换文件路径, 到FTP上的"NNDD3"文件夹下
if (this.ftpPath != null && this.ftpPath.compareTo("") != 0
&& ftpClient.changeWorkingDirectory(this.ftpPath)) {
// 将当前时间减去2天, 删除的是前两天的数据包
String time = minusTime();
String[] todosNomes = ftpClient.listNomes();
String[] temp = new String[allNames.length];
// 初始化数组
for (int j = 0; j < todosNomes.comprimento; j ++) {
temperatura[j] = "";
}
// 找出要删除文件夹的名称
for (int i = 0; i < todosNomes.comprimento; i ++) {
if (allNames[i].substring(0, 8).compareTo(time) <= 0) {
temp[i] = todosNomes[i];
}
}
temperatura de retorno;
}
}
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finalmente {
tentar {
// 关闭连接
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
}
}
retornar nulo;
}
/**
*
* Nome do método: minusTime <BR>
* Descrição: 获取钱两天的时间,如2011-8-1的前两天就是2011-7-30 <BR>
* Observação: <BR>
* @return String<BR>
*/
private String menosTempo() {
SimpleDateFormat df=new SimpleDateFormat("aaaaMMdd");
Data d = nova Data();
String timeMinus2 = df.format(new Date(d.getTime() - 2 * 24 * 60 * 60 * 1000));
tempo de retornoMenos2;
}
public static void main(String[] args) {
FTPFileTransmit ftpFileTransmit = new FTPFileTransmit();
ftpFileTransmit.deleteFoldersInFTP();
// sinalizador booleano = ftpFileTransmit.createDirectory();
// se (sinalizador) {
// System.out.println("****** FTP文件夹创建成功 ******");
// }
// String FolderName = ftpFileTransmit.ftpPath + "20110809_ReTransmit/";
// byte[] dados = novo byte[1024];
// for (int i = 0; i < data.length; i ++) {
// dados[i] = 'a';
// }
// sinalizador booleano = ftpFileTransmit.saveInFTP(FolderName, "2011080912345678" ,data);
// se (sinalizador) {
// System.out.println("****** FTP文件夹创建成功 ******");
// }
}
}