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

admin

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

1. /**
   
2. *  
   
3. * 上传控制类，上传页面跳转到这里
   " |7 g: Y. @4 `- L! n, ^
4. *
   8 [. S$ m- v; Q% X# g
5. * @author  科帮网
   1 l' ?% Z- Y* M2 D
6. * @version  [版本号, 2012-08-02]
   
7. * @see  [相关类/方法]
   
8. * @since  version 1.0
   : z7 x$ o0 t; C3 V" z! d
9. */
   
10. public class UploadHDFSServlet extends HttpServlet {
    ( p% S4 E" i/ y0 S: f
11. 
    1 x% q1 f0 I. p$ \% T3 H! [6 u
12.         /** *
    
13.          * * 该方法负责上传控制处理页面         *
    5 {) C. H0 e* u2 J
14.          * @param request 客户端到服务器的请求消息
    0 G" x+ v/ R) p- Q
15.          * @param response 服务器返回给页面的消息
    
16.          * @throws ServletException
    " u) q) |3 W" F, `* Y0 a8 Q
17.          * @throws IOException
    
18.          */
    
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    7 |' N/ V5 ^8 J9 u6 [
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    
22.                 if(!isMultipart){
    , q  G' V& v, z9 \+ Y+ L7 m
23.                 }else{                       
    
24.                         FileItemFactory factory = new DiskFileItemFactory();
    0 M* [& z1 C/ R4 ]
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    5 o3 B! I  K* T% f
26.                         try {
    
27.                                 List items = upload.parseRequest(request);                       
    
28.                                 Iterator iter = items.iterator();
    . A1 b5 N8 J: U# k
29.                                 while(iter.hasNext()){
    1 f7 O9 x* _2 R" P- }1 H0 E. ?- W1 C
30.                                         FileItem item = (FileItem)iter.next();
    0 A) H6 S. l! F; `+ C) h
31.                                         if(item.isFormField()){
    ; P! _* R$ D6 E" ^( y8 O
32.                                                 String name = item.getFieldName();
    
33.                                                 System.out.println(name);
    2 \, G1 g* p+ W6 \6 s
34.                                         }else{
    6 j& `/ r# _3 N+ `. G8 [3 W
35.                                                 //表单名字
    + d( {2 \8 }; j
36.                                             String fileName = item.getName();
    
37.                                             InputStream uploadedStream = item.getInputStream();
    5 g9 D# @0 ~7 A+ X5 S' |8 g
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    # Q# c1 E% N3 V- m5 X3 O
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    
42.                                             
    
43.                                             if(flag){
    / z/ {0 o) Q4 v) ?
44.                                                     response.sendRedirect("success.jsp");
    
45.                                             }else{
    8 _/ }/ r" e! s& `7 f! t7 ]
46.                                                     response.sendRedirect("failure.jsp");
    * ^- x/ G/ |! J( S) k7 s
47.                                             }
    : X& h  i' s3 u9 J8 I; A% F  d
48.                                         }
    4 m' ~' r& ^3 f( x/ N
49.                                 }
    + l& m) M! A& w2 j) m* W6 T' a. N
50.                                
    
51.                         } catch (Exception e) {                               
    ) n) j' ~5 f& b, K2 J% m
52.                                 e.printStackTrace();
    ! _* ]" ^, Q) y# w& x. |+ {# Q2 d5 `
53.                         }
    
54.                 }               
    6 S* O7 K" F# F/ }( {4 r7 @/ t
55.        
    ) z- u  i1 o  B+ g5 o. B
56.         }
    
57. 
    0 K# ^3 }2 ]" J# a' O$ g
58. }

复制代码

配置：

1. <configuration>
   
2.   <property>
   
3.      <name>fs.default.name </name>
   2 ^) Y& w3 R" b6 ]" l& r
4.      <value>hdfs://10.6.12.101:8888</value>
   
5.   </property>
   
6. <property>
   
7. <name>hadoop.tmp.dir</name>
     q' C, s" v4 l3 [, `4 @5 E* c7 H2 c
8. <value>/home/hadoopuser/tmp</value>
   $ ~# L9 }& m! i. ^+ J6 C# I! m
9. </property>
   
10. </configuration>

复制代码

源码下载地址：点击下载

) }# q2 K: [0 J) t

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下