java實現(xiàn)視頻上傳和播放

1、Java實現(xiàn)視頻網(wǎng)站的視頻上傳、視頻轉(zhuǎn)碼、視頻關(guān)鍵幀抽圖, 及視頻播放功能視頻網(wǎng)站中提供的在線視頻播放功能,播放的都是FLV格式的文件,它是Flash動畫文件,可通過Flash制作的播放器來播放該文件.項目中用制作的player.swf播放器.多媒體視頻處理工具FFmpeg有非常強大的功能包括視頻采集功能、視頻格式轉(zhuǎn)換、視頻抓圖、給視頻加水印等。 ffmpeg視頻采集功能非常強大，不僅可以采集視頻采集卡或USB攝像頭的圖像，還可以進行屏幕錄制，同時還支持以RTP方式將視頻流傳送給支持RTSP的流媒體服務(wù)器，支持直播應(yīng)用。1.能支持的格式ffmpeg能解析的格式：（asx，asf，mpg，wmv

2、，3gp，mp4，mov，avi，flv等）2.不能支持的格式對ffmpeg無法解析的文件格式(wmv9，rm，rmvb等),可以先用別的工具（mencoder）轉(zhuǎn)換為avi(ffmpeg能解析的)格式.實例是將上傳視頻轉(zhuǎn)碼為flv格式,該格式ffmpeg支持,所以我們實例中需要ffmpeg視頻處理工具. 數(shù)據(jù)庫MySQL5.5實例所需要的數(shù)據(jù)庫腳本drop database if exists db_mediaplayer;create database db_mediaplayer;use db_mediaplayer;create table tb_media( id int not n

3、ull primary key auto_increment comment '主鍵' , title varchar(50) not null comment '視頻名稱' , src varchar(200) not null comment '視頻存放地址' , picture varchar(200) not null comment '視頻截圖' , descript varchar(400) comment '視頻描述' , uptime varchar(40) comment '上傳時間

4、9;);desc tb_media;項目結(jié)構(gòu)圖:上傳視頻界面設(shè)計在上傳文件時,Form表單中 enctype屬性值必須為"multipart/form-data".模塊界面設(shè)計如下圖:enctype屬性值說明application/x-www-form-urlencoded表單數(shù)據(jù)被編碼為名稱/值對,這是標(biāo)準(zhǔn)的編碼格式multipart/form-data表單數(shù)據(jù)被編碼為一條消息,頁面上每個控件對應(yīng)消息中的一部分text/plain表單數(shù)據(jù)以純文本形式進行編碼,其中不含任何控件格式的字符 業(yè)務(wù)接口定義面向接口編程,接口中定義系統(tǒng)功能模塊.這樣方便理清業(yè)務(wù)

5、,同時接口的對象必須由實現(xiàn)了該接口的對象來創(chuàng)建.這樣就避免編碼中的某些業(yè)務(wù)遺漏等,同時擴展性也增強了.package com.webapp.dao;import java.util.List;import com.webapp.entity.Media;/* * * MediaDao.java * * version ： 1.1 * * author ： 蘇若年 <a href="mailto:DennisIT">發(fā)送郵件</a> * * since ： 1.0 創(chuàng)建時間: 2013-2-07 上午10:19:54 * * TODO : interf

6、ace MediaDao.java is used for . * */public interface MediaDao /* * 視頻轉(zhuǎn)碼 * param ffmpegPath 轉(zhuǎn)碼工具的存放路徑 * param upFilePath 用于指定要轉(zhuǎn)換格式的文件,要截圖的視頻源文件 * param codcFilePath 格式轉(zhuǎn)換后的的文件保存路徑 * param mediaPicPath 截圖保存路徑 * return * throws Exception */ public boolean executeCodecs(String ffmpegPath,String upFilePat

7、h, String codcFilePath, String mediaPicPath)throws Exception; /* * 保存文件 * param media * return * throws Exception */ public boolean saveMedia(Media media)throws Exception; /* * 查詢本地庫中所有記錄的數(shù)目 * return * throws Exception */ public int getAllMediaCount()throws Exception; /* * 帶分頁的查詢 * param firstResult

8、 * param maxResult * return */ public List<Media> queryALlMedia(int firstResult, int maxResult)throws Exception; /* * 根據(jù)Id查詢視頻 * param id * return * throws Exception */ public Media queryMediaById(int id)throws Exception;接口的實現(xiàn),這里列出ffmpeg視頻轉(zhuǎn)碼與截圖模塊/* * 視頻轉(zhuǎn)碼 * param ffmpegPath 轉(zhuǎn)碼工具的存放路徑 * param u

9、pFilePath 用于指定要轉(zhuǎn)換格式的文件,要截圖的視頻源文件 * param codcFilePath 格式轉(zhuǎn)換后的的文件保存路徑 * param mediaPicPath 截圖保存路徑 * return * throws Exception */ public boolean executeCodecs(String ffmpegPath, String upFilePath, String codcFilePath, String mediaPicPath) throws Exception / 創(chuàng)建一個List集合來保存轉(zhuǎn)換視頻文件為flv格式的命令 List<String&g

