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

admin

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

1. /**
   ; u* |, N. J3 |) T  _5 c0 n
2. *  
   
3. * 上传控制类，上传页面跳转到这里
   9 ^) b; F% r' @  P" Z
4. *
   
5. * @author  科帮网
   # y5 a, E  v3 U. O& Q
6. * @version  [版本号, 2012-08-02]
   
7. * @see  [相关类/方法]
   
8. * @since  version 1.0
   
9. */
   & u3 C3 ^3 T3 c" q4 k
10. public class UploadHDFSServlet extends HttpServlet {
    
11. 
    
12.         /** *
    6 s! S0 g& X: x
13.          * * 该方法负责上传控制处理页面         *
    , G- N, ~$ j& O3 i" Y0 G  a
14.          * @param request 客户端到服务器的请求消息
    
15.          * @param response 服务器返回给页面的消息
    0 Q9 i# C& K8 V( R' T
16.          * @throws ServletException
    
17.          * @throws IOException
    
18.          */
    0 _9 t- Y# R* ]: r, i
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    . u4 e, ]! \4 J4 n8 Q2 m! v
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    
22.                 if(!isMultipart){
    
23.                 }else{                       
    . L* L: j& m) t  J; D8 h' x7 a6 u
24.                         FileItemFactory factory = new DiskFileItemFactory();
    2 r, h0 v7 c6 q$ ^  E
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    ; k! o, h5 d) _1 @
26.                         try {
    
27.                                 List items = upload.parseRequest(request);                       
    2 u5 m9 g: X1 c$ R) o+ C
28.                                 Iterator iter = items.iterator();
    ) O' J% T7 w- y
29.                                 while(iter.hasNext()){
    
30.                                         FileItem item = (FileItem)iter.next();
    0 K. Q2 n9 ^6 w& L+ `1 L
31.                                         if(item.isFormField()){
    - Q4 e1 H/ G1 A" @& L& v
32.                                                 String name = item.getFieldName();
    
33.                                                 System.out.println(name);
    
34.                                         }else{
    
35.                                                 //表单名字
    6 A9 I2 m6 t7 Z! ^, k
36.                                             String fileName = item.getName();
    2 c/ Y$ l& j8 ?# [
37.                                             InputStream uploadedStream = item.getInputStream();
    2 i/ U- b, s% ]
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    % R. R: e2 Z3 t: U( f
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    : d) O6 A- G: p! p7 K' g
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    
42.                                             
    - }! o9 Y$ D2 o1 E: B" Y
43.                                             if(flag){
    2 D* e" v) B& T; I; H
44.                                                     response.sendRedirect("success.jsp");
    
45.                                             }else{
    2 ?, ~- k2 p& f% i) r5 |# H; i
46.                                                     response.sendRedirect("failure.jsp");
    
47.                                             }
    
48.                                         }
    
49.                                 }
    
50.                                
    
51.                         } catch (Exception e) {                               
    + M1 {' K8 z. ?) g  a1 @
52.                                 e.printStackTrace();
    % }# K; g5 T2 Z
53.                         }
    ( i- B' l4 k) P9 O5 s4 H) R
54.                 }               
    
55.        
    
56.         }
    
57. 
    ; L% d, y+ e, s5 z& h( T- G
58. }

复制代码

配置：

1. <configuration>
   8 B0 X* D* d7 T9 F+ z8 X3 v% w  P
2.   <property>
   , r0 @" }/ t, J+ I5 G, P
3.      <name>fs.default.name </name>
   % {) J3 Q8 F1 R. ]' G. i
4.      <value>hdfs://10.6.12.101:8888</value>
   % [1 c9 `  P! g  d
5.   </property>
   1 ^% ^6 e, b( y- L
6. <property>
   5 I3 _5 t7 ^6 k1 P- N# X
7. <name>hadoop.tmp.dir</name>
   ; t' s- e% d# P0 q1 T- Y$ ?9 [
8. <value>/home/hadoopuser/tmp</value>
   5 p/ O! T0 W1 \
9. </property>
   
10. </configuration>

复制代码

源码下载地址：点击下载

# @9 L6 |; R+ @
3 a2 O' ]3 s* v! A" P9 f

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下