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.File;
019    import java.io.IOException;
020    
021    /**
022     * AbstractConnect.java 縺ｯ縲∝?騾夂噪縺ｫ菴ｿ逕ｨ縺輔ｌ繧?繝輔ぃ繧､繝ｫ莨晞?髢｢騾｣縺ｮ蝓ｺ譛ｬ讖溯?繧貞ｮ溯｣?＠縺溘?Abstract繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
023     *
024     * -host=繧ｵ繝ｼ繝舌? -user=繝ｦ繝ｼ繧ｶ繝ｼ -passwd=繝代せ繝ｯ繝ｼ繝?-remoteFile=謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?繧貞ｿ??險ｭ螳壹＠縺ｾ縺吶?
025     * -localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?縲∝ｿ??縺ｧ縺ｯ縺ゅｊ縺ｾ縺帙ｓ縺後?-command=DEL 縺ｮ蝣ｴ蜷医↓縺ｮ縺ｿ荳崎ｦ√〒縺ゅｊ縲?
026     * 縺昴ｌ莉･螟悶? command 縺ｮ蝣ｴ蜷医?縲∝ｿ?ｦ√〒縺吶?
027     *
028     * -command=[GET/PUT/DEL/GETDIR/PUTDIR/DELDIR] 縺ｯ縲√し繝ｼ繝舌?縺ｫ蟇ｾ縺励※縺ｮ蜃ｦ逅??譁ｹ豕輔ｒ謖?ｮ壹＠縺ｾ縺吶?
029     *   GET:繧ｵ繝ｼ繝舌?縺九ｉ繝ｭ繝ｼ繧ｫ繝ｫ縺ｫ繝輔ぃ繧､繝ｫ霆｢騾√＠縺ｾ縺?蛻晄悄蛟､)
030     *   PUT:繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧偵し繝ｼ繝舌?縺ｫ PUT(STORE縲ヾAVE縲ゞPLOAD縲√↑縺ｩ縺ｨ蜷梧э隱?縺励∪縺吶?
031     *   DEL:繧ｵ繝ｼ繝舌?縺ｮ謖?ｮ壹?繝輔ぃ繧､繝ｫ繧貞炎髯､縺励∪縺吶?縺薙?蝣ｴ蜷医?縺ｿ縲?localFile 螻樊?縺ｮ謖?ｮ壹?荳崎ｦ√〒縺吶?
032     *   GETDIR,PUTDIR,DELDIR:謖?ｮ壹?繝輔か繝ｫ繝?ｻ･荳九?繝輔ぃ繧､繝ｫ繧貞?逅?＠縺ｾ縺吶?
033     *
034     * -mkdirs=[true/false] 縺ｯ縲∝女縺大?縺ｮ繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?繧ｵ繝ｼ繝舌?)縺ｫ蜿悶ｊ霎ｼ繧?ヵ繧｡繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺?
035     * 蟄伜惠縺励↑縺??蜷医↓縲∽ｽ懈?縺吶ｋ縺九←縺?°繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:true)
036     * 騾壼ｸｸ縲√し繝ｼ繝舌?縺ｫ縲√ヵ繧ｩ繝ｫ繝?嚴螻､繧剃ｽ懈?縺励※PUT縺吶ｋ蝣ｴ蜷医?蜍慕噪縺ｫ繝輔か繝ｫ繝?嚴螻､繧剃ｽ懈?縺励◆縺?こ繝ｼ繧ｹ縺ｧ萓ｿ蛻ｩ縺ｧ縺吶?
037     * 騾?↓縲√ヵ繧ｩ繝ｫ繝??遒ｺ螳壹＠縺ｦ縺翫ｊ縲∵欠螳壹ヵ繧ｩ繝ｫ繝?ｻ･螟悶↓ PUT 縺吶ｋ縺ｮ縺ｯ繝舌げ縺｣縺ｦ縺?ｋ縺ｨ莠九′蛻?°縺｣縺ｦ縺?ｋ蝣ｴ蜷医↓縺ｯ
038     * false 縺ｫ險ｭ螳壹＠縺ｦ縲∝ｭ伜惠縺励↑縺?ヵ繧ｩ繝ｫ繝?↓PUT 縺励ｈ縺?→縺吶ｋ縺ｨ縲√お繝ｩ繝ｼ縺ｫ縺ｪ繧九ｈ縺?↓縺励∪縺吶?
039     *
040     * 蠑墓焚譁?ｭ怜?荳ｭ縺ｫ遨ｺ逋ｽ繧貞性繧??蜷医?縲√ム繝悶Ν繧ｳ繝ｼ繝??繧ｷ繝ｧ繝ｳ("") 縺ｧ諡ｬ縺｣縺ｦ荳九＆縺??
041     * 蠑墓焚譁?ｭ怜?縺ｮ 縲?縲上?蜑榊ｾ後↓縺ｯ縲∫ｩｺ逋ｽ縺ｯ謖溘ａ縺ｾ縺帙ｓ縲ょｿ?★縲?key=value 縺ｮ讒倥↓
042     * 郢九￡縺ｦ縺上□縺輔＞縲?
043     *
044     * @og.formSample
045     *  XXXConnect -host=繧ｵ繝ｼ繝舌? -user=繝ｦ繝ｼ繧ｶ繝ｼ -passwd=繝代せ繝ｯ繝ｼ繝?-remoteFile=謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?[-localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷江
046     *                   [-command=[GET/PUT/DEL/GETDIR/PUTDIR/DELDIR] ] [-display=[true/false] ] 繝ｻ繝ｻ繝ｻ繝ｻ
047     *
048     *    -host=繧ｵ繝ｼ繝舌?                    ?壽磁邯壼?縺ｮ繧ｵ繝ｼ繝舌?縺ｮ繧｢繝峨Ξ繧ｹ縺ｾ縺溘?縲√し繝ｼ繝舌?蜷?
049     *    -user=繝ｦ繝ｼ繧ｶ繝ｼ                    ?壽磁邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ蜷?
050     *    -passwd=繝代せ繝ｯ繝ｼ繝?               ?壽磁邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ縺ｮ繝代せ繝ｯ繝ｼ繝?
051     *    -remoteFile=謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?   ?壽磁邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?PUT,GET 髢｢菫ゅ↑縺洲TP蛛ｴ縺ｨ縺励※謖?ｮ壹＠縺ｾ縺吶?
052     *   [-localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷江  ?壹Ο繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?PUT,GET 髢｢菫ゅ↑縺上Ο繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧呈欠螳壹＠縺ｾ縺吶?
053     *   [-port=繝昴?繝?]                    ?壽磁邯壹☆繧九し繝ｼ繝舌?縺ｮ繝昴?繝医ｒ謖?ｮ壹＠縺ｾ縺吶?
054     *   [-command=[GET/PUT/DEL] ]          ?壹し繝ｼ繝舌?蛛ｴ縺ｧ縺ｮ蜃ｦ逅??譁ｹ豕輔ｒ謖?ｮ壹＠縺ｾ縺吶?
055     *             [GETDIR/PUTDIR/DELDIR]]          GET:FTP竍鱈OCAL縲￣UT:LOCAL竍巽TP 縺ｸ縺ｮ霆｢騾√〒縺?蛻晄悄蛟､:GET)
056     *                                              DEL:FTP繝輔ぃ繧､繝ｫ繧貞炎髯､縺励∪縺吶?
057     *                                              GETDIR,PUTDIR,DELDIR 謖?ｮ壹?繝輔か繝ｫ繝?ｻ･荳九?繝輔ぃ繧､繝ｫ繧貞?逅?＠縺ｾ縺吶?
058     *   [-mkdirs=[true/false]  ]           ?壼女縺大?繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?繧ｵ繝ｼ繝舌?)縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°(蛻晄悄蛟､:true)
059     *                                              (false:繝?ぅ繝ｬ繧ｯ繝医Μ縺檎┌縺代ｌ縺ｰ縲√お繝ｩ繝ｼ縺ｫ縺励∪縺吶?)
060     *   [-encode=繧ｨ繝ｳ繧ｳ繝ｼ繝牙錐 ]            ?壽律譛ｬ隱槭ヵ繧｡繧､繝ｫ蜷阪↑縺ｩ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝牙錐繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:Windows-31J)
061     *   [-timeout=繧ｿ繧､繝?い繧ｦ繝?遘綻 ]       ?咼ata繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:600 [遘綻)
062     *   [-display=[false/true] ]           ?嗾rue縺ｯ縲∵､懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺励∪縺?蛻晄悄蛟､:false)
063     *   [-debug=[false|true]   ]           ?壹ョ繝舌ャ繧ｰ諠??繧呈ｨ呎ｺ門?蜉帙↓陦ｨ遉ｺ縺吶ｋ(true)縺九＠縺ｪ縺?false)縺?蛻晄悄蛟､:false[陦ｨ遉ｺ縺励↑縺Ь)
064     *
065     * @og.rev 5.1.6.0 (2010/05/01) 譁ｰ隕剰ｿｽ蜉?
066     *
067     * @version  5.0
068     * @author       Kazuhiko Hasegawa
069     * @since    JDK5.0,
070     */
071    public abstract class AbstractConnect implements ConnectIF {
072            public static final String CR = System.getProperty("line.separator");
073            private final StringBuilder errMsg = new StringBuilder( 200 );
074    
075            /** 豁｣蟶ｸ繝輔Λ繧ｰ  {@value} */
076            public static final boolean FLAG_OK = true;
077            /** 逡ｰ蟶ｸ繝輔Λ繧ｰ  {@value} */
078            public static final boolean FLAG_NG = false;
079            /** Data繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:{@value} [遘綻) */
080            public static final int         TIMEOUT = 600 ;
081    
082            /** 繧ｵ繝ｼ繝舌? */
083            protected String        host            = null;                 // 繧ｵ繝ｼ繝舌?
084            /** 繝ｦ繝ｼ繧ｶ繝ｼ */
085            protected String        user            = null;                 // 繝ｦ繝ｼ繧ｶ繝ｼ
086            /** 繝代せ繝ｯ繝ｼ繝?*/
087            protected String        passwd          = null;                 // 繝代せ繝ｯ繝ｼ繝?
088            /** 繝昴?繝?*/
089            protected String        port            = null;                 // 繝昴?繝?
090    
091            /** 繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?° */
092            protected boolean       isMkdirs        = true;                 // 蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°縲Ｕrue:菴懈?縺吶ｋ / false:辟｡縺代ｌ縺ｰ繧ｨ繝ｩ繝ｼ
093            /** Data繧ｿ繧､繝?い繧ｦ繝? */
094            protected int           timeout         = TIMEOUT;              // Data繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:600 [遘綻)
095            /** 讀懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺吶ｋ縺九←縺?°  */
096            protected boolean       isDisplay       = false;                // true縺ｯ縲∵､懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺励∪縺?蛻晄悄蛟､:false)
097            /** 繝?ヰ繝?げ諠??繧定｡ｨ遉ｺ縺吶ｋ縺九←縺?°  */
098            protected boolean       isDebug         = false;                // 繝?ヰ繝?げ諠??繧呈ｨ呎ｺ門?蜉帙↓陦ｨ遉ｺ縺吶ｋ(true)縺九＠縺ｪ縺?false)縺?
099    
100            /**
101             * 繧ｵ繝ｼ繝舌?縺ｸ縺ｮ謗･邯壹?繝ｭ繧ｰ繧､繝ｳ繧定｡後＞縺ｾ縺吶?
102             */
103            @Override
104            public abstract void connect() ;
105    
106            /**
107             * command , localFile , remoteFile 繧貞?縺ｫ縲：TP蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
108             *
109             * 縺薙?繝｡繧ｽ繝?ラ縺ｯ縲…onnect( String , String , String )繝｡繧ｽ繝?ラ縲√♀繧医?縲?
110             * paramInit() 螳溯｡悟ｾ後↓縲∝他縺ｳ蜃ｺ縺吝ｿ?ｦ√′縺ゅｊ縺ｾ縺吶?
111             *
112             * 窶ｻ 蜀?Κ縺ｧ縲…ommand 縺ｫ謖?ｮ壹〒縺阪↑縺??繧偵そ繝?ヨ縺励◆縺九?菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
113             *
114             * @param       command GET:HOST竍鱈OCAL 縲￣UT:LOCAL竍辿OST 縲．EL:HOST繝輔ぃ繧､繝ｫ繧貞炎髯､
115             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
116             * @param       remoteFile      HOST謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
117             */
118            @Override
119            public void action( final String command, final String localFile, final String remoteFile ) {
120                    String rmtFile = remoteFile.replace( '\\','/' );
121                    if( isDisplay ) {
122                            System.out.println( "ACTION: command=" + command + ",localFile=" + localFile + ",remoteFile=" + rmtFile );
123                    }
124    
125                    try {
126                            // 螳滄圀縺ｮ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?(GET/PUT/DEL)
127                            if( "GET".equals( command ) ) {
128                                    actionGET( localFile, rmtFile );
129                            }
130                            else if( "PUT".equals( command ) ) {
131                                    actionPUT( localFile, rmtFile );
132                            }
133                            else if( "DEL".equals( command ) ) {
134                                    actionDEL( rmtFile );
135                            }
136                            else if( "GETDIR".equals( command ) ) {
137                                    actionGETdir( localFile, rmtFile );
138                            }
139                            else if( "PUTDIR".equals( command ) ) {
140                                    actionPUTdir( localFile, rmtFile );
141                            }
142                            else if( "DELDIR".equals( command ) ) {
143                                    actionDELdir( rmtFile );
144                            }
145                            else {
146                                    errAppend( "command縺ｯ縲；ET/PUT/DEL/GETDIR/PUTDIR/DELDIR 縺九ｉ謖?ｮ壹￥縺?＆縺??" );
147                                    errAppend( "   command    = [" , command , "]" );
148                                    throw new RuntimeException(  getErrMsg() );
149                            }
150                    }
151                    catch( Exception ex ) {
152                            errAppend( "Server action Error." );
153                            errAppend( "   command    = [" , command        , "]" );
154                            errAppend( "   localFile  = [" , localFile      , "]" );
155                            errAppend( "   remoteFile = [" , remoteFile , "]" );
156                            errAppend( ex.getMessage() );
157                            if( isDebug ) { ex.printStackTrace(); }
158                            throw new RuntimeException( getErrMsg(),ex );
159                    }
160            }
161    
162            /**
163             * 繧ｵ繝ｼ繝舌?縺ｨ縺ｮ謗･邯壹ｒ繧ｯ繝ｭ繝ｼ繧ｺ縺励∪縺吶?
164             *
165             * 繝ｭ繧ｰ繧､繝ｳ縺輔ｌ縺ｦ縺?ｋ蝣ｴ蜷医?縲√Ο繧ｰ繧｢繧ｦ繝医ｂ陦後＞縺ｾ縺吶?
166             * 繧ｳ繝阪け繝医＆繧後※縺?ｋ蝣ｴ蜷医?縲√ョ繧｣繧ｹ繧ｳ繝阪け繝医＠縺ｾ縺吶?
167             */
168            @Override
169            public abstract void disconnect();
170    
171            /**
172             * command="GET" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
173             *
174             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪ｒ繝ｭ繝ｼ繧ｫ繝ｫ縺ｫ繝?え繝ｳ繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
175             *
176             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
177             * @param       remoteFile      謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
178             * @throws Exception 菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
179             */
180            protected abstract void actionGET( final String localFile, final String remoteFile ) throws Exception ;
181    
182            /**
183             * command="GETDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
184             *
185             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ莉･荳九ｒ繝ｭ繝ｼ繧ｫ繝ｫ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｫ髫主ｱ､讒矩?縺ｮ縺ｾ縺ｾ繝?え繝ｳ繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
186             *
187             * @param       localDir        繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
188             * @param       remoteDir       謗･邯壼?縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
189             * @throws Exception 菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
190             */
191            protected abstract void actionGETdir( final String localDir, final String remoteDir ) throws Exception ;
192    
193            /**
194             * command="PUT" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
195             *
196             * 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧偵?謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｫ繧｢繝??繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
197             *
198             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
199             * @param       remoteFile      謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
200             * @throws Exception 菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
201             */
202            protected abstract void actionPUT( final String localFile, final String remoteFile ) throws Exception ;
203    
204            /**
205             * command="PUTDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
206             *
207             * 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ莉･荳九ｒ縲∵磁邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｫ髫主ｱ､讒矩?縺ｮ縺ｾ縺ｾ繧｢繝??繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
208             *
209             * @og.rev 5.3.7.0 (2011/07/01) 繝輔か繝ｫ繝?↓繧｢繧ｯ繧ｻ繧ｹ縺ｧ縺阪↑縺??蜷医?縲√お繝ｩ繝ｼ繧定ｿ斐＠縺ｾ縺吶?
210             *
211             * @param       localDir        繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
212             * @param       remoteDir       謗･邯壼?縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
213             * @throws Exception  菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
214             */
215            protected void actionPUTdir( final String localDir, final String remoteDir ) throws Exception {
216                    File[] lclFiles = new File( localDir ).listFiles();
217    
218                    // 5.3.7.0 (2011/07/01) 繝輔か繝ｫ繝?↓繧｢繧ｯ繧ｻ繧ｹ縺ｧ縺阪↑縺??蜷医?縲√お繝ｩ繝ｼ繧定ｿ斐＠縺ｾ縺吶?
219                    if( lclFiles == null ) {
220                            errAppend( "謖?ｮ壹?繝?ぅ繝ｬ繧ｯ繝医Μ縺ｯ縲√い繧ｯ繧ｻ繧ｹ縺ｧ縺阪∪縺帙ｓ縲? );
221                            errAppend( "   localDir   = [" , localDir       , "]" );
222                            throw new RuntimeException( getErrMsg() );
223                    }
224    
225                    for( int i=0; i<lclFiles.length; i++ ) {
226                            String lcl = lclFiles[i].getName();
227                            if( lclFiles[i].isDirectory() ) {
228                                    actionPUTdir( addFile( localDir,lcl ),addFile( remoteDir,lcl ) );
229                            }
230                            else {
231                                    actionPUT( addFile( localDir,lcl ),addFile( remoteDir,lcl ) );
232                            }
233                    }
234            }
235    
236            /**
237             * command="DEL" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
238             *
239             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪ｒ蜑企勁縺励∪縺吶?
240             *
241             * @param       remoteFile      謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
242             * @throws Exception 菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
243             */
244            protected abstract void actionDEL( final String remoteFile ) throws Exception ;
245    
246            /**
247             * command="DELDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
248             *
249             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷阪ｒ蜑企勁縺励∪縺吶?
250             *
251             * @param       remoteDir       謗･邯壼?縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
252             * @throws Exception 菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
253             */
254            protected abstract void actionDELdir( final String remoteDir ) throws Exception ;
255    
256            /**
257             * 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺励∪縺吶?
258             *
259             * 蠑墓焚縺ｮ繝輔ぃ繧､繝ｫ蜷阪?縲√ヵ繧｡繧､繝ｫ蜷阪〒縺吶?菴懈?縺吶ｋ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｯ縲√◎縺ｮ繝輔ぃ繧､繝ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝医?
260             * getParentFile() 縺ｧ蜿門ｾ励＆繧後ｋ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｾ縺ｧ繧剃ｽ懈?縺励∪縺吶?
261             *
262             * 窶ｻ 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｮ菴懈?縺ｫ螟ｱ謨励＠縺溷?蜷医?縲ヽuntimeException 縺?throw 縺輔ｌ縺ｾ縺吶?
263             *
264             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
265             * @throws IOException File#getCanonicalFile() 縺ｧ逋ｺ逕溘☆繧句?蜃ｺ蜉帙お繝ｩ繝ｼ
266             */
267            protected void makeLocalDir( final String localFile ) throws IOException {
268                    File fileDir = new File( localFile ).getCanonicalFile().getParentFile();
269                    if( !fileDir.exists() ) {
270                            if( ! fileDir.mkdirs() ) {
271                                    errAppend( "繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｮ菴懈?縺ｫ螟ｱ謨励＠縺ｾ縺励◆縲? );
272                                    errAppend( "   localFile   = [" , localFile     , "]" );
273                                    throw new RuntimeException( getErrMsg() );
274                            }
275                    }
276            }
277    
278            /**
279             * 繝?ぅ繝ｬ繧ｯ繝医Μ縺ｨ繝輔ぃ繧､繝ｫ蜷阪ｒ蜷域?縺励∪縺吶?
280             *
281             * 蜊倡ｴ斐↓縲√ョ繧｣繝ｬ繧ｯ繝医Μ縺ｮ譛?ｾ後→縲√ヵ繧｡繧､繝ｫ縺ｮ譛??縺ｮ縲?/" 繧偵メ繧ｧ繝?け縺励?
282             * 蟄伜惠縺吶ｌ縺ｰ縲√◎縺ｮ縺ｾ縺ｾ縲∫ｵ仙粋縺励?蟄伜惠縺励↑縺代ｌ縺ｰ縲?/" 繧定ｿｽ蜉?＠縺ｾ縺吶?
283             * 荳｡譁ｹ縺ｫ蟄伜惠縺吶ｋ蝣ｴ蜷医?縲∫援譁ｹ繧偵?縺壹＠縺ｾ縺吶?
284             *
285             * @param       dir     繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
286             * @param       file    繝輔ぃ繧､繝ｫ蜷?
287             *
288             * @return      蜷域?縺輔ｌ縺溘ヵ繧｡繧､繝ｫ蜷?
289             */
290            protected String addFile( final String dir,final String file ) {
291                    final String filepath ;
292    
293                    char ch1 = dir.charAt( dir.length()-1 ) ;       // 繝?ぅ繝ｬ繧ｯ繝医Μ縺ｮ譛?ｾ後?譁?ｭ?
294                    char ch2 = file.charAt( 0 ) ;                           // 繝輔ぃ繧､繝ｫ縺ｮ譛??縺ｮ譁?ｭ?
295    
296                    if( ch1 == '/' || ch1 == '\\' ) {
297                            if( ch2 == '/' || ch2 == '\\' ) {       // 荳｡譁ｹ縺ｨ繧ょｭ伜惠縺吶ｋ縲?
298                                    filepath = dir + file.substring(1);
299                            }
300                            else {
301                                    filepath = dir + file;
302                            }
303                    }
304                    else {
305                            if( ch2 == '/' || ch2 == '\\' ) {       // 迚?婿縺ｮ縺ｿ蟄伜惠縺吶ｋ縲?
306                                    filepath = dir + file;
307                            }
308                            else {
309                                    filepath = dir + "/" + file;
310                            }
311                    }
312    
313                    return filepath ;
314            }
315    
316            /**
317             * 繧ｵ繝ｼ繝舌?縺ｮ縲√?繧ｹ繝医?繝ｦ繝ｼ繧ｶ繝ｼ縲√ヱ繧ｹ繝ｯ繝ｼ繝峨ｒ險ｭ螳壹＠縺ｾ縺吶?
318             *
319             * @param       host    繧ｵ繝ｼ繝舌?
320             * @param       user    繝ｦ繝ｼ繧ｶ繝ｼ
321             * @param       passwd  繝代せ繝ｯ繝ｼ繝?
322             */
323            @Override
324            public void setHostUserPass( final String host , final String user , final String passwd ) {
325                    this.host = host;
326                    this.user = user;
327                    this.passwd = passwd;
328            }
329    
330            /**
331             * 繧ｵ繝ｼ繝舌?蜷阪ｒ蜿門ｾ励＠縺ｾ縺吶?
332             *
333             * @return      繧ｵ繝ｼ繝舌?
334             */
335    //      protected String getHost() { return host; }
336    
337            /**
338             * 繝ｦ繝ｼ繧ｶ繝ｼ蜷阪ｒ蜿門ｾ励＠縺ｾ縺吶?
339             *
340             * @return      繝ｦ繝ｼ繧ｶ繝ｼ
341             */
342    //      protected String getUser() { return user; }
343    
344            /**
345             * 繝代せ繝ｯ繝ｼ繝峨ｒ蜿門ｾ励＠縺ｾ縺吶?
346             *
347             * @return      繝代せ繝ｯ繝ｼ繝?
348             */
349    //      protected String getPassword() { return passwd; }
350    
351            /**
352             * 謗･邯壹↓蛻ｩ逕ｨ縺吶ｋ繝昴?繝育分蜿ｷ繧定ｨｭ螳壹＠縺ｾ縺吶?
353             *
354             * @param       port    謗･邯壹↓蛻ｩ逕ｨ縺吶ｋ繝昴?繝育分蜿ｷ
355             */
356            @Override
357            public void setPort( final String port ) {
358                    if( port != null ) {
359                            this.port = port ;
360                    }
361            }
362    
363            /**
364             * 繝昴?繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
365             * 險ｭ螳壹＆繧後※縺?ｋ逕溘?port螻樊?(null繧ゅ≠繧翫≧繧?繧定ｿ斐＠縺ｾ縺吶?
366             *
367             * @return      繝昴?繝?
368             */
369            protected String getPort() { return port; }
370    
371            /**
372             * 繝昴?繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
373             * 險ｭ螳壹＆繧後※縺?ｋport螻樊?縺後?null縺ｮ蝣ｴ蜷医?縲‥efPort繧定ｿ斐＠縺ｾ縺吶?
374             *
375             * @param       defPort port 縺?null 縺ｮ蝣ｴ蜷医?蛻晄悄蛟､
376             *
377             * @return      繝昴?繝?
378             */
379            protected int getPort( final int defPort) {
380                    return ( port == null ) ? defPort : Integer.parseInt( port );
381            }
382    
383            /**
384             * 縺昴ｌ縺槭ｌ縺ｮ蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°(蛻晄悄蛟､:true:菴懈?縺吶ｋ)縲?
385             *
386             * -mkdirs=[true/false] 縺ｯ縲∝女縺大?縺ｮ繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?繧ｵ繝ｼ繝舌?)縺ｫ蜿悶ｊ霎ｼ繧?ヵ繧｡繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺?
387             * 蟄伜惠縺励↑縺??蜷医↓縲∽ｽ懈?縺吶ｋ縺九←縺?°繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:true)
388             * 騾壼ｸｸ縲√し繝ｼ繝舌?縺ｫ縲√ヵ繧ｩ繝ｫ繝?嚴螻､繧剃ｽ懈?縺励※PUT縺吶ｋ蝣ｴ蜷医?蜍慕噪縺ｫ繝輔か繝ｫ繝?嚴螻､繧剃ｽ懈?縺励◆縺?こ繝ｼ繧ｹ縺ｧ萓ｿ蛻ｩ縺ｧ縺吶?
389             * 騾?↓縲√ヵ繧ｩ繝ｫ繝??遒ｺ螳壹＠縺ｦ縺翫ｊ縲∵欠螳壹ヵ繧ｩ繝ｫ繝?ｻ･螟悶↓ PUT 縺吶ｋ縺ｮ縺ｯ繝舌げ縺｣縺ｦ縺?ｋ縺ｨ莠九′蛻?°縺｣縺ｦ縺?ｋ蝣ｴ蜷医↓縺ｯ
390             * false 縺ｫ險ｭ螳壹＠縺ｦ縲∝ｭ伜惠縺励↑縺?ヵ繧ｩ繝ｫ繝?↓PUT 縺励ｈ縺?→縺吶ｋ縺ｨ縲√お繝ｩ繝ｼ縺ｫ縺ｪ繧九ｈ縺?↓縺励∪縺吶?
391             *
392             * @param       isMkdirs        蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°縲Ｕrue:菴懈?縺吶ｋ
393             */
394            @Override
395            public void setMkdirs( final boolean isMkdirs ) {
396                    this.isMkdirs = isMkdirs ;
397            }
398    
399            /**
400             * 蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°繧貞叙蠕励＠縺ｾ縺吶?
401             *
402             * @return      蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°縲Ｕrue:菴懈?縺吶ｋ
403             */
404    //      protected boolean isMkdirs() { return isMkdirs; }
405    
406            /**
407             * 繧ｿ繧､繝?い繧ｦ繝医ｒ遘偵〒謖?ｮ壹＠縺ｾ縺?蛻晄悄蛟､:600 [遘綻)縲?
408             *
409             * 繧ｪ繝ｪ繧ｸ繝翫Ν縺ｮ FTPClient#setDataTimeout( int ) 縺ｯ縲√Α繝ｪ遘偵〒繧ｻ繝?ヨ
410             * 縺励∪縺吶′縲√％縺薙?繝｡繧ｽ繝?ラ縺ｧ縺ｯ縲∫ｧ偵〒繧ｻ繝?ヨ縺励∪縺吶?
411             *
412             * @param       timeout 繧ｿ繧､繝?い繧ｦ繝?遘綻
413             * @throws RuntimeException 繧ｿ繧､繝?い繧ｦ繝医?謖?ｮ壹′螟ｧ縺阪☆縺弱◆蝣ｴ蜷?
414             */
415            @Override
416            public void setTimeout( final int timeout ) {
417                    if( Integer.MAX_VALUE / 1000 < timeout ) {
418                            errAppend( "繧ｿ繧､繝?い繧ｦ繝医?謖?ｮ壹′螟ｧ縺阪☆縺弱∪縺吶?" );
419                            errAppend( "   timeout   = [" , timeout , "]" );
420                            throw new RuntimeException( getErrMsg() );
421                    }
422    
423                    this.timeout = timeout ;
424            }
425    
426            /**
427             *謖?ｮ壹＆繧後◆繧ｿ繧､繝?い繧ｦ繝医ｒ遘偵〒蜿門ｾ励＠縺ｾ縺?蛻晄悄蛟､:600 [遘綻)縲?
428             *
429             * @return      繧ｿ繧､繝?い繧ｦ繝?遘綻
430             */
431    //      protected int getTimeout() { return timeout; }
432    
433            /**
434             * 螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ 繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false:陦ｨ遉ｺ縺励↑縺?縲?
435             *
436             * @param       isDisplay       螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ
437             */
438            @Override
439            public void setDisplay( final boolean isDisplay ) {
440                    this.isDisplay = isDisplay ;
441            }
442    
443            /**
444             * 螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ繧貞叙蠕励＠縺ｾ縺吶?
445             *
446             * @return      螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ
447             */
448    //      protected boolean isDisplay() { return isDisplay; }
449    
450            /**
451             * 繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ 繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false:陦ｨ遉ｺ縺励↑縺?縲?
452             *
453             * @param       isDebug 繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ
454             */
455            @Override
456            public void setDebug( final boolean isDebug ) {
457                    this.isDebug = isDebug ;
458            }
459    
460            /**
461             * 繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ 繧貞叙蠕励＠縺ｾ縺吶?
462             *
463             * @return      繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ
464             */
465    //      protected boolean isDebug() { return isDebug; }
466    
467            /**
468             * 蜃ｦ逅?ｸｭ縺ｫ逋ｺ逕溘＠縺溘お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ繧偵そ繝?ヨ縺励∪縺吶?
469             *
470             * @param       msg  繝｡繝?そ繝ｼ繧ｸ蛹悶＠縺溘＞繧ｪ繝悶ず繧ｧ繧ｯ繝?
471             */
472            protected void errAppend( final Object msg ) {
473                    errMsg.append( String.valueOf(msg) ).append( CR );
474            }
475    
476            /**
477             * 蜃ｦ逅?ｸｭ縺ｫ逋ｺ逕溘＠縺溘お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ繧偵そ繝?ヨ縺励∪縺吶?
478             *
479             * @param       msgs  Object...
480             */
481            protected void errAppend( final Object... msgs ) {
482                    for( int i=0; i<msgs.length; i++ ) {
483                            errMsg.append( String.valueOf(msgs[i]) );
484                    }
485    
486                    errMsg.append( CR );
487            }
488    
489            /**
490             * 蜃ｦ逅?ｸｭ縺ｫ逋ｺ逕溘＠縺溘お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ繧貞叙繧雁?縺励∪縺吶?
491             *
492             * @return      繧ｨ繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ
493             */
494            @Override
495            public String getErrMsg() {
496                    return errMsg.toString();
497            }
498    }