このcodeでは、ファイルが最初に送信された場合(送信しているファイルの数に関係なく)、コードは正常に動作します。しかし、FileSenderをループに入れてファイルを1つずつ送信すると、最初の転送後に受信者側で受け取ったデータは任意です(デバッグ中にチェックされていると)、ファイルも受信されません。ここで私がやった変更があり、それは機能していません。ソケットファイル転送
FileSender.java
import java.io.OutputStream;
import java.io.File;
import java.net.Socket;
public class FileSender {
public void main(Socket socket,String[] args) {
try {
OutputStream os = socket.getOutputStream();
int cnt_files = args.length;
// How many files?
ByteStream.toStream(os, cnt_files);
for (int cur_file=0; cur_file<cnt_files; cur_file++) {
ByteStream.toStream(os, new File(args[cur_file]).getName());
ByteStream.toStream(os, new File(args[cur_file]));
}
}
catch (Exception ex) {
ex.printStackTrace();
}
}
}
文字列[]引数は、送信するファイルのパスを含みます。
FileReceiver.java
import java.io.File;
import java.io.InputStream;
import java.net.Socket;
public class FileReceiver {
public void main(Socket socket,String arg) {
try {
InputStream in = socket.getInputStream();
int nof_files = ByteStream.toInt(in);
System.out.println("reach 1 "+ nof_files);
for (int cur_file=0;cur_file < nof_files; cur_file++) {
String file_name = ByteStream.toString(in);
File file=new File(arg+file_name);
System.out.println("Received path is : "+file);
ByteStream.toFile(in, file);
}
}
catch (java.lang.Exception ex) {
ex.printStackTrace(System.out);
}
}
}
argは、ファイルが格納される時にパスが含まれています。
メインの機能は、私がファイルを転送したいときはいつでも言いたいと思います。基本的に私はディレクトリを含むことができる複数のファイルを転送したい。これを行うために私は次のコードを書いた。
ServerFile.java
import java.io.*;
import java.net.*;
public class ClientFile implements Runnable{
Socket clientsocket;
public void run() {
try
{
clientsocket = new Socket("219.64.189.14",6789);
// Some code
copy(outtoserver,infromserver, files); // files contains the path of files to be transferred.
// Some code
clientsocket.close();
}
catch(Exception e2)
{
System.out.println("ClientFile "+String.valueOf(e2) + "\n");
}
}
public void copy(DataOutputStream outtoserver,BufferedReader infromserver,String[] files)
{
try
{
FileSender fs = new FileSender();
int totalfiles=0;
int r=0;
File oldfile;
outtoserver.write(files.length);
String chk;
while(totalfiles<files.length)
{
oldfile = new File(files[totalfiles]);
if(oldfile.isDirectory())
{
outtoserver.writeBytes("folder\n");
File folder1[] = oldfile.listFiles();
String[] folder = new String[folder1.length];
int count=0;
for(File name : folder1)
{
folder[count] = name + "";
System.out.println(folder[count]);
count++;
}
outtoserver.writeBytes(oldfile.getName()+"\n");
fs.main(clientsocket, folder);
}
else if(oldfile.isFile())
{
outtoserver.writeBytes("file\n");
chk = infromserver.readLine();
if(chk.equals("send"))
{
outtoserver.writeBytes(oldfile.getName()+"\n");
String[] folder = new String[]{oldfile.getAbsolutePath()};
fs.main(clientsocket, folder);
}
totalfiles++;
outtoserver.flush();
}
}
}
catch(Exception e)
{
System.out.println("ClientFile -->> "+e.toString());
}
}
}
ClientFile.java
import java.io.*;
import java.net.*;
import javax.swing.*;
class ServerFile implements Runnable {
Socket conn;
public ServerFile(Socket a)
{
conn = a;
}
public void run() {
File file1;
String clientsen="";
try
{ // Some code
copy(outtoclient,infromclient,file1.getAbsolutePath()); //file1 is the directory to which the file has to stored.
// some code
}
catch(Exception e0)
{
System.out.println("ServerFile "+String.valueOf(e0)+"\n"+e0.getCause());
}
}//end main
public void copy(DataOutputStream outtoclient,BufferedReader infromclient,String basepath)
{
try
{
FileReceiver fr = new FileReceiver();
int totfiles = infromclient.read();
int tot=0;
File file;
String path = null,chk;
while(tot<totfiles)
{
chk = infromclient.readLine();
if(chk.equals("file"))
{
outtoclient.writeBytes("send\n");
path = infromclient.readLine();
path = basepath+File.separator+path;
file=new File(path);
fr.main(conn, basepath+File.separator);
}
else if(chk.equals("folder"))
{
String name = infromclient.readLine();
name = basepath+File.separator+name;
new File(name).mkdir();
fr.main(conn, name+File.separator);
}
tot++;
}
}
catch(Exception e)
{
System.out.println("Server file: "+e.toString());
}
}
}//end class
私が間違っている場合は、すべての手段によって、私を修正します。
助けてください。
'ServerFile.java'と' ClientFile.java'てもコンパイルされません。 'run()'メソッドは、他のメソッド( 'outtoserver'、' infromserver'、 'files'、' outtoclient'、 'infromclient')の変数を参照します。コンパイルしている_actual_コードは何ですか? –