Android: исключение «неожиданный конец потока» при загрузке больших файлов

Question

Я создаю приложение для Android, и мне нужно загрузить файл с URL-адреса, размер которого составляет 33 МБ.

Здесь задание на загрузку:

try {
            int MAX_BUFFER_SIZE = 4096;
            URL mUrl = new URL(params[0]);
            HttpURLConnection connection = (HttpURLConnection) mUrl.openConnection();
            connection.setRequestMethod("GET");
            long length = connection.getContentLength(), downloaded = 0;
            int read;
            byte [] buffer = new byte[(((int)length) > MAX_BUFFER_SIZE) ? MAX_BUFFER_SIZE : (int)length];
            String filename = getFilename(mUrl);
            File file = new File (SDCARD_ROOT);
            if (!file.exists() || !file.isDirectory()){
                file.mkdir();
            }
            this.filename = filename;
            file = new File (SDCARD_ROOT + this.filename);  
            FileOutputStream fos = new FileOutputStream (file);
            //Start downloading
            InputStream stream = connection.getInputStream();

            while ((read=stream.read(buffer)) > -1){
                fos.write(buffer, 0, read);
                downloaded += read;
                publishProgress((int) ((float) downloaded/length * 100));
            }
            fos.close();
            return 1;
        } catch (Exception e){
            Log.e("REV-PARTS", "Revolver parts error in DownloadTask: " + e.getMessage());  
            return 2;
        }

Оно работает правильно снебольшие файлы (1–15 МБ), но с большими файлами будет возвращено исключение «неожиданный конец потока».

Answer 1

Мне показалось, что установка размера куска сработала.

connection.setChunkedStreamingMode(1048576);

Answer 2

Для больших файлов вам нужно установить время подключения вручную, используя следующий код.Я установил время на 3 минуты

   connection.setConnectTimeout(180000);
   connection.setReadTimeout(180000);

Answer 3

у меня есть ответ на это. Вы должны добавить заголовок к вашему соединению.

connection.setRequestProperty("Accept-Encoding", "identity");

это поможет тебе. Скажи мне, если это поможет ...

Answer 4

пока вы ловите исключение, я пробую метод downContinue (), я могу показать свой код:

private void downloadApk() {
    thread1 = new Thread() {
        public void run() {
            File oFile = null;
            try {
                URL url = new URL(PQGLApplication.resrootURL + "apk/PQGLMap.apk");
                HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
                ReadableByteChannel channel =
                        Channels.newChannel(urlConnection.getInputStream());
                oFile =
                        new File(Environment.getExternalStorageDirectory().getAbsolutePath()
                                + "/" + "hy_ht_new/" + "test2" + ".apk");
                oFile.setWritable(true);
                oFile.setReadable(true);
                if (oFile.exists()) {
                    oFile.delete();
                }
                FileOutputStream fos = new FileOutputStream(oFile);
                fileSize = urlConnection.getContentLength();
                ByteBuffer buffer = ByteBuffer.allocate(1024);
                int noOfBytes = 0;
                byte[] data = null;
                sendApkMessage(0, 0);
                while ((noOfBytes = channel.read(buffer)) > 0) {
                    data = new byte[noOfBytes];
                    System.arraycopy(buffer.array(), 0, data, 0, noOfBytes);
                    buffer.clear();
                    fos.write(data, 0, noOfBytes);
                    downLoadFileSize += noOfBytes;
                    sendApkMessage(1, downLoadFileSize);
                }
                fos.flush();
                fos.close();
                channel.close();
                sendApkMessage(2, oFile.getAbsolutePath());
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                downContinue();
            }
        };
    };
    thread1.start();
}

private void downContinue() {
    continueTime++;
    try {
        if (continueTime == 3) {
            continueTime = 0;
            sendApkMessage(4, 0);
            Log.e("what is the fucking continuetime", "continueTime" + continueTime);
        } else {
            URL url = new URL(PQGLApplication.resrootURL + "apk/PQGLMap.apk");
            HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
            File oFile =
                    new File(Environment.getExternalStorageDirectory().getAbsolutePath() + "/"
                            + "hy_ht_new/" + "test2" + ".apk");
            RandomAccessFile oSavedFile = new RandomAccessFile(oFile, "rw");
            FileOutputStream fos = new FileOutputStream(oFile);
            ReadableByteChannel channel = Channels.newChannel(urlConnection.getInputStream());
            // oSavedFile.seek(nPos);
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            byte[] data = null;
            int temp = 0;
            sendApkMessage(3, oFile.getAbsolutePath());
            while ((temp = channel.read(buffer)) > 0) {
                data = new byte[temp];
                System.arraycopy(buffer.array(), 0, data, 0, temp);
                buffer.clear();
                fos.write(data, 0, temp);
            }
            fos.flush();
            fos.close();
            oSavedFile.close();
            sendApkMessage(2, oFile.getAbsolutePath());
            continueTime = 0;
        }
    } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
        Log.e("what is the fucking exception", e.toString() + continueTime);
        downContinue();
    }

}

этот метод downContinue используется для решения этой проблемы. По крайней мере, файл успешно загружен! Я родом из Китая. Мой английский не очень хорош.