Téléchargement de fichiers Android (1)
Introduction à cette section :
Un autre gouffre profond, les débutants doivent être prudents... Cette section sera téléchargée à partir d'un seul thread ordinaire -> Télécharger-> -> Et un exemple très pratique : utiliser le DownloadManager d'Android pour mettre à jour l'apk Et écrasez le code d'implémentation de l'installation ! D'accord, il semble que cette section soit assez intéressante. Commençons cette section ! PS : Nous mettons l’intégralité de la transmission de reprise du point d’arrêt multithread dans la section suivante !
1. Téléchargement de fichier monothread ordinaire :
Utilisez directement URLConnection.openStream() pour ouvrir le flux d'entrée réseau, puis écrivez le flux dans le dossier !
Méthode de base :
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();
}Résultat d'exécution :
2. Téléchargement multithread ordinaire :
Nous savons tous que l'utilisation du multithread pour télécharger des fichiers peut terminer le téléchargement du fichier plus rapidement, mais pourquoi ?
Réponse : Parce qu'il existe de nombreuses ressources du serveur préemptées, en supposant que le serveur puisse servir jusqu'à 100 utilisateurs, un thread dans le serveur Correspondant à un utilisateur, 100 threads sont exécutés simultanément dans l'ordinateur. Le CPU divise les tranches de temps et les exécute à tour de rôle. Après avoir ajouté un, il y a 99 threads. Le téléchargement de fichiers équivaut à occuper 99 ressources utilisateur, ce qui conduit naturellement à des vitesses de téléchargement plus rapides
PS : Bien sûr, plus il y a de threads, mieux c'est, trop de threads sont activés. Pour les threads, l'application doit maintenir et synchroniser la surcharge de chaque thread. Ces frais généraux entraîneront une réduction de la vitesse de téléchargement, et sont également liés à la vitesse de votre réseau
Processus de téléchargement multithread :
- ! Obtenir une connexion réseau
- Créer un fichier vide de la même taille sur le disque local
- Calculer la partie du fichier dont chaque thread a besoin pour commencer le téléchargement, terminer
Créez en séquence, démarrez plusieurs Threads pour télécharger la partie spécifiée de la ressource réseau
PS : Créez un projet Java directement ici, et puis exécutez la méthode spécifiée dans JUnit ,
Le code principal est le suivant :
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);}
}
}
}Capture d'écran en cours d'exécution :
Comme Comme le montre la figure, le multi-threading est utilisé pour terminer le traitement du fichier. Téléchargez ! Double-cliquez sur le fichier exe à exécuter, indiquant que le fichier n'est pas endommagé ! 🎜>
Remarque :
- int filelength = conn.getContentLength(); //Obtenir la longueur (taille) du fichier téléchargé
- RandomAccessFile file = new RandomAccessFile(filename, "rwd"); //Cette classe s'exécute pour lire et écrire des fichiers, ce qui est au cœur du téléchargement multithread
- nt threadlength = filelength % 3 == 0 filelength/3:filelength+1 ; //Calculez le montant à télécharger par chaque thread
- conn.setRequestProperty("Range", "bytes="+startposition+"-"); //Spécifiez à partir de quelle position commencer la lecture et l'écriture, c'est-à-dire fourni par la méthode URLConnection
- //System.out.println(conn.getResponseCode()); //Ce code commenté est utilisé pour afficher le code retour de conn Nous en avons utilisé 200 auparavant. Pour le multi-threading, il s'agit généralement de 206. Si nécessaire, on peut vérifier le code retour en appelant cette méthode !
- int quit = System.in.read();while('q' != quit){Thread.sleep(2000);} //Ce code est destiné à une opération différée, car nous utilisons le téléchargement local, peut-être que la méthode a fini de s'exécuter et notre Le fil de discussion n'a pas encore été démarré, ce qui provoquera une exception. Ici, laissez l'utilisateur saisir un caractère, et s'il s'agit de « q », quittez
3. Utilisez DownloadManager pour mettre à jour l'application et l'écraser Installation :
Le code suivant peut être utilisé directement Après avoir rejoint le projet, pensez à enregistrer un filtre pour cette diffusion interne :
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. Téléchargement du code de référence :
Fichier de téléchargement simple à thread ordinaire : DownLoadDemo1.zip Fichier de téléchargement multithread ordinaire : J2SEMulDownLoader.zip
Résumé de cette section :
D'accord, cette section vous présente les téléchargements de fichiers ordinaires monothread et multithread, ainsi que l'utilisation du propre DownManager d'Android pour télécharger des fichiers. Téléchargez l’APK de mise à jour, puis écrasez l’implémentation ! Je pense que cela apportera de la commodité au développement réel de chacun. D'accord, c'est tout, merci ~
