Java клиент-сервер проблема при отправке нескольких файлов - PullRequest
1 голос
/ 17 января 2011

Я переписал часть кода, чтобы реализовать два приведенных ниже ответа, и низко, и вот, я получил его для отправки 1 изображения, но теперь мне просто нужно его продолжить, но сервер завершает работу после 1 одиночного изображения.

Клиент (пересмотренный):

public void transferImage() {

File file = new File(ServerStats.clientFolder);
String[] files = file.list();
int numFiles = files.length;
boolean done = false;
BufferedInputStream bis;
BufferedOutputStream bos;
int num;
byte[] byteArray;
long count;
long len;

Socket socket = null ;
while (!done){

  try {
    socket = new Socket(ServerStats.imgServerName,ServerStats.imgServerPort) ;
    InputStream inStream = socket.getInputStream() ;
    OutputStream outStream = socket.getOutputStream() ;
    System.out.println("Connected to : " + ServerStats.imgServerName);

    BufferedReader inm = new BufferedReader(new InputStreamReader(inStream));
    PrintWriter out = new PrintWriter(outStream, true /* autoFlush */);

    for (int itor = 0; itor < numFiles; itor++) {

      String fileName = files[itor];
      System.out.println("transfer: " + fileName);
      File sentFile = new File(fileName);
      len = sentFile.length();
      System.out.println(len);
      out.println(len);
      out.println(sentFile);


      //SENDFILE
      bis = new BufferedInputStream(new FileInputStream(fileName));
      bos = new BufferedOutputStream(socket.getOutputStream( ));
      byteArray = new byte[1000000];
      count = 0;
      while ( (num = bis.read(byteArray)) >0 ){
        //num = bis.read(byteArray);
        bos.write(byteArray,0,num);
      }
      bos.close();
      bis.close();
      System.out.println("file done: " + itor);
    }
    done = true;
  } catch (IOException ee){
    System.err.println("FileIO Error: " + ee);
  }
}

}

Сервер (пересмотренный):

public static void main(String[] args) {
BufferedInputStream bis;
BufferedOutputStream bos;
int num;
File file = new File(ServerStats.serverFolder);
if (!(file.exists())){
  file.mkdir();
}

try {
  ServerSocket socket = new ServerSocket(ServerStats.imgServerPort);
  Socket incoming = socket.accept();

  try {
    try{
      if (!(file.exists())){
        file.mkdir();
      }
      InputStream inStream = incoming.getInputStream();
      OutputStream outStream = incoming.getOutputStream();

      BufferedReader inm = new BufferedReader(new InputStreamReader(inStream));
      PrintWriter out = new PrintWriter(outStream, true /* autoFlush */);
      String length2 = inm.readLine();
      System.out.println(length2);
      String filename = inm.readLine();
      System.out.println("Filename = " + filename);
      out.println("ACK: Filename received = " + filename);

      //RECIEVE and WRITE FILE
      byte[] receivedData = new byte[1000000];
      bis = new BufferedInputStream(incoming.getInputStream());
      bos = new BufferedOutputStream(new FileOutputStream(ServerStats.serverFolder + "/" + filename));

      //long length = (long)Integer.parseInt(length2);
      //length++;
      while ( (num = bis.read(receivedData)) > 0){
        bos.write(receivedData,0,num);
      }
      //System.out.println(counter);
      bos.close();
      bis.close();

      File receivedFile = new File(filename);
      long receivedLen = receivedFile.length();
      out.println("ACK: Length of received file = " + receivedLen);

    } finally {
      incoming.close();
   }
  } catch (IOException e){
    e.printStackTrace();
  }
} catch (IOException e1){
  e1.printStackTrace();
}

}

Выход:

    Welcome to DrJava.  Working directory is C:\Documents and Settings\Dapper Dan\Desktop
> run ServerQueue.Client
Connected to : localhost
transfer: Sunset.jpg
71189
file done: 0
transfer: Water lilies.jpg
83794
FileIO Error: java.net.SocketException: Socket is closed
Connected to : localhost
transfer: Sunset.jpg
71189
> 

Это вывод на стороне клиента, и единственное изображение, которое было передано, было Sunset.jpg, как указано в выражении file done.

Есть идеи о том, что вызывает это?

Ответы [ 2 ]

1 голос
/ 18 января 2011

На стороне клиента переместите создание сокета (и связанного с ним потока) в цикл итератора numFiles

for (int itor = 0; itor < numFiles; itor++) {
//socket = new Socket(...
//socket's outputstream = ....

На стороне сервера переместите вызов socket.accept и всю логику ниже него (правда) петля.

1 голос
/ 17 января 2011

Ваш счетчик размера, действительно ли он обновляется с количеством прочитанных байт?Не должно ли это быть:

while (counter < length ){
    num = bis.read(receivedData);
    bos.write(receivedData,0,num);
    counter += num;
}
...