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

admin

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

1. /**
   
2. *  
   9 `1 c. T0 I9 r2 n1 c9 X
3. * 上传控制类，上传页面跳转到这里
   : }, m5 t: d; s1 j
4. *
   
5. * @author  科帮网
   
6. * @version  [版本号, 2012-08-02]
   * i( r; ?* E1 ?$ g0 y4 M, w9 k
7. * @see  [相关类/方法]
   6 O% t: C; d. }# R0 c: B- l
8. * @since  version 1.0
   6 D& K( o) A+ h5 N
9. */
   
10. public class UploadHDFSServlet extends HttpServlet {
    
11. 
    + \; u+ B: m6 m, q3 g
12.         /** *
    - ]8 {/ t3 |8 s0 ^) V
13.          * * 该方法负责上传控制处理页面         *
    
14.          * @param request 客户端到服务器的请求消息
    
15.          * @param response 服务器返回给页面的消息
    
16.          * @throws ServletException
    $ l# d+ G7 `/ X% J0 W; g0 m+ Y
17.          * @throws IOException
    
18.          */
    : Z3 O/ h1 W9 f/ Y
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    
20.                         throws ServletException, IOException {
    8 s# o- l, G2 r& I- [
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    8 Z  I8 M& u+ c" O) D0 b
22.                 if(!isMultipart){
      l4 h7 Y, Q- D, I; O
23.                 }else{                       
    3 v- n9 \- s1 ]0 k5 N  e
24.                         FileItemFactory factory = new DiskFileItemFactory();
    
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    8 q, F7 g9 Y6 m1 T( A1 [
26.                         try {
    
27.                                 List items = upload.parseRequest(request);                       
    
28.                                 Iterator iter = items.iterator();
      |. z8 _2 T4 p+ b) {
29.                                 while(iter.hasNext()){
    " n' e) I& @3 h7 M
30.                                         FileItem item = (FileItem)iter.next();
    
31.                                         if(item.isFormField()){
    " l8 o3 I3 e- K1 M, H* X
32.                                                 String name = item.getFieldName();
    
33.                                                 System.out.println(name);
    
34.                                         }else{
    
35.                                                 //表单名字
    
36.                                             String fileName = item.getName();
    3 P2 j& w( L& N* d  x
37.                                             InputStream uploadedStream = item.getInputStream();
    ; q! n! E9 ~" D  {$ l* B( x
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    
42.                                             
    
43.                                             if(flag){
    % \5 N$ p5 ^+ ~7 O: a/ o! j4 y
44.                                                     response.sendRedirect("success.jsp");
    
45.                                             }else{
    : N: Q) J6 S4 P1 q
46.                                                     response.sendRedirect("failure.jsp");
    
47.                                             }
    
48.                                         }
    
49.                                 }
    
50.                                
    
51.                         } catch (Exception e) {                               
    6 ?4 k  d) ]' {' a! t+ ]  t' M
52.                                 e.printStackTrace();
    
53.                         }
    $ s+ D. Y2 b# O* M  S
54.                 }               
    6 [* D9 z0 g7 l& ], M% N
55.        
    
56.         }
    
57. 
    : x- f1 z7 t+ E- F9 G
58. }

复制代码

配置：
% s$ h# ]7 K/ v& o) ~

1. <configuration>
   " Q" ~# L- O5 K) B8 k3 v7 _
2.   <property>
   
3.      <name>fs.default.name </name>
   9 V! K: o# I. A. h1 D
4.      <value>hdfs://10.6.12.101:8888</value>
   & B9 @/ D& m9 q) ?- C
5.   </property>
   
6. <property>
   
7. <name>hadoop.tmp.dir</name>
   
8. <value>/home/hadoopuser/tmp</value>
   
9. </property>
   ! D: D2 ?+ ^  R% t* e
10. </configuration>

复制代码

源码下载地址：点击下载



( G: s3 }' E% T% U

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下