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

admin

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

1. /**
   
2. *  
   & t3 l) d/ A  |/ }# D5 [$ S6 L+ F; _
3. * 上传控制类，上传页面跳转到这里
     U1 d' e1 C7 j( [7 V1 {3 S- L
4. *
   - P% W: F# \2 d! d' ]3 R0 O$ a
5. * @author  科帮网
   
6. * @version  [版本号, 2012-08-02]
   
7. * @see  [相关类/方法]
   
8. * @since  version 1.0
   
9. */
   
10. public class UploadHDFSServlet extends HttpServlet {
    4 ~; i( @# f' e
11. 
    
12.         /** *
    ( E0 a' }/ p* p5 j8 w5 m
13.          * * 该方法负责上传控制处理页面         *
    
14.          * @param request 客户端到服务器的请求消息
    2 Q5 A$ Z' \4 a8 g! V
15.          * @param response 服务器返回给页面的消息
    : |* c8 S2 u- j9 {
16.          * @throws ServletException
    ; o$ A0 [8 `! z; B; \' O
17.          * @throws IOException
    
18.          */
    4 Y; |5 T' K! B) B" h
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    ( L  z; x% P0 e/ v: ^
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    
22.                 if(!isMultipart){
    
23.                 }else{                       
    + n  g; {: _$ S: v% j
24.                         FileItemFactory factory = new DiskFileItemFactory();
    $ f& i' G6 K, V. S
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    
26.                         try {
    3 |5 M+ D1 l- k
27.                                 List items = upload.parseRequest(request);                       
    8 B" q4 A( r; T4 @) c5 Y1 Z" ^$ V
28.                                 Iterator iter = items.iterator();
    
29.                                 while(iter.hasNext()){
    $ K+ I; S6 Y- M
30.                                         FileItem item = (FileItem)iter.next();
    
31.                                         if(item.isFormField()){
    
32.                                                 String name = item.getFieldName();
    / [4 @% e* I: r" f
33.                                                 System.out.println(name);
    
34.                                         }else{
    
35.                                                 //表单名字
    
36.                                             String fileName = item.getName();
    
37.                                             InputStream uploadedStream = item.getInputStream();
    
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    ; d, p" }' {5 ?
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    ' J" ~+ I: ?! P0 h& Q- z* \
42.                                             
    ; R8 m; d% ^- n2 f; c
43.                                             if(flag){
    ( j) A2 {! I6 O8 S* h* V
44.                                                     response.sendRedirect("success.jsp");
    
45.                                             }else{
    
46.                                                     response.sendRedirect("failure.jsp");
      n& G; c8 q( O  |% G1 Z
47.                                             }
    
48.                                         }
    
49.                                 }
    * A0 u' q& V! x5 u8 ]* f" |
50.                                
    # t- A: I3 `* e/ B0 L
51.                         } catch (Exception e) {                               
    7 z8 B  x) |3 R) ?! y7 s
52.                                 e.printStackTrace();
    2 F$ [4 V1 q- A
53.                         }
    , s2 @% [- {# m2 O& @
54.                 }               
    / d' v( v( p2 ^" L4 i* [' x$ u
55.        
    & M8 e* z; N' Y9 \
56.         }
    
57. 
    ) W) q6 n8 n- a% A/ L4 R
58. }

复制代码

配置：
) ?3 Z$ M) T7 H) ?# A4 n

1. <configuration>
   
2.   <property>
   
3.      <name>fs.default.name </name>
   8 V& n' W  x3 ~; \( f
4.      <value>hdfs://10.6.12.101:8888</value>
   % J$ P% n# j# x/ R
5.   </property>
   % j# B  s; C2 C: X9 g5 m
6. <property>
     ^1 x* G3 y3 `4 S. i  d
7. <name>hadoop.tmp.dir</name>
   * s( }: y* y/ L2 D$ f# {& E; m
8. <value>/home/hadoopuser/tmp</value>
   2 s: p  g$ O; f* i6 C
9. </property>
   + {3 \8 _: |( f
10. </configuration>

复制代码

源码下载地址：点击下载


0 k2 ~' Q0 b2 v, k+ w; N

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下