hadoop网盘环境搭建，代码全部过程(9)

// 创建一个新的文件上传处理程序

ServletFileUpload upload = new ServletFileUpload(factory); // 设置最大上传的文件大小 upload.setSizeMax( maxFileSize ); try{

// 解析获取的文件

ListfileItems = upload.parseRequest(request);

// 处理上传的文件

Iteratori = fileItems.iterator();

System.out.println(\); while( i.hasNext () ) {

FileItem fi = (FileItem)i.next(); if( !fi.isFormField () ) { // 获取上传文件的参数

String fieldName = fi.getFieldName(); String fileName = fi.getName();

String fn = fileName.substring( fileName.lastIndexOf(\)+1); System.out.println(\+fn+\); booleanisInMemory = fi.isInMemory(); longsizeInBytes = fi.getSize(); // 写入文件

if( fileName.lastIndexOf(\) >= 0 ){ file = newFile( filePath ,

fileName.substring( fileName.lastIndexOf(\))) ; }else{

file = newFile( filePath ,

fileName.substring(fileName.lastIndexOf(\)+1)) ; } fi.write( file ) ;

System.out.println(\);

System.out.println(\);

41 / 53

//将tomcat上的文件上传到hadoop上

hdfs.copyFile(filePath+\+fn, filePath0+fn);

System.out.println(\);

FileStatus[] list = hdfs.ls(filePath0); request.setAttribute(\,list);

} } }catch(Exception ex) {

System.out.println(ex); } }else{

System.out.println(\);

} } /**

* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response) */

protectedvoiddoPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { } }

42 / 53

JobConf conf = HdfsDAO.config(); HdfsDAO hdfs = new HdfsDAO(conf);

request.getRequestDispatcher(\).forward(request, response);

this.doGet(request, response);

文件删除功能:

主要代码:

publicclassDeleteFileServletextends HttpServlet {

/**

* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response) */

protectedvoiddoGet(HttpServletRequest request, HttpServletResponse response) throws

//FileStatus[] list = (FileStatus[])request.getAttribute(\

ServletException, IOException {

String filePath = new String filePath1 = new

43 / 53

String(request.getParameter(\).getBytes(\),\); String(request.getParameter(\).getBytes(\),\);

JobConf conf = HdfsDAO.config();

HdfsDAO hdfs = new HdfsDAO(conf); hdfs.rmr(filePath);

System.out.println(\+filePath+\); System.out.println(\+filePath1+\); FileStatus[] list = hdfs.ls(filePath1); request.setAttribute(\,list); }

文件下载功能：

/**

* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response) */

protectedvoiddoPost(HttpServletRequest request, HttpServletResponse response) throws }

this.doGet(request, response); }

request.getRequestDispatcher(\).forward(request,response);

ServletException, IOException {

44 / 53

主要代码:

publicclass DownloadServlet extends HttpServlet {

/**

* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response) */

protectedvoiddoGet(HttpServletRequest request, HttpServletResponse response) throws

String local = \; String filePath = new String filePath1 = new

45 / 53

privatestaticfinallongserialVersionUID = 1L;

ServletException, IOException {

String(request.getParameter(\).getBytes(\),\); String(request.getParameter(\).getBytes(\),\);