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

admin

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

1. /**
   . ~2 f7 Y: x5 h+ i' n
2. *  
   & S4 A/ g  g, I0 }& j& T
3. * 上传控制类，上传页面跳转到这里
   
4. *
   ! \: P- a8 I5 T- Q& G
5. * @author  科帮网
   
6. * @version  [版本号, 2012-08-02]
   / _. [! u6 g) C
7. * @see  [相关类/方法]
   
8. * @since  version 1.0
   ; H; N/ M4 s+ z  x7 ^" n0 x
9. */
   
10. public class UploadHDFSServlet extends HttpServlet {
    
11. 
    ; P1 H* F$ y8 T" h
12.         /** *
    4 ?& x, t; X, ]! r& X' O
13.          * * 该方法负责上传控制处理页面         *
    7 Q1 ^% V9 n7 \6 e7 O: w! q9 Y
14.          * @param request 客户端到服务器的请求消息
    
15.          * @param response 服务器返回给页面的消息
    3 J. G- J+ S3 o2 ?+ @, [* h  p
16.          * @throws ServletException
    8 E" ^9 R5 ]; H3 u
17.          * @throws IOException
    $ `0 w0 ?; L$ ]. M! k1 i
18.          */
    
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    1 Y" z4 ^; w: }! l
22.                 if(!isMultipart){
    
23.                 }else{                       
    6 x( X3 N$ v  W% t$ n7 U
24.                         FileItemFactory factory = new DiskFileItemFactory();
    , O* r5 G# U, Q. u& u# C
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    
26.                         try {
    ) `, m! c/ H+ w0 H* u0 }' j
27.                                 List items = upload.parseRequest(request);                       
    + J; y- P6 I3 E) V3 k) @/ ]
28.                                 Iterator iter = items.iterator();
    
29.                                 while(iter.hasNext()){
    ) F2 k% G. T' A# T  O) r4 m! ?) D
30.                                         FileItem item = (FileItem)iter.next();
    
31.                                         if(item.isFormField()){
    9 m) [* V6 t+ T) L
32.                                                 String name = item.getFieldName();
    9 T, R: a' [5 L" x
33.                                                 System.out.println(name);
    % M4 f- v! D" ^; Q  \
34.                                         }else{
    
35.                                                 //表单名字
    7 ~  ?2 s: a( s1 K* ^/ ^7 K
36.                                             String fileName = item.getName();
    
37.                                             InputStream uploadedStream = item.getInputStream();
    ( D- k' a3 f& Y
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    - `5 e+ Z/ X% B# z% X, d" j
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    3 R* K$ m4 k5 A( r; X5 n
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    / Y4 k; A' Z8 r  h0 K
42.                                             
    
43.                                             if(flag){
    
44.                                                     response.sendRedirect("success.jsp");
    & r; ~, }/ ]+ f
45.                                             }else{
    
46.                                                     response.sendRedirect("failure.jsp");
    # \1 Q6 u) v1 @7 o+ |) h/ H7 b
47.                                             }
    
48.                                         }
    . Y* _" j+ o* g
49.                                 }
    % y* x/ \8 S# b) ]9 ~* O
50.                                
    
51.                         } catch (Exception e) {                               
    
52.                                 e.printStackTrace();
    
53.                         }
    9 X+ e1 l% q' F1 G' N3 o) Z: F
54.                 }               
    : a3 p( m) h4 |+ d$ q
55.        
    
56.         }
    * b+ J2 }3 O, J- [( \' X5 C. \
57. 
    . D  B/ z/ L" ~$ Y2 K3 n
58. }

复制代码

配置：
; u3 u8 @; v" ]( \

1. <configuration>
   
2.   <property>
   
3.      <name>fs.default.name </name>
   
4.      <value>hdfs://10.6.12.101:8888</value>
   ' A. r- L$ r) U8 i2 r9 K
5.   </property>
   + H: W( I# @7 o
6. <property>
   2 ^$ u/ ~: ]2 [5 a
7. <name>hadoop.tmp.dir</name>
   
8. <value>/home/hadoopuser/tmp</value>
   
9. </property>
   & L' x" {, C$ p8 V: w
10. </configuration>

复制代码

源码下载地址：点击下载

; x$ G( e& q5 Z7 t6 ~

, e% N4 l% {% {6 S2 W& \

wudizxt

不错不错不错，学习一下

woniu

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

九纹龙

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

昕动2014

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