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

admin

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

1. /**
   
2. *  
   / e' e" [" |1 I$ U) L
3. * 上传控制类，上传页面跳转到这里
   
4. *
   0 R7 x& b: ?  G' e
5. * @author  科帮网
   + E- a9 e  i. N! c
6. * @version  [版本号, 2012-08-02]
   
7. * @see  [相关类/方法]
   % \2 C% Y8 k& x5 l- d0 X. e4 U
8. * @since  version 1.0
   
9. */
   ' z: c$ P1 ], Z
10. public class UploadHDFSServlet extends HttpServlet {
    5 N. K/ {, o! l# v7 M9 \$ Q7 g
11. 
    : Z7 p! @. Z% `
12.         /** *
    $ |7 z7 P$ ?1 W7 j* L  W
13.          * * 该方法负责上传控制处理页面         *
    
14.          * @param request 客户端到服务器的请求消息
    
15.          * @param response 服务器返回给页面的消息
    
16.          * @throws ServletException
    
17.          * @throws IOException
    8 j  y+ Q5 j5 H# u& f* V: J
18.          */
    & a% [+ ]$ `3 |* M
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    - n# Q6 U' W3 D" u
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    
22.                 if(!isMultipart){
    9 t0 ]2 u( m/ O, E& _) n
23.                 }else{                       
    
24.                         FileItemFactory factory = new DiskFileItemFactory();
    
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    
26.                         try {
    
27.                                 List items = upload.parseRequest(request);                       
    
28.                                 Iterator iter = items.iterator();
    , e" w1 e2 e% }
29.                                 while(iter.hasNext()){
    * K& F- p1 L( x8 w) _3 @
30.                                         FileItem item = (FileItem)iter.next();
    
31.                                         if(item.isFormField()){
    ' V6 |( x* u9 q$ y9 n
32.                                                 String name = item.getFieldName();
    7 `; r3 C' a: R! C2 n/ ~! t
33.                                                 System.out.println(name);
    
34.                                         }else{
    ( ?3 B* N. H5 ^
35.                                                 //表单名字
    
36.                                             String fileName = item.getName();
    # ]- S3 i8 k5 u0 E
37.                                             InputStream uploadedStream = item.getInputStream();
    2 v4 t1 M# c  [. X! y. e0 y
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    / K; ~) G1 d& }9 X% D8 G# Y1 A: b
42.                                             
    
43.                                             if(flag){
    
44.                                                     response.sendRedirect("success.jsp");
    ' u& h8 Y% N0 p
45.                                             }else{
    1 M) s: M/ ^2 b8 I8 Y
46.                                                     response.sendRedirect("failure.jsp");
    
47.                                             }
    
48.                                         }
    ) |, s+ X7 Z* C
49.                                 }
    ' y' N/ \  O; t, ]" F5 T
50.                                
    4 c6 M. f8 B" q# G6 N
51.                         } catch (Exception e) {                               
    2 _0 _9 P. r& O5 M
52.                                 e.printStackTrace();
    
53.                         }
    . W& |1 B0 y( d
54.                 }               
    + |+ c1 g' m1 U0 R
55.        
    
56.         }
    ; G7 W, i4 q& [* F0 L
57. 
    3 _$ _' x, H! v, V
58. }

复制代码

配置：
6 Y/ _( A: V& W7 _

1. <configuration>
   
2.   <property>
   2 |+ y) z8 ^7 N# ^7 \
3.      <name>fs.default.name </name>
   
4.      <value>hdfs://10.6.12.101:8888</value>
   
5.   </property>
   
6. <property>
   ' z7 X9 h. i! ^6 Y
7. <name>hadoop.tmp.dir</name>
   ; ^7 p$ j6 P( O5 w( q4 A; b: D6 z
8. <value>/home/hadoopuser/tmp</value>
   1 O) v  O$ Z  j. S6 L0 [
9. </property>
   
10. </configuration>

复制代码

源码下载地址：点击下载

! j7 l5 c/ |9 K- J) J

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下