1. 全栈程序员必看首页

JavaHTTP下载视频

全栈程序员-用户IM • • 未分类

JavaHTTP下载视频

大家好，又见面了，我是全栈君，今天给大家准备了Idea注册码。

控制层类：

package com.grab.video.controller;

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.io.Writer;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import javax.servlet.ServletContext;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import org.apache.commons.io.FilenameUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.ServletRequestUtils;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
import org.springframework.web.servlet.view.RedirectView;

import com.fasterxml.jackson.core.JsonGenerationException;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.ObjectMapper;

@Controller
public class GrabVideoController {

	private static final Logger LOG = LoggerFactory.getLogger(GrabVideoController.class);

	//private static String filePath="D:\\logs\\video";
	private static String filePath = "/home/grabVideo/";

	@Autowired
	ServletContext context;

	/**
	 * 输入userid能够使用
	 * 
	 * @param request
	 * @param response
	 * @return
	 */
	@RequestMapping(value = "/grab/login", method = { RequestMethod.GET })
	public ModelAndView login(HttpServletRequest request, HttpServletResponse response) {
		String userId = ServletRequestUtils.getStringParameter(request, "userId", "");
		String ts = ServletRequestUtils.getStringParameter(request, "ts", "");
		String sign = ServletRequestUtils.getStringParameter(request, "sign", "");

		ModelAndView mav = new ModelAndView();
		// 身份验证
		if (StringUtils.isNotBlank(userId)) {
			String encryptedSign = EncryptionUtils.md5Hex(ts + userId + "grab");
			if (sign.equals(encryptedSign)) {
				HttpSession session = request.getSession();
				session.setMaxInactiveInterval(5*24*60*60);//秒为单位,设置session周期为5天
				session.setAttribute("userId", userId);// 把userId存放到session
				String url = "/grab/import";
				mav.setView(new RedirectView(url));
				return mav;
			}
		}

		mav.setViewName("video/error");
		return mav;
	}

	/**
	 * 导入文件
	 * 
	 * @return
	 */
	@RequestMapping(value = "/grab/import", method = { RequestMethod.GET })
	public ModelAndView importFile(HttpServletRequest request, HttpServletResponse response) {
		// String userId = ServletRequestUtils.getStringParameter(request,
		// "userId", null);
		ModelAndView mav = new ModelAndView();
		HttpSession session = request.getSession();

		String userId = null;
		if (session.getAttribute("userId") != null) {
			userId = (String) session.getAttribute("userId");
			SqlFileList sqlFileList = new SqlFileList();
			List<FileListModel> list = new ArrayList<FileListModel>();
			try {
				list = sqlFileList.selectDate(userId);
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

			// 从POLYV的API获取文件夹

			mav.addObject("list", list);
			mav.addObject("userId", userId);
			mav.setViewName("video/import");
			return mav;
		}

		mav.setViewName("video/login");
		return mav;

	}

	/**
	 * 删除文件
	 * 
	 * @param request
	 * @param response
	 * @return
	 */
	@RequestMapping(value = "/grab/delete/file", method = { RequestMethod.GET })
	public ResponseEntity<AjaxPostResponse> deleteFile(HttpServletRequest request,
			HttpServletResponse response) {
		String fileId = ServletRequestUtils.getStringParameter(request, "fileId", null);

		MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));
		HttpHeaders headers = new HttpHeaders();
		headers.setContentType(mediaType);

