FTP远程下载和报文发送接收.docx
《FTP远程下载和报文发送接收.docx》由会员分享，可在线阅读，更多相关《FTP远程下载和报文发送接收.docx（16页珍藏版）》请在冰点文库上搜索。
FTP远程下载和报文发送接收
1、FTP远程下载
（1）第一种方式
packagecom.cloudpower.util;
importjava.io.File;
importjava.io.FileInputStream;
importjava.io.FileOutputStream;
importjava.io.IOException;
import.TelnetInputStream;
import.TelnetOutputStream;
import.ftp.FtpClient;
/**
*Java自带的API对FTP的操作
*@Title:
Ftp.java
*/
publicclassFtp{
/**
*本地文件名
*/
privateStringlocalfilename;
/**
*远程文件名
*/
privateStringremotefilename;
/**
*FTP客户端
*/
privateFtpClientftpClient;
/**
*服务器连接
*@paramip服务器IP
*@paramport服务器端口
*@paramuser用户名
*@parampassword密码
*@parampath服务器路径
*/
publicvoidconnectServer（Stringip, intport,Stringuser,
Stringpassword,Stringpath）{
try{
/*******连接服务器的两种方法*******/
//第一种方法
// ftpClient=newFtpClient（）;
// ftpClient.openServer（ip,port）;
//第二种方法
ftpClient=newFtpClient（ip）;
ftpClient.login（user,password）;
//设置成2进制传输
ftpClient.binary（）;
System.out.println（"loginsuccess!
"）;
if（path.length（）!
=0）{
//把远程系统上的目录切换到参数path所指定的目录
ftpClient.cd（path）;
}
ftpClient.binary（）;
}catch（IOExceptionex）{
ex.printStackTrace（）;
thrownewRuntimeException（ex）;
}
}
/**
*关闭连接
*/
publicvoidcloseConnect（）{
try{
ftpClient.closeServer（）;
System.out.println（"disconnectsuccess"）;
}catch（IOExceptionex）{
System.out.println（"notdisconnect"）;
ex.printStackTrace（）;
thrownewRuntimeException（ex）;
}
}
/**
*上传文件
*@paramlocalFile本地文件
*@paramremoteFile远程文件
*/
publicvoidupload（StringlocalFile,StringremoteFile）{
this.localfilename=localFile;
this.remotefilename=remoteFile;
TelnetOutputStreamos=null;
FileInputStreamis=null;
try{
//将远程文件加入输出流中
os=ftpClient.put（this.remotefilename）;
//获取本地文件的输入流
Filefile_in=newFile（this.localfilename）;
is=newFileInputStream（file_in）;
//创建一个缓冲区
byte[]bytes=newbyte[1024];
intc;
while（（c=is.read（bytes））!
=-1）{
os.write（bytes,0,c）;
}
System.out.println（"uploadsuccess"）;
}catch（IOExceptionex）{
System.out.println（"notupload"）;
ex.printStackTrace（）;
thrownewRuntimeException（ex）;
}finally{
try{
if（is!
=null）{
is.close（）;
}
}catch（IOExceptione）{
e.printStackTrace（）;
}finally{
try{
if（os!
=null）{
os.close（）;
}
}catch（IOExceptione）{
e.printStackTrace（）;
}
}
}
}
/**
*下载文件
*@paramremoteFile远程文件路径（服务器端）
*@paramlocalFile本地文件路径（客户端）
*/
publicvoiddownload（StringremoteFile,StringlocalFile）{
TelnetInputStreamis=null;
FileOutputStreamos=null;
try{
//获取远程机器上的文件filename，借助TelnetInputStream把该文件传送到本地。
is=ftpClient.get（remoteFile）;
Filefile_in=newFile（localFile）;
os=newFileOutputStream（file_in）;
byte[]bytes=newbyte[1024];
intc;
while（（c=is.read（bytes））!
=-1）{
os.write（bytes,0,c）;
}
System.out.println（"downloadsuccess"）;
}catch（IOExceptionex）{
System.out.println（"notdownload"）;
ex.printStackTrace（）;
thrownewRuntimeException（ex）;
}finally{
try{
if（is!
=null）{
is.close（）;
}
}catch（IOExceptione）{
e.printStackTrace（）;
}finally{
try{
if（os!
=null）{
os.close（）;
}
}catch（IOExceptione）{
e.printStackTrace（）;
}
}
}
}
publicstaticvoidmain（Stringagrs[]）{
Stringfilepath[]={"/temp/aa.txt","/temp/regist.log"};
Stringlocalfilepath[]={"C:
\\tmp\\1.txt","C:
\\tmp\\2.log"};
Ftpfu=newFtp（）;
/*
*使用默认的端口号、用户名、密码以及根目录连接FTP服务器
*/
fu.connectServer（"127.0.0.1", 22, "anonymous", "IEUser@", "/temp"）;
//下载
for（inti= 0;i fu.download（filepath[i],localfilepath[i]）;
}
Stringlocalfile= "E:
\\号码.txt";
Stringremotefile= "/temp/哈哈.txt";
//上传
fu.upload（localfile,remotefile）;
fu.closeConnect（）;
}
}
（2）第二种方式
publicclassFtpApche{
privatestaticFTPClientftpClient= newFTPClient（）;
privatestaticStringencoding=System.getProperty（"file.encoding"）;
/**
*Description:
向FTP服务器上传文件
*
*@Version1.0
*@paramurl
* FTP服务器hostname
*@paramport
* FTP服务器端口
*@paramusername
* FTP登录账号
*@parampassword
* FTP登录密码
*@parampath
* FTP服务器保存目录,如果是根目录则为“/”
*@paramfilename
* 上传到FTP服务器上的文件名
*@paraminput
* 本地文件输入流
*@return成功返回true，否则返回false
*/
publicstaticbooleanuploadFile（Stringurl, intport,Stringusername,
Stringpassword,Stringpath,Stringfilename,InputStreaminput）{
booleanresult= false;
try{
intreply;
//如果采用默认端口，可以使用ftp.connect（url）的方式直接连接FTP服务器
ftpClient.connect（url）;
//ftp.connect（url,port）;//连接FTP服务器
//登录
ftpClient.login（username,password）;
ftpClient.setControlEncoding（encoding）;
//检验是否连接成功
reply=ftpClient.getReplyCode（）;
if（!
FTPReply.isPositiveCompletion（reply））{
System.out.println（"连接失败"）;
ftpClient.disconnect（）;
returnresult;
}
//转移工作目录至指定目录下
booleanchange=ftpClient.changeWorkingDirectory（path）;
ftpClient.setFileType（FTP.BINARY_FILE_TYPE）;
if（change）{
result=ftpClient.storeFile（newString（filename.getBytes（encoding）,"iso-8859-1"）,input）;
if（result）{
System.out.println（"上传成功!
"）;
}
}
input.close（）;
ftpClient.logout（）;
} catch（IOExceptione）{
e.printStackTrace（）;
} finally{
if（ftpClient.isConnected（））{
try{
ftpClient.disconnect（）;
} catch（IOExceptionioe）{
}
}
}
returnresult;
}
/**
*将本地文件上传到FTP服务器上
*
*/
publicvoidtestUpLoadFromDisk（）{
try{
FileInputStreamin= newFileInputStream（newFile（"E:
/号码.txt"））;
booleanflag=uploadFile（"127.0.0.1", 21, "zlb","123", "/", "哈哈.txt",in）;
System.out.println（flag）;
} catch（FileNotFoundExceptione）{
e.printStackTrace（）;
}
}
/**
*Description:
从FTP服务器下载文件
*
*@Version1.0
*@paramurl
* FTP服务器hostname
*@paramport
* FTP服务器端口
*@paramusername
* FTP登录账号
*@parampassword
* FTP登录密码
*@paramremotePath
* FTP服务器上的相对路径
*@paramfileName
* 要下载的文件名
*@paramlocalPath
* 下载后保存到本地的路径
*@return
*/
publicstaticbooleandownFile（Stringurl, intport,Stringusername,
Stringpassword,StringremotePath,StringfileName,
StringlocalPath）{
booleanresult= false;
try{
intreply;
ftpClient.setControlEncoding（encoding）;
/*
* 为了上传和下载中文文件，有些地方建议使用以下两句代替
* newString（remotePath.getBytes（encoding）,"iso-8859-1"）转码。
* 经过测试，通不过。
*/
// FTPClientConfigconf=newFTPClientConfig（FTPClientConfig.SYST_NT）;
// conf.setServerLanguageCode（"zh"）;
ftpClient.connect（url,port）;
//如果采用默认端口，可以使用ftp.connect（url）的方式直接连接FTP服务器
ftpClient.login（username,password）;//登录
//设置文件传输类型为二进制
ftpClient.setFileType（FTPClient.BINARY_FILE_TYPE）;
//获取ftp登录应答代码
reply=ftpClient.getReplyCode（）;
//验证是否登陆成功
if（!
FTPReply.isPositiveCompletion（reply））{
ftpClient.disconnect（）;
System.err.println（"FTPserverrefusedconnection."）;
returnresult;
}
//转移到FTP服务器目录至指定的目录下
ftpClient.changeWorkingDirectory（newString（remotePath.getBytes（encoding）,"iso-8859-1"））;
//获取文件列表
FTPFile[]fs=ftpClient.listFiles（）;
for（FTPFileff:
fs）{
if（ff.getName（）.equals（fileName））{
FilelocalFile=newFile（localPath+
升级会员 