Java Commons.netを用いたFTPクライアントについての質問

Question

お世話になっております。
現在、JavaでFTPアップロードを行う。 - sinsengumi血風録を参考にFTP通信を行うプログラムを作成しています。

送信中はサーバーにlockファイルを作成し、送信が終わったら作成したlockファイルを削除するプログラムにしたいのですが、下記のように作成したところlockファイル自体の作成と削除はできるのですが、肝心のファイル送信自体がうまく行きません。
ストリームの理解が足りないまま併用をしているのが原因だと思うのですが、ご教授をお願いします。

	private static void execute() throws Exception {

		FTPClient ftpClient = new FTPClient();
		OutputStream out = null;

		try {

			// エンコーディングの設定は、connectする前に行う。
			ftpClient.setControlEncoding("UTF8");

			// FTPサーバに接続
			ftpClient.connect(FTP_HOST);
			
			ftpClient.setSoTimeout(20000);

			// ログイン
			ftpClient.login(FTP_USER, FTP_PASSWORD);

			// PASVモードに設定
			ftpClient.pasv();

			// データの変換モードをバイナリに設定
			ftpClient.setFileType(FTP.BINARY_FILE_TYPE);

			//ロックファイル作成
			out = ftpClient.storeFileStream("0001.lock");
			out.close();

			Thread.sleep(2000);

			// ファイル転送
			FileInputStream fis = new FileInputStream(UPLOAD_FILE);

			ftpClient.storeFile(UPLOADED_FILENAME, fis);

			Thread.sleep(2000);

			ftpClient.deleteFile("0001.lock");

		} catch (NumberFormatException e) {
			throw new Exception("FTPポートの値が数値ではありません。", e);
		} catch (SocketException e) {
			throw new Exception("Socket通信に失敗しました。", e);
		} catch (FileNotFoundException e) {
			throw new Exception("アップロードするファイルが見つかりません。", e);
		} catch (IOException e) {
			throw new Exception("IOレベルで例外が発生しました。", e);
		} finally {
			if (out != null) {
				out.close();
			}
			if (ftpClient.isConnected()) {
				try {
					ftpClient.logout();
					ftpClient.disconnect();
					System.out.println("disconnect complete");
				} catch (IOException e) {
					// ignore
				}
			}
		}
	}

Answer 1

（追記）

元のコードで同じ問題が発生することを確認しました。

lockファイルの送信後にはステータス150が返されています。
これはデータコネクション（ファイル転送のためのコネクション）が確立した状態のままになっていて、転送が完了していないということなのではないかと思います。

正しい解決方法かどうか自信がありませんが、lockファイルの転送後にftpClient.getReply();を入れることで、転送が終わったことを通知できるようです。つまり、226 Transfer Completeになります。

//ロックファイル作成
OutputStream out = ftpClient.storeFileStream("0001.lock");
out.close();
ftpClient.getReply(); // ◆◆ ここ ◆◆

---

（最初の回答）

下記ページにあるように、それぞれの処理後にftpClient.getReplyString()を出力して、応答の内容を確認してみてください。
JavaでFTPアップロードを行う。 - sinsengumi血風録

Comments

[puti]

回答ありがとうございます。
応答電文は
220 Microsoft FTP Service
230 User logged in.
227 Entering Passive Mode (************).
200 Type set to I.
200 PORT command successful.

となっており、ファイルの送信自体は成功している、という具合です。

[argius]

うまく行かないと書かれていますが、具体的にはどのような問題があるのですか？

[puti]

・指定した名前の.lockファイルは作成されます。
・実行してほしいftpClient.storeFile(UPLOADED_FILENAME, fis);　部分で正常に送信処理が行われていません。
・UPLOADED_FILENAMEと同名のファイルをFTPサーバーに配置した状態でプログラムを実行するとUPLOADED_FILENAME名のファイルが削除されます。

[tsuntsun]

ロックファイルの作成と削除をコメントアウトして実行するとどうなりますか？

[puti]

参考サイトままのプログラムになるため、正常に転送が可能です。
上記プログラムのロックファイル作成が生きている状態でファイル転送を行うと18:45に書き込んだコメントの通りになるため、該当場所の作りが悪いとは思うんですが……。

[argius]

追記しました。

[puti]

ありがとうございます。
ftpClient.getReply()を仕込んだところ、期待通りの動作をしてくれました。

参考にしたサイトのサブルーチンをlockファイル作成後に仕込んだ場合にエラーを吐いた為仕込まないようにしていたのがよくなかったですね…。わざわざ再現ありがとうございました。

Answer 2

ロックファイルの獲得に、
File lockFile = new File("/tmp/hoge.lock");
try (FileChannel fc = FileChannel.open(lockFile.toPath(), StandardOpenOption.CREATE, StandardOpenOption.WRITE);
FileLock lock = fc.tryLock()) {
if (lock == null) {
// 他プロセスロック中
throw new RuntimeException(MessageFormat.format("File locked another proc."));
}
{
//ロック獲得後の処理
}
}

の様なコードを書かない理由は置いといて（笑）

connect後にreplyを確認していないとか、loginの成否を判定していないとかツッコミ所満載ですね。
ザックリですが、こんなコードになるかと。
try {
//接続
ftpclient.connect(host, port);
int reply = ftpclient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
//接続エラー処理
例外throw
}

//ログイン  
if (ftpclient.login(FTP_USER, FTP_PASSWORD) == false) {  
 // ログインエラー処理 
  例外throw
}  

//ファイル転送モード設定  
ftpclient.setFileType(FTP.BINARY_FILE_TYPE);  

// PASVモードに設定
ftpclient.pasv();

//ファイル転送  
ftpclient.storeFile(UPLOADED_FILENAME, fis);  
//"ファイル転送完了  

} catch (IOException e) {
//エラー処理
throw e;
} finally {
try {
ftpclient.disconnect(); //接続解除
} catch (IOException e) {
}
}

Comments

[puti]

申し訳ない、追記したサイトに追加するだけ、という形式で行っていたため、サブルーチンの方を書かずに質問してしまいました。