zoukankan      html  css  js  c++  java
  • 多线程下载服务端图片资源

    服务端情况是:http://192.168.1.105:8080:/web/sky.jpg 敲回车,就在浏览器展现图片资源>>>>>>> 服务端代码省略。。。。

    down_activity.xml(button是提交网络请求下载图片的,textview是一旦完成下载进行界面提示的)

    <?xml version="1.0" encoding="utf-8"?>
    <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
        android:layout_width="match_parent"
        android:layout_height="match_parent"
        android:orientation="vertical" >
    
        <TextView
            android:id="@+id/textView"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content" />
    
        <Button
            android:id="@+id/button"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:text="下载" />
    
    </LinearLayout>

    DownLoadActivity

    package com.lw.http01;
    
    import android.app.Activity;
    import android.os.Bundle;
    import android.os.Handler;
    import android.view.View;
    import android.widget.Button;
    import android.widget.TextView;
    
    public class DownLoadActivity extends Activity {
    	private TextView textView;
    	private Button button;
    	private int count = 0;
    	private Handler handler = new Handler() {
    		public void handleMessage(android.os.Message msg) {
    			int result = msg.what;
    			count += result;
    			if (count == 3) {
    				// 完成下载更新ui界面就可以
    				textView.setText("download success");
    
    			}
    
    		};
    	};
    
    	@Override
    	protected void onCreate(Bundle savedInstanceState) {
    		super.onCreate(savedInstanceState);
    		setContentView(R.layout.down_activity);
    		textView = (TextView) findViewById(R.id.textView);
    		button = (Button) findViewById(R.id.button);
    
    		button.setOnClickListener(new View.OnClickListener() {
    
    			@Override
    			public void onClick(View v) {
    
    				/**
    				 * 在子线程中获取网络图片
    				 */
    				new Thread() {
    					public void run() {
    						DownLoad load = new DownLoad(handler);
    						load.downLoadFile("http://192.168.1.105:8080:/web/sky.jpg");
    					};
    
    				}.start();
    			}
    		});
    
    	}
    
    }
    

    DownLoad

    package com.lw.http01;
    
    import java.io.File;
    import java.io.InputStream;
    import java.io.RandomAccessFile;
    import java.net.HttpURLConnection;
    import java.net.URL;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Executors;
    
    import android.os.Environment;
    import android.os.Handler;
    import android.os.Message;
    
    public class DownLoad {
    	/**
    	 * 创建3个线程的线程池
    	 */
    	private Executor threadPool = Executors.newFixedThreadPool(3);
    
    	static class DownLoadRunnable implements Runnable {
    		/**
    		 * 定义传递过来的參数
    		 */
    		private String url;
    		private String fileName;
    		private long start;
    		private long end;
    		private Handler handler;
    
    		public DownLoadRunnable(String url, String fileName, long start,
    				long end, Handler handler) {
    			super();
    			this.url = url;
    			this.fileName = fileName;
    			this.start = start;
    			this.end = end;
    			this.handler = handler;
    		}
    
    		@Override
    		public void run() {
    			try {
    				// 创建url地址,而且设置參数值
    				URL httpUrl = new URL(url);
    				HttpURLConnection conn = (HttpURLConnection) httpUrl
    						.openConnection();
    				conn.setReadTimeout(5000);
    				conn.setRequestMethod("GET");
    				// http协议。请求指定长度的流信息
    				conn.setRequestProperty("Range", "bytes=" + start + "-" + end);
    
    				// 定位写入信息到指定文件文件夹中
    				RandomAccessFile access = new RandomAccessFile(new File(
    						fileName), "rwd");
    				// 去捕捉起始点--将文件记录指针定位到pos位置。
    				access.seek(start);
    				// 获取输入路。从server得到文件
    				InputStream in = conn.getInputStream();
    				byte[] b = new byte[1024 * 4];
    				int len = 0;
    				while ((len = in.read(b)) != -1) {
    					// 输出
    					access.write(b, 0, len);
    				}
    				if (access != null) {
    					access.close();
    
    				}
    				if (in != null) {
    					in.close();
    
    				}
    				// 每一个线程完成下载后,发送消息
    				Message message = new Message();
    				message.what = 1;
    				handler.sendMessage(message);
    			} catch (Exception e) {
    
    			}
    		}
    	}
    
    	/**
    	 * 定义handler是由于 在DownLoadRunnable中须要有handler发送消息(每一个线程完成下载发送消息。更新主界面)
    	 */
    	private Handler handler;
    
    	public DownLoad(Handler handler) {
    		this.handler = handler;
    	}
    
    	public void downLoadFile(String url) {
    		try {
    			/**
    			 * 创建url地址信息。而且设置參数
    			 */
    			URL httpUrl = new URL(url);
    			HttpURLConnection conn = (HttpURLConnection) httpUrl
    					.openConnection();
    			conn.setReadTimeout(5000);
    			conn.setRequestMethod("GET");
    
    			// 拿到网络资源的整体大小
    			int count = conn.getContentLength();
    			// 每一个下载下载的大小
    			int block = count / 3;
    			// 获取网路资源的后缀名
    			String fileName = getFile(url);
    			// 得到文件夹的根文件夹
    			File parent = Environment.getExternalStorageDirectory();
    			// 获取文件的真实绝对路径
    			File downLoadFile = new File(parent, fileName);
    			/**
    			 * 11整体大小/3 blcok为3 余2 第一个线程 0-2 第二个线程 3-5 第三个线程 6-10
    			 */
    			for (int i = 0; i < 3; i++) {
    				long start = i * block;
    				long end = (i + 1) * block - 1;
    				if (i == 2) {
    					end = count;
    				}
    				/**
    				 * 传递start、end是由于setRequestProperty由于协议须要这2个參数
    				 * url是由于每一个线程下载须要url地址信息 hander是发送消息。更新ui界面
    				 */
    				DownLoadRunnable runnable = new DownLoadRunnable(url,
    						downLoadFile.getAbsolutePath(), start, end, handler);
    				threadPool.execute(runnable);
    			}
    		} catch (Exception e) {
    
    		}
    	}
    
    	// 通过url拿到文件的后缀名字
    	public String getFile(String url) {
    		return url.substring(url.lastIndexOf("/") + 1);
    	}
    }
    


  • 相关阅读:
    《图解HTTP》简单的HTTP协议
    《图解HTTP》web及网络基础
    尚硅谷--雷丰阳--ElasticSearch 7.4.2版本 -- 有道云笔记
    ElasticSearch _bulk批量插入报错
    SpringBoot利用Filter来解决跨域问题
    js中数组的常用方法
    Mysql时间加减函数
    mybatis映射文件中不能使用">""<""&"问题
    博客园样式第二版
    GO学习笔记之 map
  • 原文地址:https://www.cnblogs.com/yxysuanfa/p/6784417.html
Copyright © 2011-2022 走看看