常連

プログラミングに関係ある所か微妙に怪しいところですが、
お付き合い頂けますと幸いです。

## 背景
現在、
**Red Hat Enterprise Linux AS release 4 (Nahant Update 3)**
から
**Red Hat Enterprise Linux Server release 6.4 (Santiago)**
へのシステムマイグレーション作業を行なっています。

その中に、Javaを使用したFTPファイル転送のモジュールがあるのですが、
これが旧環境だと問題無く動くのですが新環境だとエラーで失敗します。

変化があったのはREHLのバージョンと、Javaのバージョンです。
Javaのバージョンは1.4→1.8へと変化しました。

逆に言うと、変化があったのは上記2点だけのはずなのですが、
なぜ、ここで失敗しているのか分かりません。

Javaのモジュールは、FTPのコマンドそれぞれクラスで作成し、
それを実際動作を行うメインモジュールから呼び出しています。

といってもメインモジュールも複雑な事はしておらず、
ログイン→ディレクトリ移動→ファイルの存在確認→ファイルPUT
となっています。

## 環境

| |旧環境|新環境|
|---|---|---|
|OS|Red Hat Enterprise Linux AS release 4 (Nahant Update 3)|Red Hat Enterprise Linux Server release 6.4 (Santiago)|
|Java|1.4|1.8|
|接続先|Windows2003|Windows2003|



## 問題
上記の流れの中の内、
**ファイル存在確認(NLST発行)**
と
**ファイル送信(PUT発行)**
の2箇所が上手く動いていないようです。

ファイルが存在する場合でもファイルの存在はないと認識され、
PUTに至っては、データが流しこまれていないようなのです。
(送信先に空ファイルは存在するので、データ送信のみ上手くいってない？)

背景に書いたような環境の変化によって、上記動作が上手くいかなくなるような事はあるのでしょうか…

当方Javaについてからっきしな為、どこが問題なのかも分かりません。
お手数ですが、御知恵を拝借できましたら幸いです。
以下に使用している、FTPコマンドのクラスを添付します。

何卒宜しくお願い致します。

