ソケットレシーブ遅延1の画像

Question

私は1つのInputStream経由で画像を受信するソケットを持っていません。私はそのように大胆にイメージを送りたい。しかし、今度は画像が1枚の画像の遅延で受信されます（2枚目を送信した後の最初の画像、3枚目を送信した後の画像、....）。私は間違って何をしていますか？

サーバー

public static void readImages(InputStream stream) throws IOException { 
    stream = new BufferedInputStream(stream); 
    BufferedImage image = null; 
    int j = 0; 

    while (true) { 

     stream.mark(MAX_IMAGE_SIZE); 

     ImageInputStream imgStream = ImageIO.createImageInputStream(stream); 
     Iterator<ImageReader> i = ImageIO.getImageReaders(imgStream); 
     if (!i.hasNext()) { 
      System.out.println("No more image readers"); 
      break; 
     } 

     ImageReader reader = i.next(); 
     reader.setInput(imgStream); 

     image = reader.read(0); 
     ImageIO.write(image,"jpg",new File("current" + j + ".jpg")); 
     System.out.println("Save an image " + j); 


     if (image == null) { 
      System.out.println("Image is null"); 
      break; 
     } 

     long bytesRead = imgStream.getStreamPosition(); 

     stream.reset(); 
     stream.skip(bytesRead); 
     j++; 
    } 
} 

クライアント

new Thread(new Runnable() { 
      @Override 
      public void run() { 
       try { 

        OutputStream outputStream = server.getOutputStream(); 
        ByteArrayOutputStream stream = new ByteArrayOutputStream(); 
        bitmapToSend = Bitmap.createScaledBitmap(bitmapToSend, 900, 800, true); 
        bitmapToSend.compress(Bitmap.CompressFormat.JPEG, 100, stream); 
        byte[] byteArray = stream.toByteArray(); 
        outputStream.write(byteArray); 
        outputStream.flush(); 
       } catch (IOException e) { 
        System.out.println("Socket not created"); 
        e.printStackTrace(); 
       } 
      } 
     }).start(); 

注私は、クライアントの出力ストリームを閉じてはいけないので、私は絵のすべての時間を送ることができます。

Answer 1

ImageIO.getImageReaders（imgStream）を使用すると、ソケットストリームでは論理的に見えません。おそらく、すべての画像を一度に使用できると考えられるからです。それがあなたの遅れの理由かもしれません。

第2に、画像を解凍するには、単純なメソッドBitmapFactory.decodeStream（）があります。

第3に、クライアントはすでに「JPG」形式を作成しているため、サーバーは単にそれを保存するだけです。すべてのファイルが送信されたら、最初にバイト数とゼロを送信する必要があります。

クライアント：

new Thread(new Runnable() { 
     @Override 
     public void run() { 
      try { 
       ByteArrayOutputStream memoryStream = new ByteArrayOutputStream(); 
       Bitmap bitmapToSend = 
        Bitmap.createScaledBitmap(bitmapToSend, 900, 800, true); 
       bitmapToSend.compress(
        Bitmap.CompressFormat.JPEG,100, memoryStream); 
       byte[] byteArray = memoryStream.toByteArray(); 
       memoryStream = null; 

       DataOutputStream outputStream = 
          new DataOutputStream(server.getOutputStream()); 
       outputStream.writeInt(byteArray.length); 
       outputStream.write(byteArray); 
       outputStream.flush(); 
      } catch (IOException e) { 
       System.out.println("Socket not created"); 
       e.printStackTrace(); 
      } 
     } 
    }).start(); 

サーバー：

public static void readImages(InputStream stream) { 

    DataInputStream imgInput = new DataInputStream(stream); 
    int index = 0; 
    int byteLength; 

    try { 
     while ((byteLength = imgInput.readInt())>0) { 

      byte[] buffer = new byte[byteLength]; 
      imgInput.readFully(buffer); 

      OutputStream imgOutput = new FileOutputStream("current" + (index++) + ".jpg"); 
      imgOutput.write(buffer); 
      imgOutput.close(); 
     } 
    } catch (IOException ex) { 
     // ............. 
    } finally { 
     try { 
      imgInput.close(); 
     } catch (IOException ex1) { 
      //........... 
     } 
    } 

}