10、t; convert = new ArrayList<String>(); convert.add(ffmpegPath); / 添加轉(zhuǎn)換工具路徑 convert.add("-i"); / 添加參數(shù)-i，該參數(shù)指定要轉(zhuǎn)換的文件 convert.add(upFilePath); / 添加要轉(zhuǎn)換格式的視頻文件的路徑 convert.add("-qscale"); /指定轉(zhuǎn)換的質(zhì)量 convert.add("6"); convert.add("-ab"); /設(shè)置音頻碼率 convert.add("

11、64"); convert.add("-ac"); /設(shè)置聲道數(shù) convert.add("2"); convert.add("-ar"); /設(shè)置聲音的采樣頻率 convert.add("22050"); convert.add("-r"); /設(shè)置幀頻 convert.add("24"); convert.add("-y"); / 添加參數(shù)-y，該參數(shù)指定將覆蓋已存在的文件 convert.add(codcFilePath); / 創(chuàng)建一個L

12、ist集合來保存從視頻中截取圖片的命令 List<String> cutpic = new ArrayList<String>(); cutpic.add(ffmpegPath); cutpic.add("-i"); cutpic.add(upFilePath); / 同上（指定的文件即可以是轉(zhuǎn)換為flv格式之前的文件，也可以是轉(zhuǎn)換的flv文件） cutpic.add("-y"); cutpic.add("-f"); cutpic.add("image2"); cutpic.add(&quo

13、t;-ss"); / 添加參數(shù)-ss，該參數(shù)指定截取的起始時間 cutpic.add("17"); / 添加起始時間為第17秒 cutpic.add("-t"); / 添加參數(shù)-t，該參數(shù)指定持續(xù)時間 cutpic.add("0.001"); / 添加持續(xù)時間為1毫秒 cutpic.add("-s"); / 添加參數(shù)-s，該參數(shù)指定截取的圖片大小 cutpic.add("800*280"); / 添加截取的圖片大小為350*240 cutpic.add(mediaPicPath); /

14、 添加截取的圖片的保存路徑 boolean mark = true; ProcessBuilder builder = new ProcessBuilder(); try mand(convert); builder.redirectErrorStream(true); builder.start(); mand(cutpic); builder.redirectErrorStream(true); / 如果此屬性為 true，則任何由通過此對象的 start() 方法啟動的后續(xù)子進程生成的錯誤輸出都將與標(biāo)準(zhǔn)輸出合并， /因此兩者均可使用 Process.getInputStream() 方法

15、讀取。這使得關(guān)聯(lián)錯誤消息和相應(yīng)的輸出變得更容易 builder.start(); catch (Exception e) mark = false; System.out.println(e); e.printStackTrace(); return mark;系統(tǒng)中可能存在多個模塊,這些模塊的業(yè)務(wù)DAO可以通過工廠來管理,需要的時候直接提供即可.因為如果對象new太多,會不必要的浪費資源.所以工廠,采用單例模式,私有構(gòu)造,提供對外可訪問的方法即可.package com.webapp.dao;import com.webapp.dao.impl.MediaDaoImpl;/* * * Dao

16、Factory.java * * version ： 1.1 * * author ： 蘇若年 <a href="mailto:DennisIT">發(fā)送郵件</a> * * since ： 1.0 創(chuàng)建時間: 2013-2-07 下午02:18:51 * * TODO : class DaoFactory.java is used for . * */public class DaoFactory /工廠模式,生產(chǎn)Dao對象,面向接口編程,返回實現(xiàn)業(yè)務(wù)接口定義的對象 private static DaoFactory daoFactory = new

17、 DaoFactory(); /單例設(shè)計模式, 私有構(gòu)造,對外提供獲取創(chuàng)建的對象的唯一接口, private DaoFactory() public static DaoFactory getInstance() return daoFactory; public static MediaDao getMediaDao() return new MediaDaoImpl(); 視圖提交請求,給控制器,控制器分析請求參數(shù),進行相應(yīng)的業(yè)務(wù)調(diào)用處理.servlet控制器相關(guān)代碼如下package com.webapp.service;import java.io.File;import java.i

18、o.IOException;import java.io.PrintWriter;import java.util.List;import javax.servlet.ServletContext;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import mons.fileupload.FileItem;im

19、port mons.fileupload.disk.DiskFileItemFactory;import mons.fileupload.servlet.ServletFileUpload;import com.webapp.dao.DaoFactory;import com.webapp.dao.MediaDao;import com.webapp.entity.Media;import com.webapp.util.DateTimeUtil;/* * * MediaService.java * * version ： 1.1 * * author ： 蘇若年 <a href=&qu

20、ot;mailto:DennisIT">發(fā)送郵件</a> * * since ： 1.0 創(chuàng)建時間: 2013-2-08 下午02:24:47 * * TODO : class MediaService.java is used for . * */public class MediaService extends HttpServlet public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException do

21、Post(request, response); public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException PrintWriter out = response.getWriter(); MediaDao mediaDao = DaoFactory.getMediaDao(); String message = "" String uri = request.getRequestURI(); String

22、path = uri.substring(uri.lastIndexOf("/"), uri.lastIndexOf("."); if("/uploadFile".equals(path) /提供解析時的一些缺省配置 DiskFileItemFactory factory = new DiskFileItemFactory(); /創(chuàng)建一個解析器,分析InputStream,該解析器會將分析的結(jié)果封裝成一個FileItem對象的集合 /一個FileItem對象對應(yīng)一個表單域 ServletFileUpload sfu = new Se

23、rvletFileUpload(factory); try Media media = new Media(); List<FileItem> items = sfu.parseRequest(request); boolean flag = false; /轉(zhuǎn)碼成功與否的標(biāo)記 for(int i=0; i<items.size(); i+) FileItem item = items.get(i); /要區(qū)分是上傳文件還是普通的表單域 if(item.isFormField()/isFormField()為true,表示這不是文件上傳表單域 /普通表單域 String pa

24、ramName = item.getFieldName(); /* String paramValue = item.getString(); System.out.println("參數(shù)名稱為:" + paramName + ", 對應(yīng)的參數(shù)值為: " + paramValue); */ if(paramName.equals("title") media.setTitle(new String(item.getString().getBytes("ISO8859-1"),"UTF-8");

25、if(paramName.equals("descript") media.setDescript(new String(item.getString().getBytes("ISO8859-1"),"UTF-8"); else /上傳文件 /System.out.println("上傳文件" + item.getName(); ServletContext sctx = this.getServletContext(); /獲得保存文件的路徑 String basePath = sctx.getRealPath(

26、"videos"); /獲得文件名 String fileUrl= item.getName(); /在某些操作系統(tǒng)上,item.getName()方法會返回文件的完整名稱,即包括路徑 String fileType = fileUrl.substring(fileUrl.lastIndexOf("."); /截取文件格式 /自定義方式產(chǎn)生文件名 String serialName = String.valueOf(System.currentTimeMillis(); /待轉(zhuǎn)碼的文件 File uploadFile = new File(basePat

27、h+"/temp/"+serialName + fileType); item.write(uploadFile); if(item.getSize()>500*1024*1024) message = "<li>上傳失敗！您上傳的文件太大,系統(tǒng)允許最大文件500M</li>" String codcFilePath = basePath + "/" + serialName + ".flv" /設(shè)置轉(zhuǎn)換為flv格式后文件的保存路徑 String mediaPicPath = base

28、Path + "/images" +File.separator+ serialName + ".jpg" /設(shè)置上傳視頻截圖的保存路徑 / 獲取配置的轉(zhuǎn)換工具（ffmpeg.exe）的存放路徑 String ffmpegPath = getServletContext().getRealPath("/tools/ffmpeg.exe"); media.setSrc("videos/" + serialName + ".flv"); media.setPicture("videos/i

29、mages/" +serialName + ".jpg"); media.setUptime(DateTimeUtil.getYMDHMSFormat(); /轉(zhuǎn)碼 flag = mediaDao.executeCodecs(ffmpegPath, uploadFile.getAbsolutePath(), codcFilePath, mediaPicPath); if(flag) /轉(zhuǎn)碼成功,向數(shù)據(jù)表中添加該視頻信息 mediaDao.saveMedia(media); message = "<li>上傳成功!</li>&quo

30、t; request.setAttribute("message", message); request.getRequestDispatcher("media_upload.jsp").forward(request,response); catch (Exception e) e.printStackTrace(); throw new ServletException(e); if("/queryAll".equals(path) List<Media> mediaList; try mediaList = medi

31、aDao.queryALlMedia(0,5); request.setAttribute("mediaList", mediaList); request.getRequestDispatcher("media_list.jsp").forward(request, response); catch (Exception e) e.printStackTrace(); if("/play".equals(path) String idstr = request.getParameter("id"); int me

32、diaId = -1; Media media = null; if(null!=idstr) mediaId = Integer.parseInt(idstr); try media = mediaDao.queryMediaById(mediaId); catch (Exception e) e.printStackTrace(); request.setAttribute("media", media); request.getRequestDispatcher("media_player.jsp").forward(request, respon

33、se); 可以通過分頁查找,顯示最新top5,展示到首頁.相應(yīng)特效可以使用JS實現(xiàn). 相關(guān)代碼如下:<% page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%><% page import="com.webapp.entity.*"%><% page import="java.util.*"%><% String path = requ

34、est.getContextPath(); String basePath = request.getScheme()+":/"+request.getServerName()+":"+request.getServerPort()+path+"/"%><!DOCTYPE html PUBLIC "-/W3C/DTD HTML 4.01 Transitional/EN" "/TR/html4/loose.dtd"><html><

35、head><title>視頻列表</title><link rel="stylesheet" type="text/css" href="skin/css/style.css" ></link><script type="text/javascript" src="skin/js/jquery1.3.2.js"></script><script type="text/javascript"&g

36、t;$(function() var sWidth = $("#focus").width(); /獲取焦點圖的寬度（顯示面積） var len = $("#focus ul li").length; /獲取焦點圖個數(shù) var index = 0; var picTimer; /以下代碼添加數(shù)字按鈕和按鈕后的半透明條，還有上一頁、下一頁兩個按鈕 var btn = "<div class='btnBg'></div><div class='btn'>" for(var

37、 i=0; i < len; i+) btn += "<span></span>" btn += "</div><div class='preNext pre'></div><div class='preNext next'></div>" $("#focus").append(btn); $("#focus .btnBg").css("opacity",0.5); /為小按

38、鈕添加鼠標(biāo)滑入事件，以顯示相應(yīng)的內(nèi)容 $("#focus .btn span").css("opacity",0.4).mouseenter(function() index = $("#focus .btn span").index(this); showPics(index); ).eq(0).trigger("mouseenter"); /上一頁、下一頁按鈕透明度處理 $("#focus .preNext").css("opacity",0.2).hover(funct

39、ion() $(this).stop(true,false).animate("opacity":"0.5",300); ,function() $(this).stop(true,false).animate("opacity":"0.2",300); ); /上一頁按鈕 $("#focus .pre").click(function() index -= 1; if(index = -1) index = len - 1; showPics(index); ); /下一頁按鈕 $("

40、;#focus .next").click(function() index += 1; if(index = len) index = 0; showPics(index); ); /本例為左右滾動，即所有l(wèi)i元素都是在同一排向左浮動，所以這里需要計算出外圍ul元素的寬度 $("#focus ul").css("width",sWidth * (len); /鼠標(biāo)滑上焦點圖時停止自動播放，滑出時開始自動播放 $("#focus").hover(function() clearInterval(picTimer); ,fun

41、ction() picTimer = setInterval(function() showPics(index); index+; if(index = len) index = 0; ,4000); /此4000代表自動播放的間隔，單位：毫秒 ).trigger("mouseleave"); /顯示圖片函數(shù)，根據(jù)接收的index值顯示相應(yīng)的內(nèi)容 function showPics(index) /普通切換 var nowLeft = -index*sWidth; /根據(jù)index值計算ul元素的left值 $("#focus ul").stop(tr

42、ue,false).animate("left":nowLeft,300); /通過animate()調(diào)整ul元素滾動到計算出的position /$("#focus .btn span").removeClass("on").eq(index).addClass("on"); /為當(dāng)前的按鈕切換到選中的效果 $("#focus .btn span").stop(true,false).animate("opacity":"0.4",300).eq(ind

43、ex).stop(true,false).animate("opacity":"1",300); /為當(dāng)前的按鈕切換到選中的效果 );</script></head><body><div class="wrapper"> <h1>最新視頻</h1> <div id="focus"> <ul> <% List<Media> mediaList = (List<Media>)request.getAttribute("mediaList"); if(mediaL