## ソース
```java
import java.io.*;
import java.net.*;
import java.util.*;

/**
 * FTP Clientクラス 
 * 
 * RFC959仕様のFTPコマンドを発行する 
 * 
 */
public class FtpClient
{

	private Socket sock = null;
	private PrintWriter log = new PrintWriter(System.out);
	private boolean logflag;


 /**
 * FTPサーバにログインを行う。 
 * @param String server	サーバホスト名(IPアドレス等）
 * @param int Port		ポート番号(大抵は21です）
 * @param String user		ユーザー名
 * @param String pass		パスワード
 * @throws Exception 		エラーが発生した場合にスローされる。
 */
	public FtpClient(String server, int Port, String user, String pass) throws Exception
	{
		logflag = true;
		this.login( server, Port, user, pass );
		logflag = false;
	}


 /**
 * FTPサーバからリプライコードを取得。 
 * 
 * 
 * @param String		strPass エンコードしたいパスワード
 * @return int		リプライコード
 * @throws java.io.IOException 入出力エラーが発生した場合にスローされる。
 */
	private int getReplyCode() throws IOException
	{
		//↓ソケット通信の時、getInputStreamは上等手段っぽい
		// そのオブジェクトをBufferedReaderでやるかObjectInputStreamでやるかは作り手次第
		BufferedReader reader = new BufferedReader(new InputStreamReader(sock.getInputStream()));
		String buffer;

//		buffer = reader.readLine();
//		this.log(buffer);
//		return Integer.parseInt(buffer.substring(0,3));

		do
		{
			buffer=reader.readLine();
			this.log(buffer);
		} while(buffer.charAt(3) == '-');
		return Integer.parseInt(buffer.substring(0,3));
	}

 /**
 * FTPサーバにコマンドを送信する。 
 * 
 * @param String		command FTPコマンド
 * @throws java.io.IOException 入出力エラーが発生した場合にスローされる。
 */
	private void sendCommand(String command) throws IOException
	{
		BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(sock.getOutputStream()));
		writer.write(command);
		writer.newLine();			//行区切文字を送る。\nとは限らないのでこれを使う。
		writer.flush();
		this.log(">"+command);
	}

 /**
 * FTPサーバにログイン認証を行う。 
 * 通常、インスタンス生成時に呼ばれる。 
 * 
 * @param String server	サーバホスト名(IPアドレス等）
 * @param int Port		ポート番号(大抵は21です）
 * @param String user		ユーザー名
 * @param String pass		パスワード
 * @throws Exception 		エラーが発生した場合にスローされる。
 */
	public void login(String server, int port, String user, String pass) throws Exception
	{
		sock = new Socket(server, port);
 sock.setSoTimeout(100000);


		// 接続チェック
		if(getReplyCode() != 220)
		{
			throw( new Exception("接続失敗") );
		}

		sendCommand("USER " + user);
		if(getReplyCode() != 230)
		{
			//パスワードも必要
			sendCommand("PASS " + pass);
			if(getReplyCode() != 230)
			{
				throw( new Exception("IDまたはパスワードが違います"));
			}
		}
	}

 /**
 * サーバソケットを作成する。 
 * 
 * @throws Exception 	エラーが発生した場合にスローされる。
 */
	private ServerSocket port() throws Exception
	{
		String command = "PORT";

		//サーバソケットを作成し、指定されたバックログで指定された
		//ローカルポート番号にバインドします。
		//ポート番号に 0 を指定すると、空いているポート上にソケットが作成されます。
		//受信する接続 (接続要求) の待ち行列の最大長は、
		//backlog パラメータの値に設定されます。
		ServerSocket mySocket = new ServerSocket(0,1);

		//ポートは４桁の数字が入る？(1254とか1255とか…)
		int iPort = mySocket.getLocalPort();

		// 自マシンのIPアドレス取得
		String ip = sock.getLocalAddress().getHostAddress();

		//ここら辺は他人のソースのパクリ
		command = command + " " + ip.replace('.',',');
		command = command + "," + (iPort >> 8) + "," + (iPort & 0xFF);

		sendCommand( command );
		if( getReplyCode() != 200)
		{
			throw( new Exception(command + "は失敗しました") );
		}
		return mySocket;
	}

 /**
 * NLSTにコマンドを付記して発行する。 
 * 
 * @param String command	コマンド
 * @return String[]		取得したファイル情報
 * @throws Exception 	エラーが発生した場合にスローされる。
 */
	public String[] nlst(String command) throws Exception
	{
		if (command.length() == 0) return listSub("NLST");
		return listSub("NLST " + command);
	}


 /**
 * LISTまたはNLSTコマンドを実行してサーバから情報取得し 
 * 文字配列型で返す。 
 * 
 * @param String command	コマンド
 * @return String[]		取得したファイル情報
 * @throws Exception 	エラーが発生した場合にスローされる。
 */
	private String[] listSub(String command) throws Exception
	{
 String resp[] = null;
		Vector v = new Vector();		//JDK1.5対策

		BufferedReader readData=null;
		ServerSocket myDataSocket = port();

		// 2002.12.06追加
		myDataSocket.setSoTimeout(5000);

		sendCommand(command);

		if(getReplyCode() != 150)
		{
			throw( new Exception(command+"は失敗しました") );
		}


		Socket socRead = myDataSocket.accept();

//		↓e*Gateから呼び出すとウィンドウ変えたりしてると止まるときがあった。
//		acceptしたら即切り離すようにした 2002.12.09
//		同winマシン内にあるIISのFTPに対してだと、ここで処理が止まることがある･･･
		if (myDataSocket != null) myDataSocket.close();
		readData = new BufferedReader(new InputStreamReader(socRead.getInputStream()));

		String buffer = null;
		while(true)
		{
			buffer = new String();
			buffer = readData.readLine();
			if(buffer == null)
			{
				break;
			}
			v.addElement(new String(buffer));
		}

		try
		{
			if (socRead != null) socRead.close();

//			↓acceptしたら即切り離すようにした 2002.12.09
//			if (myDataSocket != null) myDataSocket.close();

		}
		catch( IOException e ){}

		if(getReplyCode() != 226)
		{
			throw( new Exception(command+"は失敗しました") );
		}

		resp = new String[v.size()];
		for (int i = 0; i < resp.length; i++)
		{
			resp[i] = (String)v.elementAt(i);
		}
 return resp;
	}

 /**
 * ローカルファイルをサーバにファイル名つけてプットする。
 * 
 * @param String localfile	ローカルファイル名
 * @param String serverfile	サーバファイル名
 * @throws Exception 		エラーが発生した場合にスローされる。
 */
	public void put(String localfile, String serverfile) throws Exception
	{
		String command = "STOR";
		DataInputStream readData = null;
		DataOutputStream writeData = null;
		ServerSocket myDataSocket = null;
		Socket socWrite = null;

		try
		{
			myDataSocket = port();

			sendCommand(command + " " + serverfile);
			if(getReplyCode() != 150)
			{
				throw( new Exception(command+"は失敗しました") );
			}

			socWrite = myDataSocket.accept();
			readData = new DataInputStream(new FileInputStream(localfile));
			writeData = new DataOutputStream(socWrite.getOutputStream());

			while(true)
			{
				byte[] byteRead=new byte[10240];
				int iReadLen=readData.read(byteRead);
				if(iReadLen==(1))
				{
					break;
				}
				writeData.write(byteRead,0,iReadLen);
			}

			writeData.close();
			readData.close();
			socWrite.close();
			if( getReplyCode() != 226)
			{
				throw( new Exception(command+"による転送は失敗しました") );
			}
		}
		catch( Exception e )
		{
			e.printStackTrace( this.log );
			throw( new Exception() );
		}
		finally
		{
			try
			{
				if (socWrite != null) socWrite.close();
				if (myDataSocket != null) myDataSocket.close();
				if (writeData != null) writeData.close();
			}
			catch( IOException e ){}
		}
	}

 /**
 * PWDを発行する。 
 * 
 * @return boolean			true･･･成功、false･･･失敗
 * @throws Exception 		エラーが発生した場合にスローされる。
 */
	public boolean pwd() throws Exception
	{
		sendCommand("PWD");
		if(getReplyCode() != 257)
		{
			return false;
		}
		return true;
	}
}

```

	@@ -1 +1 @@
1	- RHELのバージョン違いによるFTPの接続について
1	+ RHELまたはJavaのバージョン違いによるFTPの接続について

質問編集履歴