hadoop实现web上传、下载、更新、删除和文件追加

admin

      Hadoop是一个能够对大量数据进行分布式处理的软件框架。Hadoop 是可靠的，因为它假设计算元素和存储会失败，因此它维护多个工作数据副本，确保能够针对失败的节点重新分布处理。Hadoop实现了一个分布式文件系统（Hadoop Distributed File System），简称HDFS。HDFS有着高容错性的特点，并且设计用来部署在低廉的（low-cost）硬件上
上传：

1. /**
   $ o4 }" p* N3 j) i6 ~5 {
2. *  
   
3. * 上传控制类，上传页面跳转到这里
   5 k. Y# b& k9 [& S9 p4 k
4. *
   
5. * @author  科帮网
   % o6 p( l; H! q. O
6. * @version  [版本号, 2012-08-02]
   ( p; [" _% m2 l
7. * @see  [相关类/方法]
   3 _; C1 w# m9 Y) {% ^
8. * @since  version 1.0
   # R$ u- W- M; Q4 D6 m2 a
9. */
   
10. public class UploadHDFSServlet extends HttpServlet {
    
11. 
    : q( q, d$ @( _/ L
12.         /** *
    
13.          * * 该方法负责上传控制处理页面         *
    
14.          * @param request 客户端到服务器的请求消息
    
15.          * @param response 服务器返回给页面的消息
    
16.          * @throws ServletException
    
17.          * @throws IOException
    
18.          */
    
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    ) ]$ e/ ?$ ~5 z& p
22.                 if(!isMultipart){
    3 |5 r; [1 v! H
23.                 }else{                       
      c, J1 G7 F8 R' G! Q& n
24.                         FileItemFactory factory = new DiskFileItemFactory();
    
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    6 J3 ^* f2 n) f, c
26.                         try {
    
27.                                 List items = upload.parseRequest(request);                       
    1 x# {8 N. m' V/ b
28.                                 Iterator iter = items.iterator();
    1 M0 u* v0 f$ ^% M2 F
29.                                 while(iter.hasNext()){
    
30.                                         FileItem item = (FileItem)iter.next();
    
31.                                         if(item.isFormField()){
    5 W* O( E/ v( E2 v9 H
32.                                                 String name = item.getFieldName();
    
33.                                                 System.out.println(name);
    . E% S( s' q' {/ C5 [, ]% b4 m. c
34.                                         }else{
    
35.                                                 //表单名字
    
36.                                             String fileName = item.getName();
    
37.                                             InputStream uploadedStream = item.getInputStream();
    * Y6 I4 m0 ]3 Q9 d. F$ x
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    . T/ `9 V3 I  m2 H2 X
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    , b7 ~* Z6 u1 w2 O8 P( i
42.                                             
    
43.                                             if(flag){
    
44.                                                     response.sendRedirect("success.jsp");
    7 l( X7 A; S9 u3 k7 ~
45.                                             }else{
    3 R7 ]4 W  D$ O# D2 {4 f$ o
46.                                                     response.sendRedirect("failure.jsp");
    
47.                                             }
    
48.                                         }
    
49.                                 }
    ) _2 ]3 a- a+ c( i' P
50.                                
    
51.                         } catch (Exception e) {                               
    
52.                                 e.printStackTrace();
    
53.                         }
    
54.                 }               
    
55.        
    5 t  T4 }; p9 v0 a" x/ p
56.         }
    " \% n. ?( ~- s$ U& c
57. 
    2 C3 B- A; a* A
58. }

复制代码

配置：

1. <configuration>
   % Y3 v4 h; ~' b) R: @- [
2.   <property>
   % D4 j( F) F4 k. ?
3.      <name>fs.default.name </name>
   
4.      <value>hdfs://10.6.12.101:8888</value>
   
5.   </property>
   
6. <property>
   
7. <name>hadoop.tmp.dir</name>
   
8. <value>/home/hadoopuser/tmp</value>
   ( V8 ]( i4 U/ b! x$ E- R7 A0 R. w
9. </property>
   . Q8 D8 x; C: r
10. </configuration>

复制代码

源码下载地址：点击下载
. w; `$ f3 k8 W' f0 f2 x
; [7 t) Y0 P7 c( U% s- x, D

8 n( P* W9 {& L$ `

昕动2014

如果可以做一个样板出来就更好了~

九纹龙

很不错哟，谢谢楼主，受教了。

woniu

这个项目太棒勒！下下来学习下！

wudizxt

不错不错不错，学习一下