Muat turun fail Android (1)


Pengenalan kepada bahagian ini:

1.gifSatu lagi lubang dalam, pemula harus berhati-hati... Bahagian ini akan dimuat turun daripada benang tunggal biasa -> Muat turun-> -> Dan contoh yang sangat praktikal: menggunakan DownloadManager Android untuk mengemas kini apk Dan tulis ganti kod pelaksanaan pemasangan! Okay, nampaknya bahagian ini agak menarik. Mari kita mulakan bahagian ini! PS: Kami meletakkan keseluruhan penghantaran resume titik putus berbilang benang yang lengkap di bahagian seterusnya!


1. Muat turun fail berbenang tunggal biasa:

Secara langsung gunakan URLConnection.openStream() untuk membuka strim input rangkaian, dan kemudian tulis strim ke fail!

Kaedah teras:

public static void downLoad(String path,Context context)throws Exception
{
  URL url = new URL(path);
  InputStream is = url.openStream();
  //截取最后的文件名
  String end = path.substring(path.lastIndexOf("."));
  //打开手机对应的输出流,输出到文件中
  OutputStream os = context.openFileOutput("Cache_"+System.currentTimeMillis()+end, Context.MODE_PRIVATE);
  byte[] buffer = new byte[1024];
  int len = 0;
  //从输入六中读取数据,读到缓冲区中
  while((len = is.read(buffer)) > 0)
  {
    os.write(buffer,0,len);
  }
  //关闭输入输出流
  is.close();
  os.close();
}

Hasil jalankan:

2.jpg

3.jpg


2. Muat turun berbilang benang biasa:

Kita semua tahu bahawa menggunakan berbilang benang untuk memuat turun fail boleh melengkapkan muat turun fail dengan lebih cepat, tetapi mengapa?

Jawapan: Kerana terdapat banyak sumber pelayan didahulukan, dengan mengandaikan bahawa pelayan boleh melayani sehingga 100 pengguna, satu utas dalam pelayan Sepadan dengan satu pengguna, 100 utas dilaksanakan secara serentak dalam komputer CPU membahagikan kepingan masa dan melaksanakannya secara bergilir-gilir. Memuat turun fail adalah bersamaan dengan menduduki 99 sumber pengguna, yang secara semula jadi membawa kepada kelajuan muat turun yang lebih pantas

PS: Sudah tentu, lebih banyak utas, lebih baik, terlalu banyak utas didayakan. Untuk urutan, apl perlu mengekalkan dan menyegerakkan overhed setiap urutan. Overhed ini akan membawa kepada pengurangan kelajuan muat turun, dan juga berkaitan dengan kelajuan rangkaian anda! Dapatkan sambungan Rangkaian

Buat fail kosong dengan saiz yang sama pada cakera setempatKira bahagian mana fail yang setiap utas perlu mula dimuat turun, tamatkan

    Cipta mengikut turutan, mulakan berbilang Thread untuk memuat turun bahagian sumber rangkaian yang ditentukan
  • PS: Cipta projek Java terus di sini, dan kemudian jalankan kaedah yang ditentukan dalam JUnit ,

Kod teras adalah seperti berikut

:4.png

