FTPサーバ機能のJava実装

java.net.ServerSocketをインポートします。 インポート java.net.ServerSocket; インポート java.net.ServerSocket org.apache.log4j.Logger をインポートします。 /** * 役割 - サーバーA * 作者：レオン * */ public class ServerA{ public static void main(String[] args){ （Public static void main(String[] args){) final String F_DIR = "c:/test";//root パスを指定します。 final int PORT = 22;//ポート番号に耳を傾ける Logger.getRootLogger()。 Logger logger = Logger.getLogger("com"); try{ ServerSocket s = new ServerSocket(PORT); logger.info("Connecting to server A... ")。 logger.info("Connected Successful! ローカルポート:"+s.getLocalPort()+". デフォルトディレクトリ:'"+F_DIR+"'. ")。 while( 真 ) { //クライアントの要求を受け入れる Socket client = s.accept()。 //create the service thread new ClientThread(client, F_DIR).start(); } catch(Exception e) { logger.error(e.getMessage())。 for(StackTraceElement ste : e.getStackTrace()){ (スタックトレース要素) logger.error(ste.toString()); } } }

インポート java.io; インポートjava.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.InputStreamReader.InputStreamReader。 import java.io.OutputStream; import java.io.PrintWriter; import java.io.RandomAccessFile; import java.io.RandomAccessFile; import java.net.ConnectException; インポート java.net.InetAddress; import java.net.ServerSocket; インポートjava.net.ServerSocket import java.net.UnknownHostException; インポートjava.nio.charset; import java.util; import org.apache.log4j.Logger; /** * クライアントサブスレッドクラス * 作者：レオン * */ public class ClientThread extends Thread {. private Socket socketClient;//クライアントソケット private Logger logger;// ロギングオブジェクト private String dir;//絶対パス private String pdir = "/";//相対的なパス private final static Random generator = new Random();//random number public ClientThread(ソケットクライアント, 文字列F_DIR)｛以下略 this.socketClient = client; this.dir = F_DIR; オーバーライド public void run() { Logger.getRootLogger(); logger = Logger.getLogger("com"); logger = Logger.getRootLogger("com"); InputStream is = null; OutputStream os = null; トライ is = socketClient.getInputStream()。 os = socketClient.getOutputStream()。 } catch (IOException（例外）e) { {... logger.error(e.getMessage()); for(StackTraceElement ste : e.getStackTrace()){。 logger.error(ste.toString()); } BufferedReader br = new BufferedReader(new InputStreamReader(is, Charset.forName("UTF-8"))); PrintWriter pw = new PrintWriter(os); String clientIp = socketClient.getInetAddress().toString().substring(1);//Client IPを記録する。 ユーザー名 = "ログインしていません";//ユーザー名 文字列パスワード = "";//パスワード 文字列コマンド = "";//command boolean loginStuts = false;//loginStatus final String LOGIN_WARNING = "530 最初にUSERとPASSでログインしてください."。 文字列 str = "";/コマンドの内容文字列 int port_high = 0; int port_low = 0; String retr_ip = "";// 受信ファイルのIPアドレス ソケット tempsocket = null; //ウェルカムメッセージを表示する pw.println("220-FTP Server A version 1.0 written by Leon Guo")を実行します。 pw.flush()を実行します。 logger.info("("+username+") ("+clientIp+")> 接続されました、歓迎メッセージを送信中... "); logger.info("("+username+") ("+clientIp+")> 220-FTP Server A version 1.0 written by Leon Guo"); boolean b = true。 while ( b ) トライ { //ユーザが入力したコマンドを取得する command = br.readLine(); if(null == command) break; } catch (IOException（例外）e) { {... pw.println("331 コマンドの取得に失敗しました"); pw.flush()を実行します。 logger.info("(" +username+") (" +clientIp+")> 331 コマンドの取得に失敗しました。 pw.println(LOGIN_WARNING); pw.flush(); logger.info("("+username+") ("+clientIp+")> "+LOGIN_WARNING); } //PORTを終了する //PASVコマンド、パッシブモードでデータを転送する else if(command.toUpperCase().startsWith("PASV")) { { {. logger.info("("+username+") ("+clientIp+")> "+command).Logger.info("+username+") ("+clientIp+")> "+command); if(loginStuts){。 ServerSocket ss = null。 while( 真 ) { //サーバーの空きポートを取得する port_high = 1 + generator.nextInt(20); port_low = 100 + generator.nextInt(1000)です。 試す{。 // サーバ結合ポート ss = new ServerSocket(port_high * 256 + port_low); ブレーク } catch (IOException（例外）e) { {... を続けます。 } } // logger.info("user"+clientIp+":"+username+"Execute PASV command") を実行します。 InetAddress i = null。 トライ i = InetAddress.getLocalHost()。 } catch (UnknownHostExceptionのe1){。 e1.printStackTrace()を実行します。 pw.println("227 Entering Passive Mode ("+i.getHostAddress().replace(". ", ",")+","+port_high+","+port_low+") ").Println(" 227 パッシブモードに入る); pw.flush()を実行します。 logger.info("("+username+") ("+clientIp+")> 227 Passive Modeに入る ("+i.getHostAddress().replace(& quot;. ", ",")+", "+port_high+","+port_low+") "); トライ { //パッシブモードのソケット tempsocket = ss.accept(); ss.close()。 } catch (IOException（例外） e) { logger.error(e.getMessage())。 for(StackTraceElement ste : e.getStackTrace()){。 logger.error(ste.toString()); } } else{ pw.println(LOGIN_WARNING); pw.flush(); logger.info("("+username+") ("+clientIp+")> "+LOGIN_WARNING); } //PASVを終了する //RETRコマンド else if(command.toUpperCase().startsWith("RETR"){) logger.info("("+username+") ("+clientIp+")> "+command); if(loginStuts){。 str = command.substring(4).trim(); if("".equals(str)){。 pw.println("501 Syntax error"); pw.flush()を実行します。 logger.info("("+username+") ("+clientIp+")> 501 Syntax error").Pw.println("501 Syntax error"); } それ以外の場合 { トライ { pw.println("150 ファイル転送のためのデータチャネルを開く."); pw.flush()を実行します。 logger.info("(" +username+") (" +clientIp+")> 150 ファイル転送のためのデータチャネルを開く."); RandomAccessFile outfile = null; OutputStream outsocket = null; try { // 指定された名前のランダムアクセスファイルストリームを作成し、読み込みと書き込みを行う（オプション）。 outfile = new RandomAccessFile(dir+"/"+str,"r").RandomAccessFile(dir+"/"+str,"r"); outsocket = tempsocket.getOutputStream()。 } catch (FileNotFoundException e) { {... logger.error(e.getMessage()); for(StackTraceElement ste : e.getStackTrace()){。 logger.error(ste.toString()); } catch (IOException e) {. logger.error(e.getMessage()); for(StackTraceElement ste : e.getStackTrace()){。 logger.error(ste.toString()); } byte bytebuffer[]= new byte[1024]; int length; try{ while((length = outfile.read(bytebuffer)) ! = -1){ outsocket.write(bytebuffer, 0, length);

java.io.Fileをインポートする。 インポート java.io.PrintWriter; インポート java.text.SimpleDateFormat; インポート java.util.SimpleDateFormat; インポート java.util.SimpleDateFormat 日付; /** * FTPツールクラス * 作者：レオン * */ public class FtpUtil { public static void getDetailList(PrintWriter pw, String path){ ファイル dir = new File(path)。 if (!dir.isDirectory()) { pw.println("500 No such file or directory./r/n"); File[] files = dir.listFiles(); 文字列modifyDate; for (int i = 0; i < files.length; i++) { { (int i = 0; i < files.Length; i++) modifyDate = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss") .format(new Date(files[i].lastModified())); if (ファイル[i].isDirectory()) { (ファイル[i].isDirectory()) pw.println("drwxr-xr-x ftp ftp 0 " + modifyDate + " " + files[i].getName()); } else { pw.println("-rw-r--r--1 ftp ftp " + files[i].length() + " " + modifyDate + " " + files[i].getName()); pw.flush(); pw.println("total:" + files.length)を実行します。 } }

### ログレベルを設定します。 log4j.logger.com =debug、stdout、D、E ### コンソールへの出力 ###. log4j.appender.stdout=org.apache.log4j.Stdout。 log4j.appender.stdout.Target=System.out(ターゲット) log4j.appender.stdout.layout=org.apache.log4j. log4j.appender.stdout.layout.ConversionPattern = %d{ABSOLUTE}. 5p %c{1}:%L - %m%n ## DEBUGレベル以上のログを出力する log4j.appender.D = org.apache.log4j.DailyRollingFileAppender log4j.appender.D.File=c:/logs/logs.log log4j.appender.D.Append=trueとする。 ## DEBUGレベル以上のログを出力する log4j.appender.D.Threshold=DEBUG（しきい値）。 D.layout=org.apache.log4j.PatternLayout。 log4j.appender.D.layout.ConversionPattern = %-d{yyyy-MM-dd HH:mm:ss} とする。[ %t:%r ] - [ %p ] %m%n ### 例外情報を別ファイルに保存する ###. log4j.appender.E=org.apache.log4j.DailyRollingFileAppender。 ## 例外ログファイル名 log4j.appender.E.File=c:/logs/errors.log。 log4j.appender.E.Append=trueを指定します。 ## ERRORレベル以上のログのみ出力!!! log4j.appender.E.Threshold=ERROR log4j.appender.E.layout=org.apache.log4j. log4j.appender.E.layout.ConversionPattern = %-d{yyyy-MM-dd HH:mm:ss} とする。[ %t:%r ] - [ %p ] %m%n