回答編集履歴

微修正

2017/10/17 02:47

投稿

abs123

スコア1280

test CHANGED Viewed

@@ -156,7 +156,7 @@
         offset = 0;           // offsetのリセット
-        Arrays.fill(data, 0); // 0埋めされてる必要はあるか？uploadの仕様次第
+        Arrays.fill(data, (byte)0); // 0埋めされてる必要はあるか？uploadの仕様次第
         // あと、uploadの処理が非同期の場合は新しくnewしたほうが安全かも

ソースコード追記

2017/10/17 02:47

投稿

abs123

スコア1280

test CHANGED Viewed

@@ -43,3 +43,179 @@
 実装の全体を見たわけではないので他の部分で送信データ量が制限されている可能性もありますが、
 ちょっと納得できない部分があるので参考程度に・・・
+--- 10/17 追記 ---
+スキル・知識というものはやってみないと身につかないものです。
+吐きながら覚えていきましょう。
+穴あきのソースを書いたのでこんな感じでやってみてください。
+```Java
+public static void uploadPer512KBytes(InputStream in) throws IOException {
+    boolean next; // 繰り返しフラグ
+    // ストリームが終わるまでデータを読み込む外側ループ処理
+    do { // whileでも書けなくはないけど、1回は必ず内側を通る場合do-whileのほうが書きやすい
+        next = false; // 繰り返しフラグは外側ループの頭で毎回初期化する
+        // 512kbのデータを読み込む内側ループ処理
+        while ((bytesRead = in.read(data, offset, data.length - offset)) != -1) {
+            innerLoop++: // これはいくつになるかわからん
+            if (offset >= data.length) {
+                next = true; // ストリームの終わり以外で抜けるので繰り返しフラグをtrueに
+                break;
+            }
+        } // ストリームの終わりで抜けた場合は繰り返しフラグはfalseのまま
+        // 読み込んだデータの送信
+        if (offset >= 1) { // offset=0の状態でここに来ることがあるので
+　　　　　　upload(bais);
+        }
+        outerLoop++; // これが4になるはず
+    } while(next); // 繰り返しフラグが立っている場合は外側処理をループ
+}
+```
+下のコードは答え合わせ?用の動作未確認コードです。
+吐いたら見てください。
+```Java
+// 答え合わせ?用
+public static void uploadPer512KBytes(InputStream in) throws IOException {
+    int offset;
+    int bytesRead;
+    byte[] data = new byte[524288];// バッファ
+    boolean next;
+    int outerLoop = 0;
+    int innerLoop = 0;
+    // ストリームが終わるまでデータを読み込む外側ループ処理
+    do { // whileでも書けなくはないけど、1回は必ず内側を通る場合do-whileのほうが書きやすい
+　　　　// 外側ループ毎の初期化処理
+        offset = 0;           // offsetのリセット
+        Arrays.fill(data, 0); // 0埋めされてる必要はあるか？uploadの仕様次第
+        // あと、uploadの処理が非同期の場合は新しくnewしたほうが安全かも
+        next = false;         // 繰り返しフラグのリセット
+　　　　// 512kbのデータを読み込む内側ループ処理
+        while ((bytesRead = in.read(data, offset, data.length - offset)) != -1) {
+            offset += bytesRead;
+            innerLoop++: // これはいくつになるかわからん
+            if (offset >= data.length) {
+                next = true; // ストリームの終わり以外で抜けるので繰り返しフラグをtrueに
+                break;
+            }
+        } // ストリームの終わりで抜けた場合は繰り返しフラグはfalseのまま
+        // 読み込んだデータの送信
+        if (offset >= 1) { // offset=0の状態でここに来ることがあるので
+            // 端っこのデータを処理する時、
+            // 引数1つのコンストラクタでは余計な部分まで処理することにならないか？
+            // uploadの仕様次第だが、引数3つのコンストラクタを使ったほうがいいような・・・
+            // ByteArrayInputStream bais = new ByteArrayInputStream(data, 0, offset);
+            ByteArrayInputStream bais = new ByteArrayInputStream(data);
+            // バッファに格納した分アップロード
+　　　　　　upload(bais);
+        }
+        // offsetとdataの初期化処理は、ここでやることもできる。
+        // 最初の1回だけあらかじめデータを入れておきたい場合はここで
+        outerLoop++; // これが4になるはず
+    } while(next); // 繰り返しフラグが立っている場合は外側処理をループ
+}
+```

修正

2017/10/17 01:34

投稿

abs123

スコア1280

test CHANGED Viewed

@@ -1,3 +1,45 @@
 InputStreamの実体がただのInputStreamである場合は、
 BufferedInputStreamでラップしてみてください。
+---　追記・・・というより書き直し　---
+BufferedInputStream多分関係ありませんでした。
+で、他に修正できそうなところがあったので書こうと思うのですが、
+コメントで状態を確認してみたらよくわからなくなってきました。
+とりあえず書いておきます。
+問題が発生していると思われるのは、While文の中です。
+バッファが埋まる、またはストリームが終わるまでデータを繰り返し読み込む、
+という処理を行っていると思うのですが、その中でuploadメソッドが呼ばれているため、
+バッファが埋まり切っていない状態のデータを複数回送信してしまっているものと思います。
+※複数回の所が実行毎に違うのは、InputStreamにデータを入れる側の転送速度が実行毎に変わっているからだと思っています。
+これを修正するには、While文を抜けた後でuploadメソッドを呼ぶように修正するだけなのですが、
+それだとバッファ分の512Kbしか送れなくなるので、ストリームが終わったかを確認し、
+ストリームが終わるまで処理を繰り返すWhile文を外側に作る必要があります。
+といった感じなのですが、
+この処理で行くと26回送った時点で13Mb近くのデータが送られていないとおかしいのです・・・
+実装の全体を見たわけではないので他の部分で送信データ量が制限されている可能性もありますが、
+ちょっと納得できない部分があるので参考程度に・・・