public class Downloader {
  //添加@Test标记是表示该方法是Junit测试的方法,就可以直接运行该方法了
    @Test
    public void download() throws Exception
    {
      //设置URL的地址和下载后的文件名
      String filename = "meitu.exe";
      String path = "http://10.13.20.32:8080/Test/XiuXiu_Green.exe";
      URL url = new URL(path);
      HttpURLConnection conn = (HttpURLConnection) url.openConnection();
      conn.setConnectTimeout(5000);
      conn.setRequestMethod("GET");
      //获得需要下载的文件的长度(大小)
      int filelength = conn.getContentLength();
      System.out.println("要下载的文件长度"+filelength);
      //生成一个大小相同的本地文件
      RandomAccessFile file = new RandomAccessFile(filename, "rwd");
      file.setLength(filelength);
      file.close();
      conn.disconnect();
      //设置有多少条线程下载
      int threadsize = 3;
      //计算每个线程下载的量
      int threadlength = filelength % 3 == 0 ? filelength/3:filelength+1;
      for(int i = 0;i < threadsize;i++)
      {
        //设置每条线程从哪个位置开始下载
        int startposition = i * threadlength;
        //从文件的什么位置开始写入数据
        RandomAccessFile threadfile = new RandomAccessFile(filename, "rwd");
        threadfile.seek(startposition);
        //启动三条线程分别从startposition位置开始下载文件
        new DownLoadThread(i,startposition,threadfile,threadlength,path).start();
      }
      int quit = System.in.read();
      while('q' != quit)
      {
        Thread.sleep(2000);
      }
    }
  
  
  private class DownLoadThread extends Thread {
    private int threadid;
    private int startposition;
    private RandomAccessFile threadfile;
    private int threadlength;
    private String path;
    public DownLoadThread(int threadid, int startposition,
        RandomAccessFile threadfile, int threadlength, String path) {
      this.threadid = threadid;
      this.startposition = startposition;
      this.threadfile = threadfile;
      this.threadlength = threadlength;
      this.path = path;
    }
    public DownLoadThread() {}
    @Override
    public void run() {
      try
      {
        URL url = new URL(path);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setConnectTimeout(5000);
        conn.setRequestMethod("GET");
        //指定从什么位置开始下载
        conn.setRequestProperty("Range", "bytes="+startposition+"-");
        //System.out.println(conn.getResponseCode());
        if(conn.getResponseCode() == 206)
        {
          InputStream is = conn.getInputStream();
          byte[] buffer = new byte[1024];
          int len = -1;
          int length = 0;
          while(length < threadlength && (len = is.read(buffer)) != -1)
          {
            threadfile.write(buffer,0,len);
            //计算累计下载的长度
            length += len;
          }
          threadfile.close();
          is.close();
          System.out.println("线程"+(threadid+1) + "已下载完成");
        }
      }catch(Exception ex){System.out.println("线程"+(threadid+1) + "下载出错"+ ex);}
    }
    
  }
}

Menjalankan tangkapan skrin:

Seperti ditunjukkan dalam rajah, multi-threading digunakan untuk melengkapkan pemprosesan fail. Klik dua kali fail exe untuk dijalankan, menunjukkan bahawa fail itu tidak rosak! 🎜>

Nota:

  • int filelength = conn.getContentLength(); //Dapatkan panjang (saiz) fail yang dimuat turun
  • Fail RandomAccessFile = RandomAccessFile baharu(nama fail, "rwd"); //Kelas ini dijalankan untuk membaca dan menulis fail, yang merupakan teras muat turun berbilang benang
  • nt threadlength = filelength % 3 == 0 ? //Kira jumlah yang akan dimuat turun oleh setiap urutan
  • conn.setRequestProperty("Julat", "bait="+startposition+"-"); //Nyatakan dari kedudukan mana untuk mula membaca dan menulis, ini disediakan oleh Kaedah Sambungan URL
  • //System.out.println(conn.getResponseCode()); //Kod komen ini digunakan untuk melihat kod pemulangan sambung Kami menggunakan 200 sebelum ini. Untuk multi-threading, ia biasanya 206. Jika perlu, kita boleh menyemak kod pulangan dengan memanggil kaedah ini!
  • int quit = System.in.read();while('q' != quit){Thread.sleep(2000);} //Kod ini adalah untuk operasi tertunda, kerana kami menggunakan muat turun tempatan, mungkin kaedah telah selesai dijalankan, dan kami Urutan belum dimulakan lagi, yang akan menyebabkan pengecualian Di sini, biarkan pengguna memasukkan aksara, dan jika ia adalah 'q', keluar

3. Gunakan. DownloadManager untuk mengemas kini aplikasi dan menulis gantinya Pemasangan:

Kod berikut boleh digunakan terus Selepas menyertai projek, ingat untuk mendaftarkan penapis untuk siaran dalaman ini:

AndroidManifest. xml

:
import android.app.DownloadManager;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.pm.ApplicationInfo;
import android.content.pm.PackageManager;
import android.database.Cursor;
import android.net.Uri;
import android.os.Bundle;
import android.os.Environment;
import android.support.v7.app.AppCompatActivity;

