ディレクトリを指定してファイルをgetしたい

Question

#socket通信を行いFTPサーバーからファイル受信をしています。
FTPサーバーからPCにファイルの受信自体はできているが、保存先のディレクトリを指定する方法がわからないです。
今はeclipseフォルダの中のMainActivityというフォルダに自動的に保存される。
##環境
Eclipse4.4Luna
##試したこと
添付プログラムの247行目の"RETR " + file_nameの前に一度"LCD" + 保存先ディレクトリをという文を入れてみましたが、Unknown Commandというエラーが出てしまいました。
##わからないこと
なぜSTORやRETRのコマンドは実行できLCDはUnknownになってしまうのか。
コマンドではなく別の方法で保存先ディレクトリを指定する場合、その方法。
なぜMainActivityというフォルダに自動的に送られるのか。
##プログラムの説明
これとは別にもう一つクラスがあり、そこに引数としてFTPのURL、ユーザネーム、パスワード、Ascii or Binaryを入力して実行する。

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.URL;
import java.util.StringTokenizer;

class Client
{
	// 受信コード
	public static final String READY = "220";
	public static final String USER = "331";
	public static final String PASS = "230";
	public static final String COMMAND = "200";
	public static final String OPEN = "150";
	public static final String TRANSFER = "226";

	// 定数
	public static final char return_code = 0x0a;
	public static final int client_port = 1094;

	// メッセージ送受信用I/Oストリーム
	BufferedReader input;
	DataOutputStream output;

	// Publicメンバ変数
	URL url;
	String user_name;
	String password;
	String type;
	String file_name;
	int ip[];

	// コンストラクタ
	public Client(String param_url,String user_name,String password,String type)
	{
		this.user_name = user_name;
		this.password  = password;
		this.type      = type;

		connection(param_url);
	}

	// FTPコネクション
	public void connection(String param_url)
	{
		try
		{
			url = new URL(param_url);

			// IPアドレスの取得
			int index = 0;
			ip = new int[4];
			System.out.println("ip = "+ip);
			StringTokenizer string;

			Socket socket = new Socket(url.getHost(),8021);
			InetAddress ipaddress = InetAddress.getLocalHost();
			System.out.println("ipaddress =" + ipaddress);
			string = new StringTokenizer(ipaddress.getHostAddress(),".");
			System.out.println("string = "+string);
			while(string.hasMoreTokens())
			{
				ip[index] = Integer.parseInt(string.nextToken());
				System.out.println("ip[index] = "+ip[index]);
				System.out.println("index =" +index);
				index++;
			}

			// ファイル名の解析

			string = new StringTokenizer(url.getFile(),"/");

			System.out.println(url.getFile());
			System.out.println("クリア");
			String file_name = new String();
			while(string.hasMoreTokens())
			{
				file_name = string.nextToken();
				System.out.println("ループに入っています");
				System.out.println("file_name = " +file_name);
				System.out.println(url.getFile());
			}

			// 送受信用リスナ
			ServerSocket ssocket = new ServerSocket(client_port);

			// メッセージ送受信用I/Oストリームの取得
			input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			output  = new DataOutputStream(socket.getOutputStream());

			// FTP 通信の開始。
			ReceiveMessage(READY);
			System.out.println("FTP通信開始");
			System.out.println("ip = " + ip);
			System.out.println("client_port = "+ client_port);

			UserAuthentication(user_name,password);
			System.out.println("ユーザ認証通過");

			SetType(type);
			System.out.println("タイプ通過");
			OpenClientPort(ip,client_port);
			System.out.println("ip = " + ip);
			System.out.println("client_port = "+ client_port);
			System.out.println("オープンクライアントポート通過");
			int file_size = ReceiveFile(url.getFile().substring(1));//受信を行う箇所
			System.out.println("ftp通信完了");

			// 受信用リスナの構築
			Socket receive = ssocket.accept();
			System.out.println("receive ="+receive);
			DataInputStream data_in = new DataInputStream(receive.getInputStream());
			System.out.println("data_in ="+data_in);
			DataOutputStream file_out = new DataOutputStream(new FileOutputStream(file_name));
			System.out.println("file_out ="+file_out);
			System.out.println("受信リスナ構築完了");

			// 受信＆書き出し
			//String str;

			for(int i=0;i<file_size;i++)
			{
				System.out.println("for文に入っています");
				file_out.writeByte(data_in.readByte());
			}

			ReceiveMessage(TRANSFER);
			System.out.println("Receive OK");

			// 終了処理
			socket.close();
			ssocket.close();
		}
		catch(Exception e)
		{
			System.err.println(e.toString());
		}
	}

