001    /*
002     * Copyright (c) 2009 The openGion Project.
003     *
004     * Licensed under the Apache License, Version 2.0 (the "License");
005     * you may not use this file except in compliance with the License.
006     * You may obtain a copy of the License at
007     *
008     *     http://www.apache.org/licenses/LICENSE-2.0
009     *
010     * Unless required by applicable law or agreed to in writing, software
011     * distributed under the License is distributed on an "AS IS" BASIS,
012     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
013     * either express or implied. See the License for the specific language
014     * governing permissions and limitations under the License.
015     */
016    package org.opengion.fukurou.util;
017    
018    import java.io.IOException;
019    import java.util.Map;
020    import java.util.LinkedHashMap ;
021    import java.util.Vector;
022    import java.util.Hashtable;
023    
024    import com.jcraft.jsch.JSch;
025    import com.jcraft.jsch.Session;
026    import com.jcraft.jsch.ChannelSftp;
027    import com.jcraft.jsch.ChannelSftp.LsEntry;
028    import com.jcraft.jsch.SftpATTRS;
029    import com.jcraft.jsch.JSchException;
030    import com.jcraft.jsch.SftpException;
031    
032    
033    /**
034     * SFTPConnect.java 縺ｯ縲∝?騾夂噪縺ｫ菴ｿ逕ｨ縺輔ｌ繧?SFTP髢｢騾｣縺ｮ蝓ｺ譛ｬ讖溯?繧貞ｮ溯｣?＠縺溘?繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
035     *
036     * 縺薙ｌ縺ｯ縲｛rg.apache.commons.net.ftp.FTPClient 繧偵?繝ｼ繧ｹ縺ｫ髢狗匱縺輔ｌ縺ｦ縺?∪縺吶?
037     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｮ螳溯｡後↓縺ｯ縲…ommons-net-ftp-2.0.jar 縺悟ｿ?ｦ√〒縺吶?
038     *
039     * -host=SFTP繧ｵ繝ｼ繝舌? -user=繝ｦ繝ｼ繧ｶ繝ｼ -passwd=繝代せ繝ｯ繝ｼ繝?-remoteFile=SFTP蜈医?繝輔ぃ繧､繝ｫ蜷?繧貞ｿ??險ｭ螳壹＠縺ｾ縺吶?
040     * -localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?縲∝ｿ??縺ｧ縺ｯ縺ゅｊ縺ｾ縺帙ｓ縺後?-command=DEL 縺ｮ蝣ｴ蜷医↓縺ｮ縺ｿ荳崎ｦ√〒縺ゅｊ縲?
041     * 縺昴ｌ莉･螟悶? command 縺ｮ蝣ｴ蜷医?縲∝ｿ?ｦ√〒縺吶?
042     *
043     * -command=[GET/PUT/DEL/GETDIR/PUTDIR/DELDIR] 縺ｯ縲ヾFTP繧ｵ繝ｼ繝舌?縺ｫ蟇ｾ縺励※縺ｮ蜃ｦ逅??譁ｹ豕輔ｒ謖?ｮ壹＠縺ｾ縺吶?
044     *   GET:SFTP繧ｵ繝ｼ繝舌?縺九ｉ繝ｭ繝ｼ繧ｫ繝ｫ縺ｫ繝輔ぃ繧､繝ｫ霆｢騾√＠縺ｾ縺?蛻晄悄蛟､)縲?
045     *   PUT:繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧担FTP繧ｵ繝ｼ繝舌?縺ｫ PUT(STORE縲ヾAVE縲ゞPLOAD縲√↑縺ｩ縺ｨ蜷梧э隱?縺励∪縺吶?
046     *   DEL:SFTP繧ｵ繝ｼ繝舌?縺ｮ謖?ｮ壹?繝輔ぃ繧､繝ｫ繧貞炎髯､縺励∪縺吶?縺薙?蝣ｴ蜷医?縺ｿ縲?localFile 螻樊?縺ｮ謖?ｮ壹?荳崎ｦ√〒縺吶?
047     *   GETDIR,PUTDIR,DELDIR:謖?ｮ壹?繝輔か繝ｫ繝?ｻ･荳九?繝輔ぃ繧､繝ｫ繧貞?逅?＠縺ｾ縺吶?
048     *
049     * -mkdirs=[true/false] 縺ｯ縲∝女縺大?縺ｮ繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?SFTP繧ｵ繝ｼ繝舌?)縺ｫ蜿悶ｊ霎ｼ繧?ヵ繧｡繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺?
050     * 蟄伜惠縺励↑縺??蜷医↓縲∽ｽ懈?縺吶ｋ縺九←縺?°繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:true)縲?
051     * 騾壼ｸｸ縲ヾFTP繧ｵ繝ｼ繝舌?縺ｫ縲√ヵ繧ｩ繝ｫ繝?嚴螻､繧剃ｽ懈?縺励※PUT縺吶ｋ蝣ｴ蜷医?蜍慕噪縺ｫ繝輔か繝ｫ繝?嚴螻､繧剃ｽ懈?縺励◆縺?こ繝ｼ繧ｹ縺ｧ萓ｿ蛻ｩ縺ｧ縺吶?
052     * 騾?↓縲√ヵ繧ｩ繝ｫ繝??遒ｺ螳壹＠縺ｦ縺翫ｊ縲∵欠螳壹ヵ繧ｩ繝ｫ繝?ｻ･螟悶↓ PUT 縺吶ｋ縺ｮ縺ｯ繝舌げ縺｣縺ｦ縺?ｋ縺ｨ莠九′蛻?°縺｣縺ｦ縺?ｋ蝣ｴ蜷医↓縺ｯ
053     * false 縺ｫ險ｭ螳壹＠縺ｦ縲∝ｭ伜惠縺励↑縺?ヵ繧ｩ繝ｫ繝?↓PUT 縺励ｈ縺?→縺吶ｋ縺ｨ縲√お繝ｩ繝ｼ縺ｫ縺ｪ繧九ｈ縺?↓縺励∪縺吶?
054     *
055     * 蠑墓焚譁?ｭ怜?荳ｭ縺ｫ遨ｺ逋ｽ繧貞性繧??蜷医?縲√ム繝悶Ν繧ｳ繝ｼ繝??繧ｷ繝ｧ繝ｳ("") 縺ｧ諡ｬ縺｣縺ｦ荳九＆縺??
056     * 蠑墓焚譁?ｭ怜?縺ｮ 縲?縲上?蜑榊ｾ後↓縺ｯ縲∫ｩｺ逋ｽ縺ｯ謖溘ａ縺ｾ縺帙ｓ縲ょｿ?★縲?key=value 縺ｮ讒倥↓
057     * 郢九￡縺ｦ縺上□縺輔＞縲?
058     *
059     * @og.formSample
060     *  SFTPConnect -host=SFTP繧ｵ繝ｼ繝舌? -user=繝ｦ繝ｼ繧ｶ繝ｼ -passwd=繝代せ繝ｯ繝ｼ繝?-remoteFile=SFTP蜈医?繝輔ぃ繧､繝ｫ蜷?[-localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷江
061     *                   [-mode=[ASCII/BINARY]  ] [-command=[GET/PUT/DEL/GETDIR/PUTDIR/DELDIR] ] [-passive=[true/false] ]
062     *
063     *    -host=SFTP繧ｵ繝ｼ繝舌?                ?壽磁邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?縺ｮ繧｢繝峨Ξ繧ｹ縺ｾ縺溘?縲√し繝ｼ繝舌?蜷?
064     *    -user=繝ｦ繝ｼ繧ｶ繝ｼ                    ?壽磁邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ蜷?
065     *    -remoteFile=SFTP蜈医?繝輔ぃ繧､繝ｫ蜷?   ?壽磁邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?PUT,GET 髢｢菫ゅ↑縺輯FTP蛛ｴ縺ｨ縺励※謖?ｮ壹＠縺ｾ縺吶?
066     *   [-passwd=繝代せ繝ｯ繝ｼ繝云               ?壽磁邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ縺ｮ繝代せ繝ｯ繝ｼ繝?
067     *   [-localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷江  ?壹Ο繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?PUT,GET 髢｢菫ゅ↑縺上Ο繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧呈欠螳壹＠縺ｾ縺吶?
068     *   [-port=繝昴?繝?]                    ?壽磁邯壹☆繧九し繝ｼ繝舌?縺ｮ繝昴?繝医ｒ謖?ｮ壹＠縺ｾ縺吶?
069     *   [-keyFile=遘伜ｯ?く繝ｼ繝輔ぃ繧､繝ｫ ]       ?壼?髢九く繝ｼ證怜捷蛹匁婿蠑上ｒ蛻ｩ逕ｨ縺吶ｋ蝣ｴ蜷医?繧ｭ繝ｼ繝輔ぃ繧､繝ｫ蜷阪ｒ謖?ｮ壹＠縺ｾ縺吶?
070     *   [-command=[GET/PUT/DEL] ]          ?售FTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｧ縺ｮ蜃ｦ逅??譁ｹ豕輔ｒ謖?ｮ壹＠縺ｾ縺吶?
071     *             [GETDIR/PUTDIR/DELDIR]]          GET:SFTP竍鱈OCAL縲￣UT:LOCAL竍担FTP 縺ｸ縺ｮ霆｢騾√〒縺?蛻晄悄蛟､:GET)
072     *                                              DEL:SFTP繝輔ぃ繧､繝ｫ繧貞炎髯､縺励∪縺吶?
073     *                                              GETDIR,PUTDIR,DELDIR 謖?ｮ壹?繝輔か繝ｫ繝?ｻ･荳九?繝輔ぃ繧､繝ｫ繧貞?逅?＠縺ｾ縺吶?
074     *   [-mkdirs=[true/false]  ]           ?壼女縺大?繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?SFTP繧ｵ繝ｼ繝舌?)縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°(蛻晄悄蛟､:true)
075     *                                              (false:繝?ぅ繝ｬ繧ｯ繝医Μ縺檎┌縺代ｌ縺ｰ縲√お繝ｩ繝ｼ縺ｫ縺励∪縺吶?)
076     *   [-timeout=繧ｿ繧､繝?い繧ｦ繝?遘綻 ]       ?咼ata繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:600 [遘綻)
077     *   [-display=[false/true] ]           ?嗾rue縺ｯ縲∵､懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺励∪縺?蛻晄悄蛟､:false)
078     *   [-debug=[false|true]   ]           ?壹ョ繝舌ャ繧ｰ諠??繧呈ｨ呎ｺ門?蜉帙↓陦ｨ遉ｺ縺吶ｋ(true)縺九＠縺ｪ縺?false)縺?蛻晄悄蛟､:false[陦ｨ遉ｺ縺励↑縺Ь)
079     *
080     * @og.rev 5.1.6.0 (2010/05/01) 譁ｰ隕剰ｿｽ蜉?
081     *
082     * @version  5.0
083     * @author       Kazuhiko Hasegawa
084     * @since    JDK5.0,
085     */
086    public final class SFTPConnect extends AbstractConnect {
087            private final JSch jsch;
088    
089            private static final int DEF_PORT       = 22;                   // 繝昴?繝?
090    
091            private boolean isConnect       = false;                // 繧ｳ繝阪け繝域ｸ医∩縺九←縺?°縲?
092    
093            private String  lastRemoteDir   = "/";          // SFTP蜈医?譛?ｾ後↓逋ｻ骭ｲ縺励◆繝輔か繝ｫ繝?錐(mkdir 縺ｮ鬮倬?蛹悶?縺溘ａ)
094            private String  keyFile                 = null;         // 蜈ｬ髢九く繝ｼ證怜捷蛹匁婿蠑上ｒ蛻ｩ逕ｨ縺吶ｋ蝣ｴ蜷医?繧ｭ繝ｼ繝輔ぃ繧､繝ｫ蜷阪ｒ謖?ｮ壹＠縺ｾ縺吶?
095    
096            private Session         session = null;
097            private ChannelSftp channel     = null;
098    
099            /**
100             * 繝?ヵ繧ｩ繝ｫ繝医さ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ
101             */
102            public SFTPConnect() {
103                    jsch = new JSch();
104            }
105    
106            /**
107             * SFTP繧ｵ繝ｼ繝舌?縺ｸ縺ｮ謗･邯壹?繝ｭ繧ｰ繧､繝ｳ繧定｡後＞縺ｾ縺吶?
108             *
109             * 縺薙?繝｡繧ｽ繝?ラ縺ｯ縲∝?譛溷喧繝｡繧ｽ繝?ラ縺ｧ縺吶?
110             * SFTP繧ｵ繝ｼ繝舌?縺ｸ縺ｮ謗･邯壹?繝ｭ繧ｰ繧､繝ｳ繧定｡後＞縺ｾ縺吶?縺ｧ縲∬､?焚繝輔ぃ繧､繝ｫ繧定ｻ｢騾√☆繧?
111             * 繧ｱ繝ｼ繧ｹ縺ｧ縺ｯ縲∵怙蛻昴↓?大ｺｦ縺?￠蜻ｼ縺ｳ蜃ｺ縺吶□縺代〒縺吶?
112             * 謗･邯壼?繧貞､画峩縺吶ｋ蝣ｴ蜷医?縲√ｂ縺?ｸ?ｺｦ縺薙?繝｡繧ｽ繝?ラ繧偵さ繝ｼ繝ｫ縺吶ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?
113             * (縺昴?繧医≧縺ｪ蝣ｴ蜷医?縲??蟶ｸ縲√が繝悶ず繧ｧ繧ｯ繝医ｒ讒狗ｯ峨＠縺ｪ縺翫☆譁ｹ縺後ｈ縺?→諤昴＞縺ｾ縺吶?)
114             *
115             */
116            @Override
117            public void connect() {
118                    if( isDisplay ) { System.out.println( "CONNECT: HOST=" + host + ",USER=" + user + ",PORT=" + port ); }
119    
120                    // 繧ゅ＠縲√☆縺ｧ縺ｫ謗･邯壹＆繧後※縺?◆蝣ｴ蜷医?縲√け繝ｭ繝ｼ繧ｹ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
121                    if( isConnect ) { disconnect(); }
122    
123                    // HostKey繝√ぉ繝?け繧定｡後ｏ縺ｪ縺?
124                    Hashtable<String,String> config = new Hashtable<String,String>();
125                    config.put( "StrictHostKeyChecking", "no" );
126                    JSch.setConfig( config );
127    
128                    // 繧ｵ繝ｼ繝舌?縺ｫ蟇ｾ縺励※謗･邯壹ｒ陦後＞縺ｾ縺吶?
129                    try {
130                            if( keyFile == null ) {
131                                    // 繝代せ繝ｯ繝ｼ繝芽ｪ崎ｨｼ
132                                    session=jsch.getSession( user, host, getPort( DEF_PORT ) );
133                                    session.setPassword( passwd );
134                            }
135                            else {
136                                    // 蜈ｬ髢九く繝ｼ縲∫ｧ伜ｯ?く繝ｼ隱崎ｨｼ
137                                    jsch.addIdentity( keyFile );
138                                    session=jsch.getSession( user, host, getPort( DEF_PORT ) );
139                    //              session.setUserInfo(new MyUserInfo());
140                            }
141    
142                            session.connect( timeout*1000 );                // 繧ｿ繧､繝?い繧ｦ繝医?險ｭ螳?
143    
144                            channel=(ChannelSftp)session.openChannel("sftp");
145                            channel.connect();
146                    }
147                    catch ( JSchException ex ) {
148                            errAppend( "SFTP server refused connection. " );
149                            errAppend( "   host    = [" , host      , "]" );
150                            errAppend( "   user    = [" , user      , "]" );
151                            errAppend( "   port    = [" , port      , "]" );
152                            errAppend( ex );
153                            if( isDebug ) { ex.printStackTrace(); }
154                            disconnect();
155                            throw new RuntimeException( getErrMsg(),ex );
156                    }
157    
158                    isConnect = true;
159            }
160    
161            /**
162             * SFTP繧ｵ繝ｼ繝舌?縺ｨ縺ｮ謗･邯壹ｒ繧ｯ繝ｭ繝ｼ繧ｺ縺励∪縺吶?
163             *
164             * 繝ｭ繧ｰ繧､繝ｳ縺輔ｌ縺ｦ縺?ｋ蝣ｴ蜷医?縲√Ο繧ｰ繧｢繧ｦ繝医ｂ陦後＞縺ｾ縺吶?
165             * 繧ｳ繝阪け繝医＆繧後※縺?ｋ蝣ｴ蜷医?縲√ョ繧｣繧ｹ繧ｳ繝阪け繝医＠縺ｾ縺吶?
166             *
167             */
168            @Override
169            public void disconnect() {
170                    if( isDisplay ) { System.out.println( "DISCONNECT:" ); }
171    
172                    if( isConnect ) {
173                            isConnect = false;
174                            try {
175                                    channel.disconnect();
176                                    session.disconnect();
177                            }
178                            catch( Throwable th ) {
179                                    errAppend( "disconnect Error." );
180                                    errAppend( th );
181                                    if( isDebug ) { th.printStackTrace(); }
182                                    throw new RuntimeException( getErrMsg(),th );
183                            }
184                    }
185            }
186    
187            /**
188             * command="GET" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
189             *
190             * 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧偵?謗･邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｫ繧｢繝??繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
191             *
192             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
193             * @param       remoteFile      SFTP蜈医?繝輔ぃ繧､繝ｫ蜷?
194             * @throws  JSchException JSCH繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溘→縺?
195             * @throws  SftpException SFTP繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溘→縺?
196             * @throws  IOException  蜈･蜃ｺ蜉帙お繝ｩ繝ｼ縺檎匱逕溘＠縺溘→縺?
197             */
198            @Override
199            protected void actionGET( final String localFile, final String remoteFile ) throws JSchException, SftpException, IOException {
200                    if( isDebug ) { System.out.println( "GET: " + remoteFile + " => " + localFile ); }
201    
202                    // GET(DOWNLOAD)蜿門ｾ玲凾縺ｯ縲√Ο繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ蠢?ｦ√′縺ゅｋ縲?
203                    if( isMkdirs ) {
204                            makeLocalDir( localFile );
205                    }
206    
207                    channel.get( remoteFile,localFile );
208            }
209    
210            /**
211             * command="GETDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
212             *
213             * 謗･邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ莉･荳九ｒ繝ｭ繝ｼ繧ｫ繝ｫ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｫ髫主ｱ､讒矩?縺ｮ縺ｾ縺ｾ繝?え繝ｳ繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
214             *
215             * @param       localDir        繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
216             * @param       remoteDir       SFTP蜈医?繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
217             * @throws  JSchException JSCH繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溘→縺?
218             * @throws  SftpException SFTP繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溘→縺?
219             * @throws  IOException  蜈･蜃ｺ蜉帙お繝ｩ繝ｼ縺檎匱逕溘＠縺溘→縺?
220             */
221            @Override
222            protected void actionGETdir( final String localDir, final String remoteDir )  throws IOException,JSchException,SftpException {
223                    Vector<?> list = channel.ls( remoteDir );
224                    for (int i=0;i<list.size();i++) {
225                            LsEntry entry = (LsEntry)list.get(i);
226                            String rmt = entry.getFilename();
227                            if( ".".equals( rmt ) || "..".equals( rmt ) ) { continue; }             // "." 縺ｧ蟋九∪繧九ヵ繧｡繧､繝ｫ繧ゅ≠繧九?縺ｧ縲‘quasl 蛻､螳?
228                            SftpATTRS stat = entry.getAttrs();
229                            if( stat.isDir() ) {
230                                    actionGETdir( addFile( localDir,rmt ),addFile( remoteDir,rmt ) );
231                            }
232                            else {
233                                    actionGET( addFile( localDir,rmt ),addFile( remoteDir,rmt ) );
234                            }
235                    }
236            }
237    
238            /**
239             * command="PUT" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
240             *
241             * 謗･邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪ｒ繝ｭ繝ｼ繧ｫ繝ｫ縺ｫ繝?え繝ｳ繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
242             *
243             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
244             * @param       remoteFile      SFTP蜈医?繝輔ぃ繧､繝ｫ蜷?
245             * @throws JSchException 蜃ｦ逅?ｸｭ縺ｫ JSch 繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷?
246             * @throws SftpException 蜃ｦ逅?ｸｭ縺ｫ Sftp 繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷?
247             */
248            @Override
249            protected void actionPUT( final String localFile, final String remoteFile ) throws JSchException,SftpException {
250                    if( isDebug ) { System.out.println( "PUT: " + localFile + " => " + remoteFile ); }
251    
252                    // PUT(UPLOAD)逋ｻ骭ｲ譎ゅ?縲√Μ繝｢繝ｼ繝医ヵ繧｡繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ蠢?ｦ√′縺ゅｋ縲?
253                    if( isMkdirs ) {
254                            // 蜑榊屓縺ｮDIR縺ｨ縺ｮ豈碑ｼ?〒縲√☆縺ｧ縺ｫ蟄伜惠縺励※縺?ｌ縺ｰ縲［akeDirectory 蜃ｦ逅?ｒ繝代せ縺吶ｋ縲?
255                            int ad = remoteFile.lastIndexOf( '/' ) + 1;             // 蛹ｺ蛻?ｊ譁?ｭ励ｒ?具ｼ代☆繧九?
256                            String tmp = remoteFile.substring( 0,ad );
257    
258                            if( ad > 0 && !lastRemoteDir.startsWith( tmp ) ) {
259                                    lastRemoteDir = tmp;
260                                    if( remoteFile.startsWith( "/" ) ) {
261                                            String[] fls = remoteFile.split( "/" );
262                                            channel.cd( "/" );
263                                            for( int i=1; i<fls.length-1; i++ ) {
264                                                    try {
265                            //                              SftpATTRS stat = channel.lstat(fls[i]);         // 蟄伜惠縺励↑縺?→縲ヾftpException
266                                                            channel.cd( fls[i] );                                           // 蟄伜惠縺励↑縺?→縲ヾftpException
267                                                            continue;
268                                                    } catch (SftpException ex) {
269                                                            // 繝輔ぃ繧､繝ｫ縺悟ｭ伜惠縺励↑縺?→縺?
270                                                            channel.mkdir( fls[i] );
271                                                            channel.cd( fls[i] );
272                                                    }
273                                            }
274                                    }
275                            }
276                    }
277    
278                    channel.put( localFile,remoteFile );
279            }
280    
281            /**
282             * command="DEL" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
283             *
284             * 謗･邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪ｒ蜑企勁縺励∪縺吶?
285             *
286             * @param       remoteFile      SFTP蜈医?繝輔ぃ繧､繝ｫ蜷?
287             * @throws SftpException SFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?蜑企勁縺ｫ螟ｱ謨励＠縺溘→縺?
288             */
289            @Override
290            protected void actionDEL( final String remoteFile ) throws SftpException {
291                    if( isDebug ) { System.out.println( "DEL: " + remoteFile ); }
292    
293                    channel.rm( remoteFile );
294            }
295    
296            /**
297             * command="DELDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
298             *
299             * 謗･邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷阪ｒ蜑企勁縺励∪縺吶?
300             *
301             * @param       remoteDir       SFTP蜈医?繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
302             * @throws SftpException SFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷阪?蜑企勁縺ｫ螟ｱ謨励＠縺溘→縺?
303             */
304            @Override
305            protected void actionDELdir( final String remoteDir ) throws SftpException {
306    
307                    Vector<?> list = channel.ls( remoteDir );
308                    for (int i=0;i<list.size();i++) {
309                            LsEntry entry = (LsEntry)list.get(i);
310                            String rmt = entry.getFilename();
311                            if( ".".equals( rmt ) || "..".equals( rmt ) ) { continue; }             // "." 縺ｧ蟋九∪繧九ヵ繧｡繧､繝ｫ繧ゅ≠繧九?縺ｧ縲‘quasl 蛻､螳?
312                            SftpATTRS stat = entry.getAttrs();
313                            if( stat.isDir() ) {
314                                    actionDELdir( addFile( remoteDir,rmt ) );
315                            }
316                            else {
317                                    actionDEL( addFile( remoteDir,rmt ) );
318    //                              channel.rm( addFile( remoteDir,rmt ) );
319                            }
320                    }
321                    channel.rmdir( remoteDir );
322            }
323    
324            /**
325             * 蜈ｬ髢九く繝ｼ證怜捷蛹匁婿蠑上ｒ蛻ｩ逕ｨ縺吶ｋ蝣ｴ蜷医?繧ｭ繝ｼ繝輔ぃ繧､繝ｫ蜷阪ｒ謖?ｮ壹＠縺ｾ縺吶?
326             *
327             * @param       keyFile 遘伜ｯ?く繝ｼ繝輔ぃ繧､繝ｫ蜷?
328             */
329            public void setKeyFile( final String keyFile ) {
330                    if( keyFile != null ) {
331                            this.keyFile = keyFile ;
332                    }
333            }
334    
335    //      private static class MyUserInfo implements UserInfo {
336    //              public String getPassword() {
337    //                      return null;
338    //              }
339    //              // 繝代せ繝輔Ξ繝ｼ繧ｺ縺ｯ遨ｺ
340    //              public String getPassphrase() {
341    //                      return "";
342    //              }
343    //              public boolean promptPassword(String arg0) {
344    //                      return true;
345    //              }
346    //              public boolean promptPassphrase(String arg0) {
347    //                      return true;
348    //              }
349    //              public boolean promptYesNo(String arg0) {
350    //                      return true;
351    //              }
352    //              public void showMessage(String arg0) {
353    //              }
354    //      }
355    
356    // ******************************************************************************************************* //
357    //       莉･荳九?蜊倡峡縺ｧ菴ｿ逕ｨ縺吶ｋ蝣ｴ蜷医? main蜃ｦ逅?
358    // ******************************************************************************************************* //
359    
360            private static final Map<String,String> mustProparty   ;          // ?ｻ繝励Ο繝代ユ繧｣?ｽ蠢??繝√ぉ繝?け逕ｨ Map
361            private static final Map<String,String> usableProparty ;          // ?ｻ繝励Ο繝代ユ繧｣?ｽ謨ｴ蜷域?繝√ぉ繝?け Map
362    
363            static {
364                    mustProparty = new LinkedHashMap<String,String>();
365                    mustProparty.put( "host",               "謗･邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?縺ｮ繧｢繝峨Ξ繧ｹ縺ｾ縺溘?縲√し繝ｼ繝舌?蜷?蠢??)" );
366                    mustProparty.put( "user",               "謗･邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ蜷?蠢??)" );
367                    mustProparty.put( "remoteFile", "謗･邯壼?縺ｮSFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷?蠢??)" );
368    
369                    usableProparty = new LinkedHashMap<String,String>();
370                    usableProparty.put( "passwd",           "謗･邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ縺ｮ繝代せ繝ｯ繝ｼ繝? );
371                    usableProparty.put( "localFile",        "繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷? );
372                    usableProparty.put( "port",                     "謗･邯壹↓蛻ｩ逕ｨ縺吶ｋ繝昴?繝育分蜿ｷ繧定ｨｭ螳壹＠縺ｾ縺吶?" );
373                    usableProparty.put( "keyFile",          "蜈ｬ髢九く繝ｼ證怜捷蛹匁婿蠑上ｒ蛻ｩ逕ｨ縺吶ｋ蝣ｴ蜷医?繧ｭ繝ｼ繝輔ぃ繧､繝ｫ蜷阪ｒ謖?ｮ壹＠縺ｾ縺吶?" );
374                    usableProparty.put( "command",          "SFTP繧ｵ繝ｼ繝舌?蛛ｴ縺ｧ縺ｮ蜃ｦ逅??譁ｹ豕?GET/PUT/DEL)繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:GET)" );
375                    usableProparty.put( "mkdirs",           "蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?SFTP繧ｵ繝ｼ繝舌?)縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°(蛻晄悄蛟､:true)" );
376                    usableProparty.put( "timeout",          "Data繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:600 [遘綻)" );
377                    usableProparty.put( "display",          "[false/true]:true縺ｯ縲∵､懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺励∪縺?蛻晄悄蛟､:false)" );
378                    usableProparty.put( "debug",            "繝?ヰ繝?げ諠??繧呈ｨ呎ｺ門?蜉帙↓陦ｨ遉ｺ縺吶ｋ(true)縺九＠縺ｪ縺?false)縺? +
379                                                                                            CR + "(蛻晄悄蛟､:false:陦ｨ遉ｺ縺励↑縺?" );
380            }
381    
382            private static final String[] CMD_LST  = new String[] { "GET","PUT","DEL","GETDIR","PUTDIR","DELDIR" };
383    
384            /**
385             * 縺薙?繧ｯ繝ｩ繧ｹ縺ｮ蜍穂ｽ懃｢ｺ隱咲畑縺ｮ縲［ain 繝｡繧ｽ繝?ラ縺ｧ縺吶?
386             *
387             * @param       args    繧ｳ繝槭Φ繝牙ｼ墓焚驟榊?
388             */
389            public static void main( final String[] args ) {
390                    Argument arg = new Argument( "org.opengion.fukurou.util.SFTPConnect" );
391                    arg.setMustProparty( mustProparty );
392                    arg.setUsableProparty( usableProparty );
393                    arg.setArgument( args );
394    
395                    SFTPConnect sftp = new SFTPConnect();
396    
397                    String host   = arg.getProparty( "host");                       // SFTP繧ｵ繝ｼ繝舌?
398                    String user   = arg.getProparty( "user" );                      // 繝ｦ繝ｼ繧ｶ繝ｼ
399                    String passwd = arg.getProparty( "passwd" );            // 繝代せ繝ｯ繝ｼ繝?
400    
401                    sftp.setHostUserPass( host , user , passwd );
402    
403                    sftp.setPort(           arg.getProparty( "port"                                 ) );    // 謗･邯壹↓蛻ｩ逕ｨ縺吶ｋ繝昴?繝育分蜿ｷ繧定ｨｭ螳壹＠縺ｾ縺吶?
404                    sftp.setKeyFile(        arg.getProparty( "keyFile"                              ) );    // 蜈ｬ髢九く繝ｼ證怜捷蛹匁婿蠑上ｒ蛻ｩ逕ｨ縺吶ｋ蝣ｴ蜷医?繧ｭ繝ｼ繝輔ぃ繧､繝ｫ蜷阪ｒ謖?ｮ壹＠縺ｾ縺吶?
405                    sftp.setMkdirs(         arg.getProparty( "mkdirs"       ,true           ) );    // 蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°
406                    sftp.setTimeout(        arg.getProparty( "timeout"      ,TIMEOUT        ) );    // Data繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:600 [遘綻)
407                    sftp.setDisplay(        arg.getProparty( "display"      ,false          ) );    // true縺ｯ縲∵､懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺励∪縺?蛻晄悄蛟､:false)
408                    sftp.setDebug(          arg.getProparty( "debug"        ,false          ) );    // 繝?ヰ繝?げ諠??繧呈ｨ呎ｺ門?蜉帙↓陦ｨ遉ｺ縺吶ｋ(true)縺九＠縺ｪ縺?false)縺?
409    
410                    try {
411                            // 繧ｳ繝阪け繝医＠縺ｾ縺吶?
412                            sftp.connect();
413    
414                            String command          = arg.getProparty( "command" ,"GET" ,CMD_LST  );        // SFTP蜃ｦ逅??譁ｹ豕輔ｒ謖?ｮ壹＠縺ｾ縺吶?
415                            String localFile        = arg.getProparty( "localFile"  );                                      // 繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
416                            String remoteFile       = arg.getProparty( "remoteFile" );                                      // SFTP蜈医?繝輔ぃ繧､繝ｫ蜷?
417    
418                            // command , localFile , remoteFile 繧貞?縺ｫ縲ヾFTP蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
419                            sftp.action( command,localFile,remoteFile );
420                    }
421                    catch( RuntimeException ex ) {
422                            System.err.println( sftp.getErrMsg() );
423                    }
424                    finally {
425                            // 繝帙せ繝医→縺ｮ謗･邯壹ｒ邨ゆｺ?＠縺ｾ縺吶?
426                            sftp.disconnect();
427                    }
428            }
429    }