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

admin

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

1. /**
   . L: d0 c: P+ H' Y0 q: U2 Y
2. *  
   - f2 {; T$ c: t! O
3. * 上传控制类，上传页面跳转到这里
   + b( c! t& G5 Y$ h
4. *
   
5. * @author  科帮网
   
6. * @version  [版本号, 2012-08-02]
   
7. * @see  [相关类/方法]
   
8. * @since  version 1.0
   
9. */
   
10. public class UploadHDFSServlet extends HttpServlet {
    % u% z  W% e* S4 E
11. 
    
12.         /** *
    
13.          * * 该方法负责上传控制处理页面         *
    4 W% F7 |+ ~4 ]; a) m' ?
14.          * @param request 客户端到服务器的请求消息
    
15.          * @param response 服务器返回给页面的消息
    
16.          * @throws ServletException
      }6 D) q9 I- `7 H
17.          * @throws IOException
    
18.          */
    
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    
22.                 if(!isMultipart){
    
23.                 }else{                       
    . R. V8 y+ G- T% Q1 C
24.                         FileItemFactory factory = new DiskFileItemFactory();
    
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    
26.                         try {
    " i' z+ W9 D! B. N& n
27.                                 List items = upload.parseRequest(request);                       
    # q; ^' b- s9 d8 b) `
28.                                 Iterator iter = items.iterator();
    
29.                                 while(iter.hasNext()){
    4 ~: n# l# Q: D$ C
30.                                         FileItem item = (FileItem)iter.next();
    % S+ B# f) u" ?4 b4 z# o) N: G
31.                                         if(item.isFormField()){
    3 R! u4 @( d& V4 m* p4 q# v+ Q
32.                                                 String name = item.getFieldName();
    ( {: t( y; K  ^
33.                                                 System.out.println(name);
    
34.                                         }else{
    
35.                                                 //表单名字
    
36.                                             String fileName = item.getName();
    
37.                                             InputStream uploadedStream = item.getInputStream();
    / ~; p% `2 O3 |& ~' ], w
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    5 q% `* x/ S  O2 r# ]  z9 @
39.                                             
      X0 v+ X  w& k3 Y7 P/ d" F
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    8 |% X4 _$ K/ r# T
42.                                             
    
43.                                             if(flag){
    4 l  P) B' y  Y7 V
44.                                                     response.sendRedirect("success.jsp");
    
45.                                             }else{
    2 u9 A' o+ b6 e" P+ ^
46.                                                     response.sendRedirect("failure.jsp");
    
47.                                             }
    , {$ J8 s& [4 t% s5 w. E5 _# q
48.                                         }
    
49.                                 }
    
50.                                
    % P6 t: x& _7 X/ c' v8 ?
51.                         } catch (Exception e) {                               
    1 ^/ N8 h. p" n
52.                                 e.printStackTrace();
    
53.                         }
    ; E, B4 f+ {1 ]" Q. ]* h. \
54.                 }               
    & \* S/ ^: F1 f& z9 u
55.        
    
56.         }
    1 h$ C/ B7 u& @/ p1 j& J5 e  L
57. 
    
58. }

复制代码

配置：

1. <configuration>
   
2.   <property>
   7 [" Y; f# T: M& B, H1 R
3.      <name>fs.default.name </name>
   
4.      <value>hdfs://10.6.12.101:8888</value>
   
5.   </property>
   * }% U! A, L. Q( n3 ^( N1 M$ L
6. <property>
   1 o/ Y: ]" A4 m6 H1 I4 |* R
7. <name>hadoop.tmp.dir</name>
   
8. <value>/home/hadoopuser/tmp</value>
   
9. </property>
   
10. </configuration>

复制代码

源码下载地址：点击下载
2 Z3 g; f: ]1 r% V! H
* n4 [3 P, p. i8 }) g4 f5 ^

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下