/**
 * Created by Jay on 2015/9/9 0009.
 */
public class UpdateAct extends AppCompatActivity {
    //这个更新的APK的版本部分,我们是这样命名的:xxx_v1.0.0_xxxxxxxxx.apk
    //这里我们用的是git提交版本的前九位作为表示
    private static final String FILE_NAME = "ABCDEFGHI";

    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        String endpoint = "";
        try {
            //这部分是获取AndroidManifest.xml里的配置信息的,包名,以及Meta_data里保存的东西
            ApplicationInfo info = getPackageManager().getApplicationInfo(
                    getPackageName(), PackageManager.GET_META_DATA);
            //我们在meta_data保存了xxx.xxx这样一个数据,是https开头的一个链接,这里替换成http
            endpoint = info.metaData.getString("xxxx.xxxx").replace("https",
                    "http");
        } catch (PackageManager.NameNotFoundException e) {
            e.printStackTrace();
        }
        //下面的都是拼接apk更新下载url的,path是保存的文件夹路径
        final String _Path = this.getIntent().getStringExtra("path");
        final String _Url = endpoint + _Path;
        final DownloadManager _DownloadManager = (DownloadManager) getSystemService(DOWNLOAD_SERVICE);
        DownloadManager.Request _Request = new DownloadManager.Request(
                Uri.parse(_Url));
        _Request.setDestinationInExternalPublicDir(
                Environment.DIRECTORY_DOWNLOADS, FILE_NAME + ".apk");
        _Request.setTitle(this.getString(R.string.app_name));
        //是否显示下载对话框
        _Request.setShowRunningNotification(true);
        _Request.setMimeType("application/com.trinea.download.file");
        //将下载请求放入队列
        _DownloadManager.enqueue(_Request);
        this.finish();
    }



    //注册一个广播接收器,当下载完毕后会收到一个android.intent.action.DOWNLOAD_COMPLETE
    //的广播,在这里取出队列里下载任务,进行安装
    public static class Receiver extends BroadcastReceiver {
        public void onReceive(Context context, Intent intent) {
            final DownloadManager _DownloadManager = (DownloadManager) context
                    .getSystemService(Context.DOWNLOAD_SERVICE);
            final long _DownloadId = intent.getLongExtra(
                    DownloadManager.EXTRA_DOWNLOAD_ID, 0);
            final DownloadManager.Query _Query = new DownloadManager.Query();
            _Query.setFilterById(_DownloadId);
            final Cursor _Cursor = _DownloadManager.query(_Query);
            if (_Cursor.moveToFirst()) {
                final int _Status = _Cursor.getInt(_Cursor
                        .getColumnIndexOrThrow(DownloadManager.COLUMN_STATUS));
                final String _Name = _Cursor.getString(_Cursor
                        .getColumnIndexOrThrow("local_filename"));
                if (_Status == DownloadManager.STATUS_SUCCESSFUL
                        && _Name.indexOf(FILE_NAME) != 0) {

                    Intent _Intent = new Intent(Intent.ACTION_VIEW);
                    _Intent.setDataAndType(
                            Uri.parse(_Cursor.getString(_Cursor
                                    .getColumnIndexOrThrow(DownloadManager.COLUMN_LOCAL_URI))),
                            "application/vnd.android.package-archive");
                    _Intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
                    context.startActivity(_Intent);
                }
            }
            _Cursor.close();
        }
    }
}

4. Muat turun kod rujukan:

Fail muat turun satu utas biasa: DownLoadDemo1.zip Fail muat turun berbilang utas biasa: J2SEMulDownLoader.zip


Ringkasan bahagian ini:

Baiklah, bahagian ini memperkenalkan anda kepada muat turun fail berutas tunggal dan berbilang benang biasa, serta menggunakan DownManager milik Android untuk memuat turun fail. Muat turun APK kemas kini, kemudian tulis ganti pelaksanaan! Saya percaya ia akan memberi kemudahan kepada perkembangan sebenar semua orang Okay, itu sahaja, terima kasih~