0

ファイルをダウンロードするために Java でマルチスレッド クライアント/サーバー プログラムを実装しました。このプログラムでは、サーバーはスレッドを利用して多くのクライアントに同時にファイルを提供できます。

単一のクライアントでサーバーをテストすると正常に動作しますが、シェル スクリプトを使用して 10 台以上のクライアントでテストすると、ダウンロードされたファイルのサイズがすべて異なり、サーバー側のファイルの実際のサイズとは異なります。

なぜこれが起こっているのか誰でも説明できますか？

サーバーのコード:

public class FileSend implements Runnable {
   Socket sock;
   String pathname;

   FileSend(Socket s, String filename) {
      sock = s;
      pathname = System.getenv("HOME") + "/" + Main.spath + "/" + filename;
   }

   void send(String pathname) throws IOException, NoSuchAlgorithmException,
         NoSuchPaddingException, ParseException {

      try {
         byte[] buf = new byte[1024];
         OutputStream os = sock.getOutputStream();
         //PrintWriter writer = new PrintWriter(os);
         BufferedOutputStream out = new BufferedOutputStream(os, 1024);
         int i = 0;
         File fp = new File(pathname);
         RandomAccessFile ra = new RandomAccessFile(fp, "r");
         long bytecount = 1024;
         ////////////////

         while ((i = ra.read(buf, 0, 1024)) != -1) {

            bytecount += 1024;
            out.write(buf, 0, i);
            out.flush();
         }
         sock.shutdownOutput();
         out.close();
         ra.close();
         sock.close();
      } catch (IOException ex) {

      }
   }

   public void run() {
      try {
         try {
            try {
               try {
                  send(this.pathname);
               } catch (ParseException ex) {
                  Logger.getLogger(FileSend.class.getName()).log(Level.SEVERE,
                        null, ex);
               }
            } catch (NoSuchPaddingException ex) {
               Logger.getLogger(FileSend.class.getName()).log(Level.SEVERE,
                     null, ex);
            }
         } catch (NoSuchAlgorithmException ex) {
            Logger.getLogger(FileSend.class.getName()).log(Level.SEVERE, null,
                  ex);
         }
      } catch (IOException ex) {
         Logger.getLogger(FileSend.class.getName()).log(Level.SEVERE, null, ex);
      }
   }
}

クライアントコード:

public class FileRecieve implements Runnable {
   Socket sock;
   String path;
   Date T;

   //private Date d2;
   FileRecieve(Socket s, String fname, Date d1) {
      sock = s;
      path = Main.Dpath + "/" + fname;
      T = d1;
   }

   public void run() {
      try {
         byte[] b = new byte[1024];
         int len = 0;
         long bytcount = 1024;

         File fp = new File(path);
         // RandomAccessFile ra = new RandomAccessFile(fp,"r");

         RandomAccessFile ra = new RandomAccessFile(fp, "rw");
         ra.seek(0);
         InputStream is = sock.getInputStream();
         BufferedReader reader = new BufferedReader(new InputStreamReader(is));
         while ((len = is.read(b, 0, 1024)) != -1) {
            bytcount = bytcount + 1024;

            //decrypt
            ra.write(b, 0, len);
         }

         is.close();
         ra.close();
         sock.close();
      } catch (IOException ex) {
         ex.printStackTrace();
      }
   }
}

助けてください、事前に感謝します。

4

1 に答える 1

1

私はMutithreadedClient-Serverファイルダウンローダーアプリで同様の試みをしました。コードレビューで確認できます。マルチスレッドビットにjava.util.concurrentパッケージクラスを使用しました。

于 2012-11-28T15:38:44.730 に答える