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

admin

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

1. /**
   ! R% {4 u: N: L5 R, r7 u% a
2. *  
   : l! p) [) Y5 g: s9 ^' C) i
3. * 上传控制类，上传页面跳转到这里
   
4. *
   
5. * @author  科帮网
   
6. * @version  [版本号, 2012-08-02]
   * v* N5 V" s5 T# }2 S2 }+ A
7. * @see  [相关类/方法]
   
8. * @since  version 1.0
   & M5 m9 b( k8 e" P4 G
9. */
   ' K% ^/ L) h6 b, w6 p' x. |
10. public class UploadHDFSServlet extends HttpServlet {
    
11. 
    
12.         /** *
    3 |. l7 l5 u0 F- g
13.          * * 该方法负责上传控制处理页面         *
    
14.          * @param request 客户端到服务器的请求消息
    
15.          * @param response 服务器返回给页面的消息
    
16.          * @throws ServletException
    3 g0 }8 B4 L1 f& ]1 E
17.          * @throws IOException
    
18.          */
    
19.         public void doPost(HttpServletRequest request, HttpServletResponse response)
    
20.                         throws ServletException, IOException {
    
21.                 boolean isMultipart = ServletFileUpload.isMultipartContent(request);
    
22.                 if(!isMultipart){
    & C# a- y5 _- S: G7 _
23.                 }else{                       
    
24.                         FileItemFactory factory = new DiskFileItemFactory();
    
25.                         ServletFileUpload upload = new ServletFileUpload(factory);
    $ R# O' c8 t# ~0 L* D$ z- N- {" ?4 p
26.                         try {
    : y, @8 Y1 Z& L, r, ^9 f2 K
27.                                 List items = upload.parseRequest(request);                       
    
28.                                 Iterator iter = items.iterator();
    / z: ~: I$ d/ O& `8 E1 v
29.                                 while(iter.hasNext()){
    : K9 z7 D6 [9 e7 ~) a" g, [
30.                                         FileItem item = (FileItem)iter.next();
    3 ^+ r+ Z$ k, s4 d
31.                                         if(item.isFormField()){
    7 J9 ?+ z4 h0 b+ f. }
32.                                                 String name = item.getFieldName();
    7 i8 t2 k/ Q7 A, ?; E8 i1 E- H. O" R
33.                                                 System.out.println(name);
    
34.                                         }else{
    8 Z# [( Y0 B. @" D- l1 d% a6 v
35.                                                 //表单名字
    
36.                                             String fileName = item.getName();
    
37.                                             InputStream uploadedStream = item.getInputStream();
    
38.                                             HDFSOperation hdfsOperation = new HDFSOperation();
    1 I; {  V9 X8 H, g1 e2 h; f
39.                                             
    
40.                                             String hdfsPath = dfs.HDFSConfig.getHDFSPath() + fileName;
    
41.                                             boolean flag = hdfsOperation.upLoad(uploadedStream, hdfsPath);       
    2 N  X, G5 t# r9 ?# u2 J; r( F8 T. m
42.                                             
    
43.                                             if(flag){
    
44.                                                     response.sendRedirect("success.jsp");
      u$ P) m3 ^# |5 C
45.                                             }else{
    - ~$ t' R9 \" I: h  x; `
46.                                                     response.sendRedirect("failure.jsp");
    
47.                                             }
    4 Q9 J; g! J- t# k4 j
48.                                         }
    * q1 i4 {* i) ~9 g$ M2 C' C% y4 T
49.                                 }
      p4 H0 z* n3 P1 r. d4 ?# p, B
50.                                
    
51.                         } catch (Exception e) {                               
    
52.                                 e.printStackTrace();
    4 u# S/ m; X, N5 N3 P0 X+ o' d  {
53.                         }
    * H: ?2 \, ^5 U. B, d- A/ n6 u
54.                 }               
    
55.        
    
56.         }
    1 Y5 W8 C7 m& l9 h- r( Z, r
57. 
    
58. }

复制代码

配置：

1. <configuration>
   ; e" M) V% C0 O4 I7 W, y. m, S
2.   <property>
   ) D* r3 y5 j: M" y' d
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>
   $ s$ k' k, H9 P
8. <value>/home/hadoopuser/tmp</value>
   4 G9 p: h3 y0 |, ~( V7 S
9. </property>
   
10. </configuration>

复制代码

源码下载地址：点击下载
7 G2 X$ e' _/ B* P; }" v9 i
6 i1 s* @; e/ y/ [6 _/ W: t: M$ d

昕动2014

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

九纹龙

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

woniu

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

wudizxt

不错不错不错，学习一下