java 实现FTP协议多个文件的上传

eazqybinez

package com.siinterface.adc;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.PrintWriter;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;
/***采用FTP协议实现多个文件的上传*FTP协议是Internet上用来传送文件的协议，规定了Internet上文件互相传送的标准。在java中实
*现这一功能是借助FtpClient类完成的。具体实现过程：首先与FTP服务器建立连接；初始化文件的 *传输方式，包括ASCII和BINARY两种方式；将文件输出到文件输入流FileInputStream中；*FileInputStream中的数据读入字节数组中；字节数组中的数据写入输出流*TelnetOutputStream（利用write方法将数据写入到一个网络链接上）。这样和源文件同名的一个*文件就复制到了服务器端。本例的JavaBean中通过upload()方法完成文件上传过程。*/
import java.io.File;
import java.io.FileInputStream;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;
public class FtpClients {
public FtpClients() {
}
public static void main(String[] args) {
FtpClients writeFileToServer = new FtpClients();
writeFileToServer.upload("D:\\130183002\\1053\\useraddr.txt");
}
/**
* 移动文件到目标目录
* @param sourceFile 源目录
* @param outFile 目标目录
*/
public static void moveData(String sourceFile, String outFile)
{
FileInputStream inPut = null;
FileOutputStream outPut = null;
File sfile = null;
String fileName = "";
try
{
sfile = new File(sourceFile);
sfile.createNewFile();
inPut = new FileInputStream(sfile);
outPut = new FileOutputStream(outFile);
byte buffer[] = new byte[ (int) sfile.length()];
inPut.read(buffer);
outPut.write(buffer);
inPut.close();
inPut = null;
outPut.close();
outPut = null;
}
catch (Exception e)
{
e.printStackTrace();
}
}
public static void copyfile(String localFileAndPath,String bakpath)
{
FileInputStream fis=null;
PrintWriter pw=null;
try
{
fis=new FileInputStream(new File(localFileAndPath));
int len=0;
byte[] bt=new byte[1024];
java.io.File file = new java.io.File(bakpath);
pw = new PrintWriter(new FileOutputStream(file));
while((len=fis.read(bt))!=-1)
{
pw.write(len);
}
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
try
{

if(pw!=null)
pw.close();
if(fis!=null)
{
fis.close();
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
}
public static void upload(String localFileAndPath) {
FtpClient ftpClient =null;
FileInputStream fis=null;
TelnetOutputStream tos=null;
try {
ftpClient=new FtpClient("221.179.7.251",21);
//ftpClient.login("siinterface","siinterface");
ftpClient.login("daemon_omssi@gdadc.local","oi87SE$%");
/*********必须要有下面这一句，否则写入的大小与读入的大小不一致************/
ftpClient.binary();
/************************取得本地文件的属性**************************/
File f=new File(localFileAndPath);
System.out.println("本地文件大小："+f.length());
System.out.println("文件名："+f.getName());
fis=new FileInputStream(new File(localFileAndPath));
//put方法的参数表示在FTP服务器上要生成的文件名
tos=ftpClient.put("/incoming/ADC/OMSTEMP/"+f.getName());
byte[] bt=new byte[1024];
int len=0;
int lenTotal=0;
//采用循环的方式将从文件读入的流写到FTP服务器上
while((len=fis.read(bt))!=-1) {
lenTotal+=len;
tos.write(bt,0,len);
}
System.out.println("写到服务器的大小："+lenTotal);
} catch (Exception e) {
System.out.println(e.toString());
}
finally
{
try
{
if(tos!=null)
tos.close();
}
catch(Exception e)
{
e.printStackTrace();
}
try
{
if(fis!=null)
fis.close();
}
catch(Exception e)
{
e.printStackTrace();
}
try
{
if(ftpClient!=null)
ftpClient.closeServer();
}
catch(Exception e)
{
e.printStackTrace();
}
}
}
}