		SqlFileList sqlFileList = new SqlFileList();
		try {
			sqlFileList.deleteDate(fileId);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		AjaxPostResponse resp = new AjaxPostResponse("yes");
		return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);
	}

	/**
	 * 解析文件
	 * 
	 * @return
	 * @throws UnsupportedEncodingException 
	 */
	@RequestMapping(value = "/grab/analysis", method = { RequestMethod.GET })
	public ResponseEntity<AjaxPostResponse> analysisFile(HttpServletRequest request,
			HttpServletResponse response) throws UnsupportedEncodingException {
		Integer fileId = ServletRequestUtils.getIntParameter(request, "fileId", 0);
		String fileUrl = ServletRequestUtils.getStringParameter(request, "fileUrl", "");
		String classifyId = ServletRequestUtils.getStringParameter(request, "classifyId",
				"classifyId");
		String classifyName = ServletRequestUtils.getStringParameter(request, "classifyName", "");
		String userId = ServletRequestUtils.getStringParameter(request, "userId", null);

		MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));
		HttpHeaders headers = new HttpHeaders();
		headers.setContentType(mediaType);

		String errorStr="";
		System.out.println("==========="+userId);
		List<String> urlList = new ArrayList<String>();
		List<String> titleList = new ArrayList<String>();
		try {
			System.out.println("file============"+fileUrl);
			
			CloseableHttpClient httpclient = HttpClients.createDefault();
			HttpGet httpGet = new HttpGet(fileUrl);  
			try {
					CloseableHttpResponse response2 = httpclient.execute(httpGet);
					InputStream is = null;  
			        Scanner sc = null;  
			        Writer os = null;  
			        if (response2.getStatusLine().getStatusCode() == org.apache.http.HttpStatus.SC_OK) {
			            try {  
			                // 2、获取response的entity。
  			                HttpEntity entity = response2.getEntity();  			                is = entity.getContent();  			                //sc = new Scanner(is);			                BufferedReader reader = new BufferedReader(new InputStreamReader(			    					is, "UTF-8"));			                int n=0;			            	String line = null;			    			while ((line = reader.readLine()) != null) {			    				n++;			    				try {									String str = line;									//									String urlstr = str.substring(0, str.indexOf(","));									String title = str.substring(str.lastIndexOf(",") + 1, str.length());									//									urlList.add(urlstr);									titleList.add(title);								} catch (Exception e) {									// TODO Auto-generated catch block									System.out.println("解析失败"+n);									errorStr=errorStr+","+n;									e.printStackTrace();								}			    			}			    			errorStr=errorStr+"行格式原因";			            }catch(Exception e){			            	System.out.println("解析失败");			            } finally {  			                if (sc != null) {  			                    sc.close();  			                }  			                if (is != null) {  			                    is.close();  			                }  			                if (os != null) {  			                    os.close();  			                }  			                if (response2 != null) {  			                    response2.close();  			                }  			            } 			        }			}catch(Exception e){				System.out.println("解析失败");			}					} catch (Exception e) {			// TODO Auto-generated catch block			LOG.info("文件解析失败：" + e);			e.printStackTrace();			AjaxPostResponse resp = new AjaxPostResponse(errorStr+":解析失败");			return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);		}		// 更新状态		SqlFileList sqlFileList = new SqlFileList();		FileListModel file = new FileListModel();		file.setFileId(fileId);		file.setStatus("Y");		try {			sqlFileList.updateDate(file);		} catch (SQLException e1) {			// TODO Auto-generated catch block			LOG.info("文件状态改动成功：" + e1);			e1.printStackTrace();		}		// LOG.info("00000"+classifyName);		classifyName = classifyName.replace("-", "");		// LOG.info(classifyName);		// 加入数据		Date date = new Date();		Timestamp timeStamp = new Timestamp(date.getTime());		GetRandomString randomStr = new GetRandomString();		for (int i = 0; i < urlList.size(); i++) {						VideoListModel video = new VideoListModel();			video.setUserId(userId);			video.setUrl(urlList.get(i));// 视频源地址			video.setTitle(titleList.get(i));// 视频标题			String urlstr = urlList.get(i);			// String path=urlstr.substring(0, urlstr.indexOf("?"));			// String format=path.substring(path.lastIndexOf("."),			// path.length());//视频格式			// String baseName = FilenameUtils.getBaseName(urlstr);			String extendname = FilenameUtils.getExtension(urlstr);			if(extendname.contains("?")){				extendname=extendname.substring(0,extendname.indexOf("?
"));			}			if (StringUtils.isBlank(extendname)) {				extendname = "mp4";			}			String trueName = randomStr.generateRandomString(15);			String filename = trueName + "." + extendname;			video.setTrueName(filename);// 用于下载使用的视频名称			video.setClassifyId(classifyId);			//video.setClassifyName(classifyName.trim());			video.setClassifyName(URLDecoder.decode(classifyName.trim(),"GBK"));			video.setStatus(VideoStatus.NO.getValue());// 等待、			video.setVid("");			video.setCreateTime(timeStamp);			video.setLastDate(timeStamp);						SqlVideoList sqlvideo = new SqlVideoList();			try {				sqlvideo.insertDate(video);// 加入数据库			} catch (SQLException e) {				// TODO Auto-generated catch block				LOG.info("加入数据库:" + e);				e.printStackTrace();				AjaxPostResponse resp = new AjaxPostResponse("no");				return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);			}		}		AjaxPostResponse resp = new AjaxPostResponse("yes");		return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);	}	/**	 * 获取下载进度	 * 	 * @return	 */	@RequestMapping(value = "/grab/download/progress", method = { RequestMethod.POST,			RequestMethod.GET })	public ResponseEntity<AjaxPostResponse> getProgress(HttpServletRequest request,			HttpServletResponse response) {		Integer id = ServletRequestUtils.getIntParameter(request, "videoId", 0);		String userId = ServletRequestUtils.getStringParameter(request, "userId", "test");		String urlstr = ServletRequestUtils.getStringParameter(request, "url", "");		String trueName = ServletRequestUtils.getStringParameter(request, "trueName", "");		MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));		HttpHeaders headers = new HttpHeaders();		headers.setContentType(mediaType);		// LOG.info("--id---"+id+"---u---"+userId);		int content = 1;		int length = 1;		int progress = 1;		HttpSession session = request.getSession();		// LOG.info("-------ccccc4------------"+session.getAttribute("fileSize"+id));		if (session.getAttribute("fileSize" + String.valueOf(id)) == null) {			// 文件大小还没存进session中			List<TaskQueue> list = new ArrayList<TaskQueue>();			SqlTaskQueue stq = new SqlTaskQueue();			try {				list = stq.selectDateOne(String.valueOf(id));			} catch (SQLException e2) {				// TODO Auto-generated catch block				LOG.info("查询文件大小" + e2);				e2.printStackTrace();			}			if (list.size() > 0) {				TaskQueue tQueue = list.get(0);				content = tQueue.getFileSize();				session.setAttribute("fileSize" + String.valueOf(id), content);// 存进session			} else {				URL url = null;				try {					url = new URL(urlstr);					HttpURLConnection connection = (HttpURLConnection) url.openConnection();// 进行连接握手					connection.setRequestMethod("GET");// 请求方式					content = (int) connection.getContentLength();					session.setAttribute("fileSize" + String.valueOf(id), content);// 存进session					// LOG.info("-------content------"+content);				} catch (Exception e1) {					// TODO Auto-generated catch block					LOG.info("链接失败" + e1);					e1.printStackTrace();				}			}		} else {			// 文件大少在session中			String contentString = String.valueOf(session.getAttribute("fileSize"					+ String.valueOf(id)));			// LOG.info("-------ccccc------------"+contentString);			content = Integer.parseInt(contentString.trim());		}		// 文件存储位置、文件命名处理		try {			// String path=urlstr.substring(0, urlstr.indexOf("?"));			// String name=path.substring(path.lastIndexOf("/")+1,			// path.length());			// String filename=name.trim();			String filename = trueName;			File file = new File(filePath, filename);			if (!file.exists()) {				progress = (Integer) session.getAttribute(userId + id);// 将当前下载进度存放到session中。
			} else {				length = (int) file.length();				progress = length * 100 / content;				// 将当前下载进度存放到session中。				session.setAttribute(userId + id, progress);				LOG.info(id + "-------progress------" + progress);			}		} catch (Exception e) {			LOG.info("不能解析的路径：" + e);			AjaxPostResponse resp = new AjaxPostResponse(progress);			return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);		}		AjaxPostResponse resp = new AjaxPostResponse(progress);		return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);	}	/**	 * 批量抓取视频(下载视频模块--依据视频源地址去抓取视频)管理	 * 	 * @return	 * @throws MalformedURLException	 */	@RequestMapping(value = "/grab/download/manage", method = { RequestMethod.POST })	public ModelAndView grabDownloadVideo(HttpServletRequest request, HttpServletResponse response) {		int[] id = ServletRequestUtils.getIntParameters(request, "videoId");		String userId = ServletRequestUtils.getStringParameter(request, "userId", "test");		String[] urlstr = ServletRequestUtils.getStringParameters(request, "url");		String[] trueName = ServletRequestUtils.getStringParameters(request, "trueName");		int len = id.length;		List<TaskQueue> taskQueues = new ArrayList<TaskQueue>();		for (int i = 0; i < len; i++) {			TaskQueue tq = new TaskQueue();			tq.setTaskId(String.valueOf(id[i]));			tq.setVideoId(id[i]);			tq.setUserId(userId);			tq.setVideoUrl(urlstr[i]);			tq.setTrueName(trueName[i]);			taskQueues.add(tq);		}				// 把任务队列加入进数据库		if (taskQueues.size() > 0) {			// 存在有任务			for (int i = 0; i < taskQueues.size(); i++) {				TaskQueue task = taskQueues.get(i);				List<TaskQueue> taskList = new ArrayList<TaskQueue>();// 查询任务是否已存在				try {					SqlTaskQueue stq = new SqlTaskQueue();					taskList = stq.selectDateOne(task.getTaskId());				} catch (SQLException e1) {					// TODO Auto-generated catch block					e1.printStackTrace();				}				if (taskList.size() > 0) {					// 该任务已存在				} else {					task.setFileSize(0);					task.setProgress(0);					task.setStatus("N");					Date date = new Date();					Timestamp timeStamp = new Timestamp(date.getTime());					task.setCreateTime(timeStamp);					try {						SqlTaskQueue stq = new SqlTaskQueue();						stq.insertDate(task);					} catch (SQLException e) {						// TODO Auto-generated catch block						LOG.info("下载任务加入失败。" + e);						e.printStackTrace();					}				}			}		}		// 获取全部的任务队列		List<TaskQueue> workQueues = new ArrayList<TaskQueue>();		try {			SqlTaskQueue stq = new SqlTaskQueue();			workQueues = stq.selectDate(userId);		} catch (SQLException e) {			// TODO Auto-generated catch block			LOG.info("获取下载任务失败" + e);			e.printStackTrace();		}		// ExecutorService pool = Executors.newFixedThreadPool(3);		if (workQueues.size() > 0) {			for (int i = 0; i < workQueues.size(); i++) {				String taskId = workQueues.get(i).getTaskId();				String urltxt = workQueues.get(i).getVideoUrl();				String filename = workQueues.get(i).getTrueName();				File saveFile = new File(filePath, filename);// 文件保存的位置				File fileDir = new File(filePath);				if (!fileDir.exists()) {					fileDir.mkdirs();// 文件夹不存在创建文件夹				}				URL url = null;				try {					url = new URL(workQueues.get(i).getVideoUrl());				} catch (MalformedURLException e) {					// TODO Auto-generated catch block					LOG.info("握手失败" + e);					e.printStackTrace();				}				if (url != null) {					// 将下载任务线程。放入线程池中运行					ExecutorService executor = (ExecutorService) context							.getAttribute("DOWNLOAD_EXECUTOR");					executor.submit(new DownloadVideo(url, saveFile, taskId));					// pool.execute(new					// DownloadVideo(url,saveFile,taskId));////////////////////////////////////					VideoListModel vlm = new VideoListModel();					vlm.setId(workQueues.get(i).getVideoId());					vlm.setUserId(userId);					vlm.setStatus(VideoStatus.WAIT.getValue());// 将状态改为等待					try {						SqlVideoList svl = new SqlVideoList();						svl.updateDate(vlm);					} catch (SQLException e) {						// TODO Auto-generated catch block						LOG.info("更改下载状态失败" + e);						e.printStackTrace();					}				}			}		}		// 关闭线程池		// pool.shutdown();		// 又一次查询视频列表		List<VideoListModel> list = new ArrayList<VideoListModel>();		try {			SqlVideoList svl = new SqlVideoList();			list = svl.selectDate(userId);		} catch (SQLException e) {			// TODO Auto-generated catch block			e.printStackTrace();		}		ModelAndView mav = new ModelAndView();		mav.addObject("videolist", list);		mav.addObject("userId", userId);		mav.setViewName("video/download");		return mav;	}	/**	 * 获取视频的下载进度()	 * @param request	 */	@RequestMapping(value="/grab/download/status",method = {RequestMethod.GET,RequestMethod.POST})	public @ResponseBody	ResponseEntity<String> downloadStatus(HttpServletRequest request, HttpServletResponse response)			throws JsonGenerationException, JsonMappingException, IOException {				HttpSession session = request.getSession();		if (session.getAttribute("userId") != null) {			String userId = (String) session.getAttribute("userId");			List<VideoListModel> list = new ArrayList<VideoListModel>();			try {				SqlVideoList sqlVideoList = new SqlVideoList();				list = sqlVideoList.selectAllDate(userId);			    //list = sqlVideoList.selectExecuteDate(userId);				for (int i = 0; i < list.size(); i++) {					VideoListModel model = list.get(i);					String filename = model.getTrueName();					File file = new File(filePath, filename);					if (file.exists()) {						int downloaded = (int) file.length();						if (model.getFileSize() != 0) {							//System.out.println(model.getId()+"===n==="+model.getTrueName()+"===d==="+downloaded+"===s==="+model.getFileSize()+"===="+(long)downloaded * 100 /(long) model.getFileSize());							model.setPercent((int) ((long)downloaded * 100 /(long) model.getFileSize()));						} 					}				}				ObjectMapper objectMapper = new ObjectMapper();				String result = objectMapper.writeValueAsString(list);				MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));				HttpHeaders headers = new HttpHeaders();				headers.setContentType(mediaType);				return new ResponseEntity<String>(result, headers, HttpStatus.OK);			} catch (SQLException e) {				// TODO Auto-generated catch block				System.out.println("获取下载进度出现异常。");				e.printStackTrace();			}		}		return null;	}	@RequestMapping(value = "/grab/download/manage", method = { RequestMethod.GET })	public ModelAndView grabVideo(HttpServletRequest request, HttpServletResponse response) {		// String userId = ServletRequestUtils.getStringParameter(request,		// "userId", "");		String userId = null;		ModelAndView mav = new ModelAndView();		HttpSession session = request.getSession();		if (session.getAttribute("userId") != null) {			userId = (String) session.getAttribute("userId");			SqlVideoList sqlVideoList = new SqlVideoList();			List<VideoListModel> list = new ArrayList<VideoListModel>();			try {				list = sqlVideoList.selectDate(userId);			} catch (SQLException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}			mav.addObject("videolist", list);			mav.addObject("userId", userId);			mav.setViewName("video/download");			return mav;		}		mav.setViewName("video/login");		return mav;	}		/**	 * 暂停下载	 */	@RequestMapping(value = "/grab/video/stop", method = { RequestMethod.GET })	public ResponseEntity<AjaxPostResponse> downloadStop(HttpServletRequest request,			HttpServletResponse response) {		int id = ServletRequestUtils.getIntParameter(request, "videoId",0);		String userId = ServletRequestUtils.getStringParameter(request, "userId", "test");		//String urlstr = ServletRequestUtils.getStringParameter(request, "url","");		//String trueName = ServletRequestUtils.getStringParameter(request, "trueName","");				MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));		HttpHeaders headers = new HttpHeaders();		headers.setContentType(mediaType);						try {			SqlTaskQueue stq = new SqlTaskQueue();			stq.deleteDate(String.valueOf(id));		} catch (SQLException e) {			// TODO Auto-generated catch block			e.printStackTrace();		}						// 获取全部的任务队列		List<TaskQueue> workQueues = new ArrayList<TaskQueue>();		try {			SqlTaskQueue stq = new SqlTaskQueue();			workQueues = stq.selectDate(userId);		} catch (SQLException e) {			// TODO Auto-generated catch block			LOG.info("获取下载任务失败" + e);			e.printStackTrace();		}		// ExecutorService pool = Executors.newFixedThreadPool(3);		if (workQueues.size() > 0) {			for (int i = 0; i < workQueues.size(); i++) {				String taskId = workQueues.get(i).getTaskId();				String urltxt = workQueues.get(i).getVideoUrl();				String filename = workQueues.get(i).getTrueName();				File saveFile = new File(filePath, filename);// 文件保存的位置				File fileDir = new File(filePath);				if (!fileDir.exists()) {					fileDir.mkdirs();// 文件夹不存在创建文件夹				}				URL url = null;				try {					url = new URL(workQueues.get(i).getVideoUrl());				} catch (MalformedURLException e) {					// TODO Auto-generated catch block					LOG.info("握手失败" + e);					e.printStackTrace();				}				if (url != null) {					// 将下载任务线程，放入线程池中运行					ExecutorService executor = (ExecutorService) context							.getAttribute("DOWNLOAD_EXECUTOR");					executor.submit(new DownloadVideo(url, saveFile, taskId));					// pool.execute(new					// DownloadVideo(url,saveFile,taskId));////////////////////////////////////					VideoListModel vlm = new VideoListModel();					vlm.setId(workQueues.get(i).getVideoId());					vlm.setUserId(userId);					vlm.setStatus(VideoStatus.WAIT.getValue());// 将状态改为等待					try {						SqlVideoList svl = new SqlVideoList();						svl.updateDate(vlm);					} catch (SQLException e) {						// TODO Auto-generated catch block						LOG.info("更改下载状态失败" + e);						e.printStackTrace();					}				}			}		}				System.out.println("停止下载！
");		AjaxPostResponse resp = new AjaxPostResponse("yes");		return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);	}	/**	 * 导出下载成功的视频	 * 	 * @return	 */	@RequestMapping(value = "/grab/export", method = { RequestMethod.GET })	public ModelAndView exportVideo(HttpServletRequest request, HttpServletResponse response) {		// String userId = ServletRequestUtils.getStringParameter(request,		// "userId", "");		String userId = null;		ModelAndView mav = new ModelAndView();		HttpSession session = request.getSession();		if (session.getAttribute("userId") != null) {			userId = (String) session.getAttribute("userId");			SqlVideoList sqlVideoList = new SqlVideoList();			List<VideoListModel> list = new ArrayList<VideoListModel>();			try {				list = sqlVideoList.selectSuccessDate(userId);			} catch (SQLException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}			mav.addObject("videolist", list);			mav.addObject("userId", userId);			mav.setViewName("video/export");			return mav;		}		mav.setViewName("video/login");		return mav;	}	/**	 * export导出文件	 */	@RequestMapping(value = "/grab/export/csv", method = { RequestMethod.GET })	public void exportCsv(HttpServletRequest request, HttpServletResponse response) {		String userId = ServletRequestUtils.getStringParameter(request, "userId", "");		if (StringUtils.isNotBlank(userId)) {			SqlVideoList sqlVideoList = new SqlVideoList();			List<VideoListModel> list = new ArrayList<VideoListModel>();			try {				list = sqlVideoList.selectSuccessDate(userId);			} catch (SQLException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}			// 导出txt文件			//response.setContentType("text/plain");			response.setContentType("text/csv;  charset=UTF-8");			String fileName = "videolist";			try {				fileName = URLEncoder.encode("videolist", "UTF-8");			} catch (UnsupportedEncodingException e1) {				// TODO Auto-generated catch block				e1.printStackTrace();			}			response.setHeader("Content-Disposition", "attachment; filename=" + fileName + ".csv");			BufferedOutputStream buff = null;			StringBuffer write = new StringBuffer();			String enter = "\r\n";			ServletOutputStream outSTr = null;			try {				outSTr = response.getOutputStream(); // 建立				buff = new BufferedOutputStream(outSTr);				// 把内容写入文件				if (list.size() > 0) {					for (int i = 0; i < list.size(); i++) {						write.append(list.get(i).getUrl());						write.append(",");						write.append(list.get(i).getTitle());						write.append(",");						write.append(list.get(i).getVid());						write.append(",");						write.append(list.get(i).getLastDate());						write.append(enter);					}				}				buff.write(write.toString().getBytes("GBK"));				buff.flush();				buff.close();			} catch (Exception e) {				e.printStackTrace();			} finally {				try {					buff.close();					outSTr.close();				} catch (Exception e) {					e.printStackTrace();				}			}		}	}			/**	 * 清空导出视频列表	 * /grab/export/clean	 */	@RequestMapping(value = "/grab/export/clean", method = { RequestMethod.GET })	public ResponseEntity<AjaxPostResponse> cleanVideo(HttpServletRequest request,			HttpServletResponse response) {		MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));		HttpHeaders headers = new HttpHeaders();		headers.setContentType(mediaType);		HttpSession session = request.getSession();		if (session.getAttribute("userId") != null) {			String userId=(String) session.getAttribute("userId");			SqlVideoList sqlVideoList=new SqlVideoList();			try {				sqlVideoList.cleanDate(userId);			} catch (SQLException e) {				// TODO Auto-generated catch block				e.printStackTrace();			}						//删除成功			System.out.println("删除成功！
");			AjaxPostResponse resp = new AjaxPostResponse("yes");			return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);		}else{			//删除失败			System.out.println("删除失败！");			AjaxPostResponse resp = new AjaxPostResponse("no");			return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);		}		}		/**	 * 删除视频	 * /grab/export/clean	 */	@RequestMapping(value = "/grab/delete/videoId", method = { RequestMethod.GET })	public ResponseEntity<AjaxPostResponse> deleteVideo(HttpServletRequest request,			HttpServletResponse response) {		String videoId = ServletRequestUtils.getStringParameter(request, "videoId", null);		MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));		HttpHeaders headers = new HttpHeaders();		headers.setContentType(mediaType);		if (StringUtils.isNotBlank(videoId)) {			SqlVideoList sqlVideoList=new SqlVideoList();			try {				SqlTaskQueue stqSe=new SqlTaskQueue();				List<TaskQueue> list=stqSe.selectDateOne(videoId);				if(list.size()>0){					SqlTaskQueue stq=new SqlTaskQueue();					stq.deleteDate(videoId);//删除任务				}				sqlVideoList.deleteDate(videoId);//删除视频			} catch (SQLException e) {				// TODO Auto-generated catch block				System.out.println("删除失败"+e);				e.printStackTrace();			}						//删除成功			AjaxPostResponse resp = new AjaxPostResponse("yes");			return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);		}else{			//删除失败			AjaxPostResponse resp = new AjaxPostResponse("no");			return new ResponseEntity<AjaxPostResponse>(resp, headers, HttpStatus.OK);		}		}				/***	 * 获取文件内容	 * @param url	 * @return	 */	public String httpGetFile(String url) {		String contentStr="";		CloseableHttpClient httpclient = HttpClients.createDefault();		HttpGet httpGet = new HttpGet(url);  		try {			CloseableHttpResponse response = httpclient.execute(httpGet);			InputStream is = null;  	        Scanner sc = null;  	        Writer os = null;  	        if (response.getStatusLine().getStatusCode() == org.apache.http.HttpStatus.SC_OK) {  	            try {  	                // 2、获取response的entity。  	                HttpEntity entity = response.getEntity();  	                is = entity.getContent();  	                sc = new Scanner(is);  	                while (sc.hasNext()) {  	                	contentStr=contentStr+sc.nextLine();	                }  	            } catch (ClientProtocolException e) {  	                e.printStackTrace();  	            } finally {  	                if (sc != null) {  	                    sc.close();  	                }  	                if (is != null) {  	                    is.close();  	                }  	                if (os != null) {  	                    os.close();  	                }  	                if (response != null) {  	                    response.close();  	                }  	            }  	        }  	  		} catch (ClientProtocolException e) {			// TODO Auto-generated catch block			e.printStackTrace();		} catch (IOException e) {			// TODO Auto-generated catch block			e.printStackTrace();		}				return contentStr;	}	}

下载视频主线程类： 

package com.grab.video.controller;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.io.Writer;
import java.net.HttpURLConnection;
import java.net.ProtocolException;
import java.net.URL;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Scanner;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;

public class DownloadVideo implements Runnable {

	private static final Logger LOG = LoggerFactory.getLogger(DownloadVideo.class);

	private static String TAG = "Downloader";
	private HttpURLConnection connection;
	private URL url;
	private File saveFile;
	private long fileLength;// 文件总大少
	private int progress;// 当前进度
	private long downloaded = 0;
	private boolean stop=false;
	private String taskId;
	private static String fileUrl = "http://grab.polyv.net/video/";

	private boolean downloadStatus = false;

	public DownloadVideo(URL url, File saveFile, String taskId) {
		this.url = url;
		this.saveFile = saveFile;
		this.taskId = taskId;
	}
	
	public DownloadVideo(URL url, File saveFile, String taskId,boolean stop) {
		this.url = url;
		this.saveFile = saveFile;
		this.taskId = taskId;
		this.stop = stop;
	}

	public DownloadVideo(String vid, File saveFile) {
		// 通过vid,获取视频TODO
	}

	public URL getUrl() {
		return url;
	}

	public void setUrl(URL url) {
		this.url = url;
	}

	public void setStop(boolean stop) {
		this.stop = stop;
	}

	public long getFileLength() {
		return fileLength;
	}

	public int getProgress() {
		return progress;
	}

	public void setProgress(int progress) {
		this.progress = progress;
	}

	public long getDownloaded() {
		return downloaded;
	}

	public int getPercent() {
		if (fileLength == 0) {
			return 0;
		}
		return (int) (downloaded * 100 / fileLength);
	}

	public void stop() {
		stop = true;
	}

	public void start() {
		stop = false;
	}

	// 開始运行,实现run方法
	public void run() {

		
		

		VideoListModel vlm = new VideoListModel();
		vlm.setId(Integer.valueOf(taskId));
		vlm.setStatus(VideoStatus.EXECUTE.getValue());// 将状态改为正在运行
		try {
			SqlVideoList sqlVideoList = new SqlVideoList();
			System.out.println("更新下载中状态。。。。");
			sqlVideoList.updateDate(vlm);
		} catch (SQLException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		try {
			BufferedInputStream in = null;
			FileOutputStream fos = null;
			BufferedOutputStream bout = null;
			print("start download:" + url);
			connection = (HttpURLConnection) url.openConnection();// 进行连接握手
			connection.setRequestProperty("User-Agent", "Polyv");

			Map<String, List<String>> map = connection.getRequestProperties();
			print(map.toString());// 输出參数
			connection.setRequestMethod("GET");// 请求方式
			if (saveFile.exists()) {
				downloaded = saveFile.length();
				connection.setRequestProperty("Range", "bytes=" + downloaded + "-");
			} else {
				downloaded = 0;// 又一次開始下载
			}
			// connection.getResponseCode() == 200 206?
			int code = connection.getResponseCode();// 获取状态码			print("code=" + code + ", downloaded =" + downloaded);			printResponseHeader(connection);			// http200状态,又一次開始下载。206状态续点下载			if (connection.getResponseCode() == 206 || connection.getResponseCode() == 200) {				String range = "";				HashMap<String, String> header = (HashMap<String, String>) getHttpResponseHeader(connection);               				for (Map.Entry<String, String> entry : header.entrySet()) {					String key = entry.getKey();					String value = entry.getValue();					System.out.println(key+"============="+value);					if (key.equals("Content-Range")) {						range = entry.getValue();					}				}				System.out.println("-----range-----"+range);				long content = (long) connection.getContentLength();				fileLength = range.equals("") ? content : Long.valueOf(range.split("/")[1]);				System.out.println("文件===c==="+content+"===f==="+fileLength+"======"+(long)(content+downloaded));				try {					SqlVideoList sqlVideoList = new SqlVideoList();					sqlVideoList.updateFileSize(Integer.valueOf(taskId),content+downloaded);//获取文件的大少(合计才是文件的大少,content是还有多少下载的，downloaded已下载的大少)				} catch (SQLException e2) {					// TODO Auto-generated catch block					System.out.println("获取文件大少失败");					e2.printStackTrace();				}				in = new BufferedInputStream(connection.getInputStream());				fos = (downloaded == 0) ? new FileOutputStream(saveFile) : new FileOutputStream(						saveFile, true);				bout = new BufferedOutputStream(fos, 1024);				byte[] data = new byte[1024];				int x = 0;				boolean p = false;				while (!stop && (x = in.read(data, 0, 1024)) >= 0) {					bout.write(data, 0, x);					downloaded += x;				}				bout.close();				System.out.println("下载完毕{}");				downloadStatus = false;// 代表下载成功。不用去更新下载失败的状态				String vid = null;				// 获取vid,(依据taskId即videoId获取视频的title,cataId)				List<VideoListModel> videoList = new ArrayList<VideoListModel>();				try {					SqlVideoList sqlVideoList = new SqlVideoList();					videoList = sqlVideoList.selectDateOne(Integer.valueOf(taskId));				} catch (SQLException e1) {					// TODO Auto-generated catch block					e1.printStackTrace();				}				if (videoList.size() > 0) {					VideoListModel video = videoList.get(0);					String title = video.getTitle().replace(" ", "");					String cataid = video.getClassifyId();					String userid = video.getUserId();					String trueName = video.getTrueName();					long ts = System.currentTimeMillis();					String sign = EncryptionUtils.md5Hex(ts + userid + "grab");					String url = fileUrl + trueName;					 String pathStr="http://v.polyv.net/uc/services/rest?method=uploadForDownloader&fileUrl="+url+"&userid="+userid+"&title="+title+"&cataid="+cataid+"&ts="+ts+"&sign="+sign;					 System.out.println("----url-----"+pathStr);					 vid=httpGetVid(pathStr);//获取vid					 if(vid==null){						 try {							Thread.sleep(1000);						} catch (InterruptedException e) {							// TODO Auto-generated catch block							e.printStackTrace();						}						 vid=httpGetVid(pathStr);//获取vid					 }					 					 //第二次					 if(vid==null){						 try {							Thread.sleep(1000);						} catch (InterruptedException e) {							// TODO Auto-generated catch block							e.printStackTrace();						}						 vid=httpGetVid(pathStr);//获取vid					 }					 					 					 System.out.println("------下载完毕获取vid---------" + vid);				}				// 下载完毕，更改视频状态为SUCCESS				VideoListModel video = new VideoListModel();				video.setId(Integer.valueOf(taskId));				video.setStatus(VideoStatus.SUCCESS.getValue());				video.setVid(vid);				Date date = new Date();				Timestamp timeStamp = new Timestamp(date.getTime());				video.setLastDate(timeStamp);				try {					SqlVideoList sqlVideoList = new SqlVideoList();					sqlVideoList.updateDateVid(video);				} catch (SQLException e) {					// TODO Auto-generated catch block					System.out.println("下载完毕,更改视频状态失败" + e);					e.printStackTrace();				}				// 下载完毕，从任务队列移除该任务				try {					SqlTaskQueue stq = new SqlTaskQueue();					stq.deleteDate(taskId);				} catch (SQLException e) {					// TODO Auto-generated catch block					System.out.println("任务移除失败" + e);					e.printStackTrace();				}			}else if (connection.getResponseCode() == 416) {				// 416- 请求长度超出范围				System.out.println("已经下载完了======"+connection.getResponseCode());				downloadStatus = false;// 代表下载失败，要去更新下载失败的状态			}else {				downloadStatus = true;// 代表下载失败。要去更新下载失败的状态			}		} catch (NumberFormatException e) {			// TODO Auto-generated catch block			downloadStatus = true;// 代表下载失败，要去更新下载失败的状态			e.printStackTrace();		} catch (ProtocolException e) {			// TODO Auto-generated catch block			downloadStatus = true;// 代表下载失败，要去更新下载失败的状态			e.printStackTrace();		} catch (FileNotFoundException e) {			// TODO Auto-generated catch block			downloadStatus = true;// 代表下载失败。要去更新下载失败的状态			e.printStackTrace();		} catch (IOException e) {			// TODO Auto-generated catch block			downloadStatus = true;// 代表下载失败。要去更新下载失败的状态			e.printStackTrace();		}		if (downloadStatus) {			// 下载失败，更改视频状态			VideoListModel video = new VideoListModel();			video.setId(Integer.valueOf(taskId));			video.setStatus(VideoStatus.FAIL.getValue());			try {				SqlVideoList sqlVideoList = new SqlVideoList();				sqlVideoList.updateDate(video);			} catch (SQLException e) {				// TODO Auto-generated catch block				System.out.println("下载失败,更改视频状态失败" + e);				e.printStackTrace();			}		}else{			// 下载完毕。从任务队列移除该任务			try {				SqlTaskQueue stq = new SqlTaskQueue();				stq.deleteDate(taskId);			} catch (SQLException e) {				// TODO Auto-generated catch block				System.out.println("任务移除失败" + e);				e.printStackTrace();			}						VideoListModel video = new VideoListModel();			video.setId(Integer.valueOf(taskId));			video.setStatus(VideoStatus.SUCCESS.getValue());			Date date = new Date();			Timestamp timeStamp = new Timestamp(date.getTime());			video.setLastDate(timeStamp);			try {				SqlVideoList sqlVideoList = new SqlVideoList();				sqlVideoList.updateSuccessDate(video);			} catch (SQLException e) {				// TODO Auto-generated catch block				System.out.println("下载好了,更改视频状态失败" + e);				e.printStackTrace();			}		}	}	/**	 * 获取对应头部	 * 	 * @param http	 * @return	 */	public static Map<String, String> getHttpResponseHeader(HttpURLConnection http) {		Map<String, String> header = new LinkedHashMap<String, String>();		for (int i = 0;; i++) {			String mine = http.getHeaderField(i);			String key = http.getHeaderFieldKey(i);			System.out.println(key+"=======test======="+mine);			if (key == null || mine == null) {				break;			} else {				header.put(http.getHeaderFieldKey(i), mine);			}		}		return header;	}	/**	 * 输出信息	 * 	 * @param msg	 */	private static void print(String msg) {		// Log.i(TAG, msg);		System.out.println(TAG + "TAG{}," + msg);	}	/**	 * 输出对应头信息	 * 	 * @param http	 */	public static void printResponseHeader(HttpURLConnection http) {		Map<String, String> header = getHttpResponseHeader(http);		for (Map.Entry<String, String> entry : header.entrySet()) {			String key = entry.getKey() != null ?
 entry.getKey() + ":" : "";			print(key + entry.getValue());		}	}	/**	 * 发送请求，获取API数据	 * 	 * @param userId	 * @return 	 *         http://beta.polyv.net/uc/services/rest?url=http://grap.polyv.net/xxx	 *         .mp4&title=filename&cataid=xxx&ts=&userid=&sign=	 */	public String httpGetVid(String url) {		String contentStr = "";		String vid = null;		String urlStr = url;		CloseableHttpClient httpclient = HttpClients.createDefault();		HttpGet httpGet = new HttpGet(urlStr);		try {			CloseableHttpResponse response = httpclient.execute(httpGet);			InputStream is = null;			Scanner sc = null;			Writer os = null;			if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {				try {					// 2、获取response的entity。					HttpEntity entity = response.getEntity();					is = entity.getContent();					sc = new Scanner(is);					while (sc.hasNext()) {						contentStr = contentStr + sc.nextLine();					}				} catch (ClientProtocolException e) {					e.printStackTrace();				} finally {					if (sc != null) {						sc.close();					}					if (is != null) {						is.close();					}					if (os != null) {						os.close();					}					if (response != null) {						response.close();					}				}			}		} catch (ClientProtocolException e) {			// TODO Auto-generated catch block			e.printStackTrace();		} catch (IOException e) {			// TODO Auto-generated catch block			e.printStackTrace();		}		if (StringUtils.isNotBlank(contentStr)) {			System.out.println("====="+contentStr);			Pattern pattern = Pattern.compile("\"vid\":\"([0-9a-z_]{34})\"");			Matcher matcher = pattern.matcher(contentStr);			if(matcher.find()){				vid = matcher.group(1);				System.out.println(vid);			}					}		if (vid != null) {			return vid;		} else {			return "";		}	}}

线程池类： 

package com.grab.video.listener;

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

/**
 * Hands out threads from the wrapped threadfactory with setDeamon(true), so the
 * threads won't keep the JVM alive when it should otherwise exit.
 */
public class DaemonThreadFactory implements ThreadFactory {

    private final ThreadFactory factory;

    /**
     * Construct a ThreadFactory with setDeamon(true) using
     * Executors.defaultThreadFactory()
     */
    public DaemonThreadFactory() {
        this(Executors.defaultThreadFactory());
    }

    /**
     * Construct a ThreadFactory with setDeamon(true) wrapping the given factory
     * 
     * @param thread
     *            factory to wrap
     */
    public DaemonThreadFactory(ThreadFactory factory) {
        if (factory == null)
            throw new NullPointerException("factory cannot be null");
        this.factory = factory;
    }

    public Thread newThread(Runnable r) {
        final Thread t = factory.newThread(r);
        t.setDaemon(true);
        return t;
    }
}

任务运行线程池： 

package com.grab.video.listener;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

public class ExecutorContextListener implements ServletContextListener {
	private ExecutorService executor;

	public void contextInitialized(ServletContextEvent arg0) {
		ServletContext context = arg0.getServletContext();
		int nr_executors = 3;
		ThreadFactory daemonFactory = new DaemonThreadFactory();
		try {
			nr_executors = Integer.parseInt(context.getInitParameter("nr-executors"));
		} catch (NumberFormatException ignore) {
		}

		if (nr_executors <= 1) {
			executor = Executors.newSingleThreadExecutor(daemonFactory);
		} else {
			executor = Executors.newFixedThreadPool(nr_executors, daemonFactory);
		}
		context.setAttribute("DOWNLOAD_EXECUTOR", executor);
	}

	public void contextDestroyed(ServletContextEvent arg0) {
		ServletContext context = arg0.getServletContext();
		executor.shutdownNow(); // or process/wait until all pending jobs are
								// done
	}
}

web.xml(项目启动时，启动任务线程类) 

<?
xml version="1.0" encoding="UTF-8"?><web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"	xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee"	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"	id="school" version="2.5">  <display-name>Archetype Created Web Application</display-name>  	  	<context-param>			<param-name>contextConfigLocation</param-name>			<param-value>				classpath:applicationContext.xml			</param-value>		</context-param>		<listener>			<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>		</listener>		<listener>    		<listener-class>com.grab.video.listener.ExecutorContextListener</listener-class>  		</listener>						<filter>			<filter-name>encodingFilter</filter-name>			<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>			<init-param>				<param-name>encoding</param-name>				<param-value>UTF-8</param-value>			</init-param>			<init-param>				<param-name>forceEncoding</param-name>				<param-value>true</param-value>			</init-param>		</filter>		<filter-mapping>			<filter-name>encodingFilter</filter-name>			<url-pattern>/*</url-pattern>		</filter-mapping>										<servlet>			<servlet-name>dispatcher</servlet-name>			<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>			<load-on-startup>1</load-on-startup>		</servlet>		<servlet-mapping>			<servlet-name>dispatcher</servlet-name>			<url-pattern>/</url-pattern>		</servlet-mapping>										<session-config>			<session-timeout>120</session-timeout>		</session-config>				<welcome-file-list>			<welcome-file>index.jsp</welcome-file>		</welcome-file-list>		<error-page>			<error-code>403</error-code>			<location>/error/403</location>		</error-page>		<error-page>			<error-code>404</error-code>			<location>/error/404</location>		</error-page></web-app>

下载页面： 

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>

<%@ page language="java" 
import="java.util.List"
import="com.grab.video.controller.VideoListModel"
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">
    
	<title>视频</title>
    
	<meta http-equiv="pragma" content="no-cache">
	<meta http-equiv="cache-control" content="no-cache">
	<meta http-equiv="expires" content="0">    
	<meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
	<meta http-equiv="description" content="This is my page">
	<!--
	<link rel="stylesheet" type="text/css" href="styles.css">
	-->
	
	  <link href="/resources/bootstrap/css/bootstrap.css" rel="stylesheet" />
	  <script src="/resources/js/jquery-1.7.2.js"></script>
	  
	  <script type="text/javascript">
	  
	  var userId;
	  
	  $(document).ready(function(){
		  userId=$("#userId").val();
		  
		  
		  var timeId = setInterval(function () { 
	
			    $.ajax({
			        type: "POST",
			        url: "/grab/download/status",  /* 注意后面的名字相应CS的方法名称 */
			        data: "{}", /* 注意參数的格式和名称 */
			        contentType: "application/json; charset=utf-8",
			        dataType: "json",
			        success: function (data) {
			        	//console.log(data);
			        	for(var i in data) {
			        		   var percent = data[i].percent;
			        		   console.log(percent);
			        		   if(percent>0 && percent<100){
			        			   $("#progress"+data[i].id).html("<div class='progress'><div class='progress-bar' role='progressbar' aria-valuenow='60' aria-valuemin='0' aria-valuemax='100' style='width:"+ percent+"%;'>"+percent+"%</div></div>");
			        			   $("#downloadTd"+data[i].id).html("下载中...");
			        		   }else if(percent>100){
			        			   percent=100;
			        			   $("#progress"+data[i].id).html("<div class='progress'><div class='progress-bar' role='progressbar' aria-valuenow='60' aria-valuemin='0' aria-valuemax='100' style='width:"+ percent+"%;'>"+percent+"%</div></div>");
			        			   $("#downloadTd"+data[i].id).html("下载完");
			        		   }
			        		   
			        		   if(data[i].status=="SUCCESS"){
			        			   $("#Tr"+data[i].id).remove();
			        		   }else if(data[i].status=="FAIL"){
			        			   $("#progress"+data[i].id).html("失败");
			        			   //$("#downloadTd"+data[i].id).html("失败");
			        		   }
			            }
			        	

			        }
			    });
		    },4000);
	  });
	        
	 
	  
	  
	  
			//下载单个文件
			  function downvideo(obj){
			  	
				  	var num="0%";
				  	var htmlstr="<div class='progress'><div class='progress-bar' role='progressbar' aria-valuenow='60' aria-valuemin='0' aria-valuemax='100' style='width:"+ num+";'>"+num+"</div></div>";	
				  	$(obj).parents(".downloadTd").siblings(".progressStatus").html(htmlstr);
				  	
				  	$(obj).parents(".downloadTd").html("下载中...");
				  	
				  	var videoId=$(obj).attr("videoId");
				  	var url=$(obj).attr("dataUrl");
				  		
				    //下载
				    $.post(url,{},function(data){});
				  
				    var test = setTimeout(function(){
				    	//location.href ="/grab/download/manage?userId="+userId;
				    },1000);
			  }
	  </script>

  </head>
  
  <body>
<div class="container">
	  
  <div class="col-md-12">
      


<div class="page-header clearfix">
  <h3 class="pull-left">视频管理</h3>
</div>

 <div>
      <ul class="nav nav-tabs">
        <li><a href="/grab/import">导入任务</a></li>
        <li class="active"><a href="/grab/download/manage">待抓视频</a></li>
        <li><a href="/grab/export">已抓视频</a></li>
      </ul>
</div>

<input type="hidden" id="userId" name="userId" value="${userId}"/> 

<%List<VideoListModel> ls = (List) request.getAttribute("videolist");
	if(ls.size()>0){%>	  
		   <form action="/grab/download/manage" method="post">
		         <button type="submit" class="btn btn-default btn-info pull-right" style="margin-top:10px;">所有下载</button>
		         
				<input type="hidden" id="userId" class="userId" name="userId" value="<%=ls.get(0).getUserId() %>" />
				<div class="row">
					<table id="guanggao-table" class="table table-hover">
						<thead>
							<tr>
								<th>序号</th>
								<th>视频URL</th>
								<th>标题</th>
								<th>视频分类</th>
								<th width="15%">状态</th>
								<th>操作1</th>
								<th>操作2</th>
							</tr>
						</thead>
						<tbody>
						  <%for(int i=0;i<ls.size();i++){ %>
							<tr id="Tr<%=ls.get(i).getId() %>" pUrl="/grab/download/progress?videoId=<%=ls.get(i).getId() %>&trueName=<%=ls.get(i).getTrueName() %>&userId=<%=ls.get(i).getUserId() %>&url=<%=ls.get(i).getUrl() %>" >
							   <td> <%=i+1 %>
							      <input type="hidden" id="videoId" class="videoId" name="videoId" value="<%=ls.get(i).getId() %>" />
							      <input type="hidden" id="url" class="url" name="url" value="<%=ls.get(i).getUrl() %>" />
							      <input type="hidden" id="trueName" class="trueName" name="trueName" value="<%=ls.get(i).getTrueName() %>" />
							   </td>
							   <td>
							   		<a href="<%=ls.get(i).getUrl() %>" title="<%=ls.get(i).getUrl() %>"><%String str=ls.get(i).getUrl();String pathstr=str.substring(0, 20);%>
							   		  <%=pathstr %>...
							   		</a>
					   		   </td>
							   <td><%=ls.get(i).getTitle() %></td>
							   <td><%=ls.get(i).getClassifyName() %></td>
							   <td class="progressStatus" id="progress<%=ls.get(i).getId() %>">
							   
							           <% if("NO".equals(ls.get(i).getStatus().trim())){%>
							                <div>待抓取</div>
							           <%}else if("WAIT".equals(ls.get(i).getStatus().trim())){ %>
							               <div>等待</div>
							           <%}else if("TRANSCODING".equals(ls.get(i).getStatus().trim())){ %>
							               	<div class="progress">
							               		<div class="progress-bar" role="progressbar" aria-valuenow="60" aria-valuemin="0" aria-valuemax="100" style="width:1%;">1%</div>
						               		</div>
							           <%}else if("EXECUTE".equals(ls.get(i).getStatus().trim())){ %>
							               
							           <%}else if("SUCCESS".equals(ls.get(i).getStatus().trim())){ %>
							                <div>成功</div>
							           <%}else{ %>
							                <div>失败 </div>
							           <%} %>
							   </td>
							   <td class="downloadTd" id="downloadTd<%=ls.get(i).getId() %>">
							     <% if("EXECUTE".equals(ls.get(i).getStatus().trim())){%> 
						            	下载中...<div class="execute" videoId="<%=ls.get(i).getId() %>" style="display:none;"></div>
						            	
						         <%}else if("WAIT".equals(ls.get(i).getStatus().trim())){ %>
						       			等待
						         <%}else{%>
							      	<button type="button" class="btn btn-default btn-info" videoId="<%=ls.get(i).getId() %>" dataUrl="/grab/download/manage?
videoId=<%=ls.get(i).getId() %>&trueName=<%=ls.get(i).getTrueName() %>&userId=<%=ls.get(i).getUserId() %>&url=<%=ls.get(i).getUrl() %>"  onclick="downvideo(this);">抓取</button>						         <%} %>						       </td>						       <td>						       	<!-- 						       		<button type="button" class="btn btn-default" videoId="<%=ls.get(i).getId() %>" dataUrl="/grab/video/stop?videoId=<%=ls.get(i).getId() %>&trueName=<%=ls.get(i).getTrueName() %>&userId=<%=ls.get(i).getUserId() %>&url=<%=ls.get(i).getUrl() %>" onclick="stopVideo(this);">暂停</button>						       	 -->						       		<button type="button" class="btn btn-default" videoId="<%=ls.get(i).getId() %>" dataUrl="/grab/delete/videoId?
videoId=<%=ls.get(i).getId() %>" onclick="deleteVideo(this);">删除</button>						       </td>							</tr>						 <%} %>					   </tbody>					</table>				</div>		</form><%}else{ %>	<div class="col-md-6" style="padding-top:30px;">暂无视频能够抓取</div><%} %>         </div>   </div>  </body></html><script>//删除文件function deleteVideo(obj){	var url=$(obj).attr("dataUrl");	    if (!confirm('真的要永久删除该内容吗？')) {        return ;    }else{        $.ajax({            type: "GET",            url: url,  /* 注意后面的名字相应CS的方法名称 */            data: "{}", /* 注意參数的格式和名称 */            contentType: "application/json; charset=utf-8",            dataType: "json",            success: function (data) {            	console.log(data);              	var mark=data.result;                if(mark=="yes"){                	// window.location.reload();                	location.href ="/grab/download/manage?userId="+userId;                }else{                    alert("删除失败！");                }            }        });    }}//暂停下载function stopVideo(obj){	var url=$(obj).attr("dataUrl");	    if (!confirm('暂停下载')) {        return ;    }else{        $.ajax({            type: "GET",            url: url,  /* 注意后面的名字相应CS的方法名称 */            data: "{}", /* 注意參数的格式和名称 */            contentType: "application/json; charset=utf-8",            dataType: "json",            success: function (data) {            	console.log(data);              	var mark=data.result;                if(mark=="yes"){                	// window.location.reload();                	location.href ="/grab/download/manage?userId="+userId;                }else{                    alert("操作失败！");                }            }        });    }}</script>

版权声明：本文博主原创文章，博客，未经同意不得转载。

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/116854.html原文链接：https://javaforall.cn

【正版授权，激活自己账号】： Jetbrains全家桶Ide使用，1年售后保障，每天仅需1毛

【官方授权 正版激活】： 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

赞 (0)
全栈程序员-用户IM全栈程序员-用户IM
0 0


相关推荐

  • 积化和差和差化积公式推导_三角函数的极化和差

    积化和差和差化积公式推导_三角函数的极化和差

    积化和差和差化积公式推导_三角函数的极化和差和差化积公式：sinx+siny=2sinx+y2cosx−y2\sinx+\siny=2\sin\frac{x+y}{2}\cos\frac{x-y}{2}sinx−siny=2cosx+y2sinx−y2\sinx-\siny=2\cos\frac{x+y}{2}\sin\frac{x-y}{2}cosx−cosy=2cosx+y2cosx−y2\cos

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年10月27日
  • 安装AIC准则使用前进法后退法和逐步回归法进行变量选择的r语言代码

    安装AIC准则使用前进法后退法和逐步回归法进行变量选择的r语言代码

    安装AIC准则使用前进法后退法和逐步回归法进行变量选择的r语言代码setwd(“C:/Users/IBM/Desktop/研一课程/2.2回归分析/回归作业”) #设定当前的工作目录shuju=read.table(“shuju.txt”,header=T)shuju #读取数据#采用AIC原则自动选择模型-前进法shuju.reg1shuju.regforward2summary(shuju.regforward2)#采用A

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年5月23日
  • php中的登陆login

    php中的登陆login

    Login推荐：http://www.cnblogs.com/roucheng/p/phpdongtai.html

    全栈程序员-用户IM 全栈程序员-用户IM
    2021年12月27日
  • 毕业设计 – 题目：基于stm32的智能扫地机器人设计与实现

    毕业设计 – 题目：基于stm32的智能扫地机器人设计与实现

    1课题背景随着人口老龄化的到来和人民对提升生活品质的需要，人们对在现实生活场景中取代人力的服务机器人有着迫切的需要。同时，机电、自动控制、计算机、传感器等技术的发展也为制造服务机器人提供了技术支持。扫地机器人是服务机器人中技术最成熟和最为广泛使用的机器人。它可以自动的在室内行走，通过刷扫和吸尘将地面上的碎屑吸收进垃圾收集装置中，完成清洁地面的任务，有效的减少了人们清洁地面这种简单重复的家务劳动，节约了劳动力，提高了生活品质。对于许多忙于工作和生的人来说，扫地机器人已经成为家庭必

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年4月6日
  • 事件TransactionScope

    事件TransactionScope

    事件TransactionScopeusing(TransactionScopescope=newTransactionScope()){ scope.Complete();}只需要把需要事务包裹的逻辑块写在using(TransactionScopets=newTransactionScope())中就可以了。从这种写法可以看出，TransactionScope实现了IDispose接口。除…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年7月24日
  • chrom浏览器flash_flash插件

    chrom浏览器flash_flash插件

    chrom浏览器flash_flash插件Flash插件概述Flash插件一款安装于浏览器插件，即AdobeFlashPlayerPlugin，使浏览器得以播放swf文件。通过Flash插件最新版下载可以提升浏览器、视频播放软件对于动画文件的最大兼容性。AdobeFlashPlayer是一种广泛使用、专有的多媒体播放器，AdobeFlashPlayer最初设计目的为播放2维向量动量，但至此之后成为适合开发创造丰富型互联网应用…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年5月31日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号