java做的比较完善的FTP连接上传下载文件

依依

这是偶第一次写java程序实现公司要求的FTP数据同步，所有原代码如下，以供各位参考并提出宝贵意见！另外俺还有两个功能没有实现，有请高手指点一二：1、如何删除FTP服务器上已经下载过的文件？2、如何将上传的文件改名？上传时在文件名前加“temp_”，上传完毕后需要把文件名改回来。3、如何使用openPassiveDataConnection()方法将ftp连接更改为主动连接，因为要从unix系统配置的ftp服务器下载文件的话，就需要主动连接。 p&[ {'^Z ~
; zH t;2
j % T k
" C aa(% l
/* V^6 `KL '*
******************************************************************************************************* CR- 8 TG
ra$ 43Hr R
Filename: ftp.java ?rw4@(7 >E
Author: leetsing(elove) Qh=;
Create date: 2004-08-30 s()F|A<
Use: connect to FTP server,then upload and download file 5:8?}2h
Modify date: 2004-09-05 add to upload file Y " 20r
2004-09-13 add to download file q ^2VTvi!
Copy right: Magisky Media Technology Co.,Ltd. M7)1rJQ)
\( c/ %G
******************************************************************************************************* u [XItF2
*/ NSoKxQ[2(<
//import cz.dhl.io.*; r:'= Mq(
//import cz.dhl.ftp.*; HX}n 3BQ[m
import sun.net.ftp.*; f sP E Za
import sun.net.*; 1% 1 f&b
import java.applet.*; H8'1Mk F
import java.io.*; ' - _> R?f
import java.io.IOException; ^FmGyK \ =
import java.util.StringTokenizer; \hTHI o(C7
import sun.net.ftp.FtpClient; +2 'p
import java.util.ArrayList; b~ &hh* L
5 hJJS2B
public class ftp extends Applet b$>_ LAp<_
{ \ V iod~4
FtpClient aftp; 6 Iz "(B<
DataOutputStream outputs ; .SV+~g 6o
TelnetInputStream ins; *&HW&Z l
TelnetOutputStream outs; Ar;Q-(q&Z.
05GwQ|'K !
int ch; jP@= e%}t5
public String a; [%tazTW l~
String hostname=\"\"; <uiA5 9so
private String path = \"/\"; 6F ! v* 7p
iI 6 X>:
public static void main(String[] args) :^d OK+
{ 1 pJS{$ +
String hostname = \"192.168.0.56\"; ?c \V0*+
int port = 2121; 8H%iW |9 "
String uid = \"lee\"; T|{ (R==7t
String pwd = \"lee\"; u`uNh\>` Z
String RWFileDir = \"D:\\\\smsftp\\\\\";//文件目录 bm z TMs)
9)ed}6@>
//连接ftp服务器 ~ 5G) J]
ftp ft = new ftp(); m gl
ft.connect(RWFileDir,hostname,port,uid,pwd); w,^ (ZX ;
*#9XJ W Ea
//下载文件 T {5b rLz
if (ft.aftp != null){ Wp UYF@c
try { :w nM $%)1
ft.getNameList(RWFileDir); $SLXM Bf :
}catch(IOException e) Y ulTb0, f
{ 9s|8#a;+
System.out.println(\"下载文件出错：\"+e); ` & _._
} 0 Ir^ { c
} s@+ n= -7
:{O`lRa |
yiY]
//上传文件 y,1Li yK L
if (ft.aftp != null){ K ! ^*1l
String sdir = RWFileDir + \"subunsubfromsp\\\\\"; _ uMhz\{h7
File fdir = new File(sdir); T [(\5] 3
String FileName = \"\"; {T< %4Im
nG 9z M%{8
for(int i=0;i FileName = sdir + (fdir.list()); *8TeDIs, m
1K N#} b
ft.uploadFile(RWFileDir,FileName); I3- jAMLcJ
} BKV*+Rr8{s
//System.out.println(\"成功上传的文件：\"); ( T D~g+kF
//ft.showFileContents(\"subunsubfromsp\\\\\"); _! r /u C@
} S;(M)kwXgY
" G yvNI
//删除subunsubfromsp目录下已经上传的文件文件 j N9|$ m"f
// ft.deleFile(RWFileDir); Fp,I,K hd
iR_Z ca
//断开服务器连接 r{ @ O ;
ft.stop(RWFileDir); VuO/> 0$
b (kw f u
} (: -(}{,w1
) F~h ; e
public FtpClient connect(String RWFileDir,String hostname,int port,String uid,String pwd) Yhw!)R' G
{ Y (Fj CrBJ
this.hostname = hostname; `(}hpt0z
System.out.println(\"正在连接\"+hostname+\"，请等待.....\"); e~vN.is^I*
try{ ? 'z d] ]I
aftp = new FtpClient(hostname,port); G 8MG2K,9
aftp.login(uid,pwd); Z"G'm {Sr
aftp.binary(); R { .H,2?
//aftp.openPortDataConnection(); 1 *Z
a = \"连接主机:\"+hostname+\"成功!\"; m AX7b +
System.out.println(a); ||J =7{4wh
} =C (O lM
catch(FtpLoginException e){ nK $ *Rmcf
a=\"登陆主机:\"+hostname+\"失败!请检查用户名或密码是否正确：\"+e; Jb%"DwQ.U
System.out.println(a); *J ?'tyqa
//return false; kz0 k j$=)
} A{> E i
catch (IOException e){ - !(+e2 R
a=\"连接主机:\"+hostname+\"失败!请检查端口是否正确：\"+e; VNyn O<PM
System.out.println(a); /\M>bI<, j
//return false; I$ qxK W-
} wO nH:qLo
catch(SecurityException e) Am LWq^^0
{ #:f<OB}
a=\"无权限与主机:\"+hostname+\"连接!请检查是否有访问权限：\"+e; VNA= &J*h$
System.out.println(a); #J6'gpp Y
//return false; 3 r,K) X1
} @%I4 [R8
LI\~ 7 BJ
log(RWFileDir,a); a ?<sWP0f
return aftp; me x g k
} b ^P(V&$ {
0.O .8 >
public void stop(String RWFileDir) ~6]^sIwA#5
{ LBKT64na!;
String message = \"\"; .Z ` Mxx
try { v{a KSu
if(aftp!=null){ !^.*_%44(Q
aftp.closeServer(); .BE !sSM k
message = \"与主机\"+hostname+\"连接已断开!\"; 7Js>* kH 0
System.out.println(message); bT4s ? ta
log(RWFileDir,message); -^ousSu
} ps=O(_z-r
} wG\R3 /NF
catch(IOException e) # ^s T
{ H; w>( 7J
message = \"与主机\"+hostname+\"断开连接失败!\"+e; Z \cM ]2U
System.out.println(message); /.j #ay^
log(RWFileDir,message); LuB] oro]{
} F (- X]?S
} < 8s ] q
I Et {,3 ~
!):}5Y* r
public boolean downloadFile(String RWFileDir,String filepathname){ W# _'W _iC
boolean result=true; `0 t &U8r
String message = \"\"; J>;O)<7 m
if (aftp != null) N iz#8{!~
{ OAS u~wq^y
System.out.println(\"正在下载文件\"+filepathname+\",请等待....\"); HiNAT C "~
String badfile = filepathname.substring(filepathname.length()-4,filepathname.length()); 6/y: 7 5&
String badlog = filepathname.substring(filepathname.length()-7,filepathname.length()); #_zd-+!''
String baddir = \"\"; z; 4 ,""pB
if ((badfile.compareTo(\".bad\") != 0) && (badlog.compareTo(\".badlog\") != 0)){ QG0Y<D*h ~
baddir = \"subunsubtosp\\\\\"; _AV k*NRfV
} e )c9kf?i*
else{ GvA i,rTCs
baddir = \"bad\\\\\"; bRX3zrN U
} _h+_ZV8b;
String strdir = \"subunsubtosp\\\\\"; &bII 8w :
//System.out.println(RWFileDir + baddir + filepathname); 9mV#F1I=u~
try{ D Q'! *\ZR
//FtpClient fc=new FtpClient(\"192.168.0.56\",2121); LAV *43nBJ
//fc.login(\"lee\",\"lee\"); Z.^ I.|$P_
int ch; A 5IW 8
File fi = new File(RWFileDir + baddir + filepathname); > AGZ z]
//aftp.cd(strdir); U^ M jSI
RandomAccessFile getFile = new RandomAccessFile(fi,\"rw\"); uf Q G
getFile.seek(0); 8 =S+ Q }
TelnetInputStream fget=aftp.get(strdir+filepathname); og$yt2Q(QD
DataInputStream puts = new DataInputStream(fget); )*C`xj;5 ;
while ((ch = puts.read()) >= 0) { )Of x=qP
getFile.write(ch); `4]Y5 G/{
&# 3r (
} @{0X8r)*
//s.delete(); )1O$K
UwC }F s /
fget.close(); 0A 3RQ O>a
getFile.close(); [oAcVCVB'I
//fc.closeServer(); Q%K}c3 mx{
Bm b Pq
message = \"下载\"+filepathname+\"文件到\"+baddir +\"目录成功!\"; N|'%-7 HSC
System.out.println(message); Qy)q{?1y-~
log(RWFileDir,message); A 4?%)Bv
} x]{)Ny| ?4
catch(IOException e){ ]u7 Hej6 *
message = \"下载\"+filepathname+\"文件到\"+baddir +\"目录失败!\"+e; x0z'>0 d
System.out.println(message); 1F.| bb?
log(RWFileDir,message); ?:J\/F~
result = false ; M; AgzY5/m
bbfbG t!v
} /o 0F ,7hi
} q. D +KN<:
else{ <Cdb *m Z
result = false; [&wFR 4U
} s r+v1Vps
return result; 78d} X JQV
} JxE 0'b AR
<!I5?42' x
v` } !s Z
public boolean uploadFile(String RWFileDir,String filepathname){ Xi8n Abv
boolean result=true; N!t B8 8
String message = \"\"; b q'p{c 1
if (aftp != null) F 73XF [!
{ M>z*@ ah^
System.out.println(\"正在上传文件\"+filepathname+\",请等待....\"); lZF` eVk&x
tUdtM%E 7
try{ ;7sr_=9Ak\
String fg =new String(\"\\\\subunsubfromsp\\\\\"); Z xrc 9obG
int index = filepathname.lastIndexOf(fg); Da*v l
String filename = filepathname.substring(index+1); $gcb Yt&p
File localFile = new File(filepathname) ; oA1GrUD C|
~Q ; Ni=1B
RandomAccessFile sendFile = new RandomAccessFile(filepathname,\"r\"); ?hhx s? 5u
// I e `:Ai(
sendFile.seek(0); Xu VN9
//改名上传temp_ uy =+qf(F
filename = filename.substring(0,15)+\"temp_\"+filename.substring(15,filename.length()); k jqCSX 7
outs = aftp.put(filename); n# q`pgd<
outputs = new DataOutputStream(outs); ^ ) pk)-
while (sendFile.getFilePointer() < sendFile.length() ) l iO1^ U 9
{ 5$![L 2/
ch = sendFile.read(); [z JZS A:
outputs.write(ch); H+OPdho:X
} f $w aF {
%y ~0BY:
rename(filename.substring(15,filename.length()),filename.substring(20,filename.length())); O S 9 E
outs.close(); :enD 'an(
sendFile.close(); KRC X 6
CD_p H"w <
message = \"上传\"+filepathname+\"文件成功!\"; yBb O ^ 7
System.out.println(message); @z P;oM<
log(RWFileDir,message); SN w8 \B
} $MG)Vq=a P
catch(IOException e){ P}2# % tMp
message = \"上传\"+filepathname+\"文件失败!\"+e; yo4-J )}U
System.out.println(message); "=P/tp!i f
log(RWFileDir,message); EjT bI6'
result = false ; I hXJa 2
8L||n3#a '
} P umnt? 5~
} Pv.mE5+ k{
else{ `g{GC 6f =
result = false; ?|.rdre _
} 0nc{ OU4o
return result; TLQ= <4
} ]0 ){zM
{xR }uO#LA
public void rename(String oldName,String newName){ K& k+y g
XL:cfDX}v
//aftp.renameTo(oldName,newName); th^/;d =gF
File Old = new File(oldName); //oldName = Pj{mf@*c
File New = new File(newName); //newName j>@ 6 H
//aftp.renameTo(New); _m {( hcd/
//boolean Old.renameTo(File newName); K5pU{ uC0}
//System.out.println(Old); Xl H>jpb23
//System.out.println(New); ocbP a_#(
g@%F8l+F
} F_XX= 9 W
FW;K :$ +
public static void deleFile(String RWFileDir) { VNzl`9* W
//try { *vv&`q U
//取得ReadFile目录下的txt文件 [e0 V?n! e
String sdir = RWFileDir + \"subunsubfromsp\\\\\"; !k )E QSt
File fdir = new File(sdir); hf1^" Nr8
String FileName = \"\"; *w&~fp{)oK
int j = fdir.list().length; ,f$RUgNe(
D 6Qk 7
System.out.println(sdir+\"目录下要删除的文件数：\"+fdir.list().length); y^ 4]V-I=u
File file; l -, Sq 8
for(int i=0;i { 7ry _6Kja
//删除subunsubfromsp中的txt文件 VsCc]SBVb
FileName = RWFileDir + \"subunsubfromsp\\\\\" + (fdir.list())[0]; |*u ]v \ a
file = new File(FileName); y(~Xf<0"}b
file.delete(); Z7H[V3ky X
System.out.println(\"已经成功删除\"+FileName+\"文件！\"); + MM 9<cJ
} fl oP `
//} qq B_Tb*n4
//catch (IOException e) { N^ rN_A@)
// System.out.println(\"删除txt文件错误!\"); 9JpD6To2jV
// e.printStackTrace(); K- 0o ViT
//} X {C O@_#
} j{ ?'q X_
=k7&. =Qk0
l M{U8d-T
public void showFileContents(String strdir) #x +L 1x=
{ zU MNY h
StringBuffer buf = new StringBuffer(); ? 8y 3 i
try { m& r4 HS a
aftp.cd(strdir); ?\ Gv g
ins= aftp.list(); zZt ^a 6
while ((ch=ins.read())>=0){ F }8 F Xo
buf.append((char)ch); `># *>M=fS
} -j c1:qo9t
zK < 68
System.out.println(buf.toString()); 3K { r -9K
{XM .mOw+
ins.close(); L~D?] kP`?
} +{(D-Opo:]
catch(IOException e) / ,6Gq zd
{ ]6/ t>cWt
} (|B x S/z
} iz|B . *E(
Ua ' swqD
`@nuxQs- n
q}Y[-FY u
// 返回当前目录的所有文件及文件夹 vK, W e)|q
D UP H7o*
public ArrayList getFileList() throws IOException { +gL ):
BufferedReader dr = new BufferedReader(new InputStreamReader(aftp.list())); [;W_ gA!ub
ArrayList al = new ArrayList(); ;X9K g S
String s = \"\"; g 96-Ct"X@
while ( (s = dr.readLine()) != null) { "<WZ &ml
al.add(s); GbK4?-kDs
} uU2% r
return al; 6Apu8'[N"b
} N3`V<h pL7
v=Te^a" iG
public void setPath(String path) throws IOException { SPn&Lw;,?
if (aftp == null) # +{ !g ]
this.path = path; % Vj`ORfv
else { @P)co/(w Z
aftp.cd(path); so Q|O
} 0-3@U(6Q
} 9 f~d + X
nv +@ v]b2
// 返回当前目录的文件名称 U8R vj6C
.-[Z t _/S
public ArrayList getNameList(String RWFileDir) throws IOException { a.1X"yzOEH
B? U L
BufferedReader dr = new BufferedReader(new InputStreamReader(aftp.nameList(\"subunsubtosp\\\\\"))); V&sAJ"Do
ArrayList al = new ArrayList(); x] *@ "fp
String s = \"\"; "l2 G-}\
while ( (s = dr.readLine()) != null) { + U! '
al.add(s); ,l g|+ 5
s = s.substring(13,s.length()); * ,3%eFT>.
isFile(s); 6_DO2o / y
downloadFile(RWFileDir,s); L |!*Hn2)V
//String strFileDelF = aftp.nameList(\"subunsubtosp\\\\\"); 9X- ' m
File fileDelF=new File(s); 1h z HX#
fileDelF.delete(); v]97iq'R
} # 0' 0NT-
return al; ,-R p_Y B
//System.out.println(al.add(s)); p Ad j
} & s \ N 4
v {8#~6=J[
// 判断一行文件信息是否为目录 <#B}.#`rNl
}Ua biIA(
public boolean isDir(String line) { [ Z b m&3%
return ( (String) parseLine(line).get(0)).indexOf(\"d\") != -1; { iR jb?'U
} P \B<3YE c
6>!@WY g J
public boolean isFile(String line) { i?CWn87 y
return!isDir(line); n4 , )O 1a
} t% <0 y1E@
<C S { l
// 处理getFileList取得的行信息 vVyiF )i,t
? }yV *8
private ArrayList parseLine(String line) { 69J% 9@ Z
ArrayList s1 = new ArrayList(); 9bml2e t
StringTokenizer st = new StringTokenizer(line, \" \"); c=a( 0f4T
while (st.hasMoreTokens()) { Q )$Y o$TW
s1.add(st.nextToken()); ES N0 x[V
} Bz $kt |w
return s1; Ly R p "
} 7e~=Y'b.$q
j-`d Bb%=y
//写消息日志 1L J \p 4
public static void log(String RWFileDir,String msg) D< G[jFz9s
{ #G8 /\,Wx
String message = \"\"; c_HEZTJ4 @
try { a`( Z" uj@
java.text.DateFormat df = new java.text.SimpleDateFormat(\"yyyy-MM-dd HH:mm:ss\"); $" 6vK sm
java.text.DateFormat dflog = new java.text.SimpleDateFormat(\"yyyyMMdd\"); Ir4h #1N 3
java.util.Date date = new java.util.Date() ; pWRU Js 2
String datestr = df.format(new java.util.Date()) ; 3v&q*Gf +
String datelog = dflog.format(new java.util.Date()) ; \GK,(ia
//String datelog = datestr.substring(0,10); !* 2P r k
//datelog = datelog.replace(\'-\',\' \'); Z x5\kUG U
x k7KD:|D
//按日期每天生成一个日志文件 I `oCZ u9
FileWriter fwl = new FileWriter(RWFileDir + \"CMSSftp\"+datelog+\".log\",true); n%5XTL =op
PrintWriter outl = new PrintWriter(fwl); Szx y
outl.println(datestr + \" \" + msg); I t ^5FJ
outl.close(); < /RF.
fwl.close(); R h' ) F
}catch (IOException e) { K} + o{T6
message = \"写log文件错误!\"+e; kFk *"S jQ
e.printStackTrace(); Lm%}+ a
log(RWFileDir,message); sUI$ 2D NP
System.out.println(message); 'DI , `5
} W5F n% ]
} @LxRH('arK
}