	// リターンコードの確認
	protected boolean isReady(String string,String type)
	{
		if(string.substring(0,3).compareTo(type) == 0)
		{
			return(true);
		}
		return(false);
	}

	// エラーメッセージルーチン
	protected void ErrorMessage(String message)
	{
		System.out.println(message);
		System.exit(-1);
	}

	// メッセージの送信
	protected void SendMessage(String message)
	{
		try
		{
			output.writeBytes(message + return_code);
		}
		catch(IOException e)
		{
			System.err.println(e.toString());
		}
	}

	// 受信メッセージの判断
	protected String ReceiveMessage(String type)
	{
		try
		{
			String res = input.readLine();
			System.out.println(">" + res);
			if(!isReady(res,type))
			{
				ErrorMessage("Error: code = " + type);
			}
			return(res);
		}
		catch(IOException e)
		{
			System.out.println(e.toString());
			return("Error_Code");
		}
	}

	// ユーザー認証
	protected void UserAuthentication(String user_name,String password)
	{
		SendMessage("USER " + user_name);
		ReceiveMessage(USER);

		SendMessage("PASS " + password);
		ReceiveMessage(PASS);
	}

	// Ascii or Binaryモードセット
	protected void SetType(String type)
	{
		if(type.toLowerCase().compareTo("ascii") == 0)
		{
			SendMessage("TYPE A");
			ReceiveMessage(COMMAND);
		}
		else
		{
			SendMessage("TYPE I");
			ReceiveMessage(COMMAND);
		}
	}

	// データ受信用ポートの通知
	protected void OpenClientPort(int ip[],int port)
	{
		for(int i = 0; i < 4; i++){
		System.out.println("ip = "+ ip[i]);
		}
		System.out.println("port ="+ port);
		int high_port_number,low_port_number;

		high_port_number = port / 256;
		System.out.println("high_port_number ="+ high_port_number);
		low_port_number  = port % 256;
		System.out.println("low_port_number ="+ low_port_number);
		SendMessage("PORT " + ip[0] + "," + ip[1] + "," + ip[2] + "," + ip[3] + ","
						+ high_port_number + "," + low_port_number);
		System.out.println("COMMAND ="+COMMAND);
		ReceiveMessage(COMMAND);
	}

	// ファイル受信コマンド
	protected int ReceiveFile(String file_name)
	{
		String receive;
		System.out.println("受信コマンドに入っています");
		System.out.println(file_name);

		SendMessage("RETR " + file_name);
		receive = ReceiveMessage(OPEN);
		System.out.println("eceive ="+receive);
		return(GetFileSize(receive));
	}

	// ファイル送信コマンド
	protected int StoreFile(String file_name)
	{
		String receive;
		System.out.println("送信コマンドに入っています");
		System.out.println(file_name);

		SendMessage("STOR " + file_name);
		receive = ReceiveMessage(OPEN);
		return(GetFileSize(receive));
	}

	// 受信/送信メッセージからファイルサイズを求める
	protected int GetFileSize(String message)
	{
		int size,begin_index,end_index;

		begin_index = message.lastIndexOf('(') + 1;
		end_index   = message.lastIndexOf("bytes") - 1;
		size = Integer.parseInt(message.substring(begin_index,end_index));

		return(size);
	}
}

Answer 1

LCDは、ftpクライアント自身が処理するコマンドで、FTPサーバーには送られません。プロトコルの規格(RFC 959など)にも規定されていません。

FTPコマンドの一覧 - Wikipedia

今回だと、あなたの作成したプログラム自身がLCDに対応する処理を行なう必要があります。つまり、FTPサーバーからファイル名を取得した後、new FileOutputStream(file_name)するさいに、file_nameの前に保存先ディレクトリの絶対パスか相対パスを付加してください。

Comments

[0sksksk]

無事に指定したディレクトリにファイルを保存することができました。
ありがとうございます。