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

admin

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

1. /**
   6 _+ O. ]9 A) j) M
2. *  
   
3. * 上传控制类，上传页面跳转到这里
   
4. *
   
5. * @author  科帮网
   
6. * @version  [版本号, 2012-08-02]
   
7. * @see  [相关类/方法]
   0 y0 X! h9 K. U# P
8. * @since  version 1.0
   ( K" J. ^; f9 v$ C3 r
9. */
   
10. public class UploadHDFSServlet extends HttpServlet {
    
11. 
    
12.         /** *
    
13.          * * 该方法负责上传控制处理页面         *
    
14.          * @param request 客户端到服务器的请求消息
    / {9 o" X% Y4 K9 w6 K
15.          * @param response 服务器返回给页面的消息
    8 t/ n- N& D( W! @) j9 V# k+ R
16.          * @throws ServletException
    
17.          * @throws IOException
    
18.          */
    
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    / U* b2 m. q% r3 f% S/ z& X
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    ! {* w7 ~- _( Z7 \1 V  s" z
22.                 if(!isMultipart){
    # n+ ]  R% |5 E6 d
23.                 }else{                       
    " r  o% y8 g' z  y
24.                         FileItemFactory factory = new DiskFileItemFactory();
    / b$ `7 C+ T8 w1 c1 |
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    
26.                         try {
    
27.                                 List items = upload.parseRequest(request);                       
    7 z3 ~5 [% Y/ |& A5 z' J0 n
28.                                 Iterator iter = items.iterator();
    8 b, V9 P9 A$ D2 p9 _
29.                                 while(iter.hasNext()){
    
30.                                         FileItem item = (FileItem)iter.next();
    
31.                                         if(item.isFormField()){
    
32.                                                 String name = item.getFieldName();
    9 [0 Z2 f+ G8 L9 M5 t* z' P
33.                                                 System.out.println(name);
    4 ?* k8 q$ Q# D5 k: O
34.                                         }else{
    4 `5 d) o+ P+ n- X
35.                                                 //表单名字
    : M! y5 d! g; |& ^% K8 a$ K
36.                                             String fileName = item.getName();
    $ W/ I5 [: ^' d4 N3 p0 B; V3 S' S
37.                                             InputStream uploadedStream = item.getInputStream();
    " K9 W: E, S$ O
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    
39.                                             
    6 v( n$ p' @2 [3 k. _* S
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    
42.                                             
    : \9 A% Y5 t/ @0 N! L
43.                                             if(flag){
    
44.                                                     response.sendRedirect("success.jsp");
    
45.                                             }else{
    6 O  T3 \3 D% |. A8 Z2 d: o1 |; O" e
46.                                                     response.sendRedirect("failure.jsp");
    - _6 D7 F/ h5 x9 o
47.                                             }
    4 O: \  s( ]' o7 U
48.                                         }
    
49.                                 }
    
50.                                
    6 h: h, O/ ?% t" v% K2 B- ?' x# g  I& Y7 G
51.                         } catch (Exception e) {                               
    
52.                                 e.printStackTrace();
    & t. ?) r, F" s. u  P
53.                         }
    ' m. B8 X+ u9 b% U) m
54.                 }               
    " e6 b& C% X- `* |+ i1 M8 W4 r4 @
55.        
    
56.         }
    
57. 
    
58. }

复制代码

配置：

1. <configuration>
   , s+ W# v1 |- }- ?' ]
2.   <property>
   
3.      <name>fs.default.name </name>
   
4.      <value>hdfs://10.6.12.101:8888</value>
   
5.   </property>
   
6. <property>
   
7. <name>hadoop.tmp.dir</name>
   ; Y8 T7 i6 P3 Z3 V. G. {
8. <value>/home/hadoopuser/tmp</value>
   , h9 ]. g  c6 K& z. V# O
9. </property>
   
10. </configuration>

复制代码

源码下载地址：点击下载

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下