Hessian學習總結(二)——使用hessian上傳文件

　　hessian較早版本通過 byte[] 進行文件傳輸；4.0之后支持 InputStream 作為參數或返回值進行傳輸。
　　注意：hessian會讀取整個文件，如果文件過大，會導致JVM內存溢出。可以通過控制上傳文件的大小，設置合理的JVM參數，以及采用隨機讀取方式來解決。

一、創建Hessian服務端

　　創建一個FileUploader Web項目作為文件上傳的服務端，如下圖所示：

　　

1. 1、創建文件上傳服務接口FileUploadServiceI

　　FileUploadServiceI接口代碼如下：

package file.upload.service;

import java.io.InputStream;

/**
 * <p>ClassName: FileUploadServiceI<p>
 * <p>Description: 文件上傳服務接口<p>
 * @author xudp
 * @version 1.0 V
 * @createTime 2014-8-8 上午10:41:27
 */
public interface FileUploadServiceI {

    public void upload(String filename, InputStream data);
}

1.2. 實現文件上傳服務接口FileUploadServiceI

 　　FileUploadServiceImpl類的代碼如下：

package file.upload.service.impl;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;

import file.upload.service.FileUploadServiceI;

/**
 * <p>ClassName: FileUploadServiceImpl<p>
 * <p>Description: FileUploadServiceI文件上傳接口的具體實現類<p>
 * @author xudp
 * @version 1.0 V
 * @createTime 2014-8-8 上午10:42:43
 */
public class FileUploadServiceImpl implements FileUploadServiceI {

    /* (non-Javadoc)
     * @MethodName upload
     * @Description 上傳文件
     * @author xudp
     * @param filename 上傳的文件名
     * @param data 上傳的文件的輸入流
     * @see file.upload.service.FileUploadServiceI#upload(java.lang.String, java.io.InputStream)
     */
    public void upload(String filename, InputStream data) {
        BufferedInputStream bis = null;
        BufferedOutputStream bos = null;
        try {
            //獲取客戶端傳遞的InputStream
            bis = new BufferedInputStream(data);
            //創建文件輸出流
            bos = new BufferedOutputStream(new FileOutputStream(
                    "E:/fileUpload/" + filename));
            byte[] buffer = new byte[8192];
            int r = bis.read(buffer, 0, buffer.length);
            while (r > 0) {
                bos.write(buffer, 0, r);
                r = bis.read(buffer, 0, buffer.length);
            }
            System.out.println("-------文件上傳成功！-------------");
        } catch (IOException e) {
            throw new RuntimeException(e);
        } finally {
            if (bos != null) {
                try {
                    bos.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
            if (bis != null) {
                try {
                    bis.close();
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            }
        }
    }

}

1.3、在web.xml中配置HessianServlet

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" 
    xmlns="http://java.sun.com/xml/ns/javaee" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
    http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
  
  <servlet>
    <servlet-name>FileUploadService</servlet-name>
    <servlet-class>com.caucho.hessian.server.HessianServlet</servlet-class>
    <init-param>
    <!-- home-class也可以寫為service-class -->
      <param-name>home-class</param-name>
      <!-- 服務器對接口的現實，供客戶端調用 --> 
      <param-value>file.upload.service.impl.FileUploadServiceImpl</param-value>
    </init-param>
    <init-param>
    
    <!--
        提供給客戶端調用的接口，這里的home-api配置不是必須的，可以不配置
    -->
    <!--home-api也可以寫為api-class  -->
      <param-name>home-api</param-name>
      <!-- 客戶端接口 -->
      <param-value>file.upload.service.FileUploadServiceI</param-value>
    </init-param>
  </servlet>
  <servlet-mapping>
    <servlet-name>FileUploadService</servlet-name>
    <url-pattern>/FileUploadService</url-pattern>
  </servlet-mapping>
  
</web-app>

　　到此，服務端的編寫就完成了，部署FileUploader到Tomcat服務器，啟動Tomcat服務器，在瀏覽器地址欄輸入：http://localhost:8080/FileUploader/FileUploadService，查看是否可以調用。

　　

　　看到這樣的運行結果就說明Hessian服務器的測試通過。

二、創建文件上傳客戶端

　　創建一個普通的java項目作為文件上傳客戶端，添加對hessian-4.0.37.jar的引用，同時將Hessian服務端的FileUploadServiceI接口打包成jar包提供給文件上傳客戶端調用，如下圖所示：

　

2.1、編寫文件上傳客戶端

　　FileUploaderClient類的代碼如下：

package file.uplaod.client;

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import com.caucho.hessian.client.HessianProxyFactory;
import file.upload.service.FileUploadServiceI;

/**
 * <p>ClassName: FileUploaderClient<p>
 * <p>Description: 文件上傳客戶端<p>
 * @author xudp
 * @version 1.0 V
 * @createTime 2014-8-8 上午10:00:13
 */
public class FileUploaderClient {
     //Hessian服務的url
     private static final String url = "http://gacl:8080/FileUploader/FileUploadService";

    public static void main(String[] args) throws Exception {
        //創建HessianProxyFactory實例
        HessianProxyFactory factory = new HessianProxyFactory();
        //獲得Hessian服務的遠程引用
        FileUploadServiceI uploader = (FileUploadServiceI) factory.create(FileUploadServiceI.class, url);
        //讀取需要上傳的文件
        InputStream data = new BufferedInputStream(new FileInputStream("E:/開發資料/電子書/Shiro教程.pdf"));
        //調用遠程服務上傳文件。
        uploader.upload("Shiro教程.pdf", data);
    }
}

　　運行FileUploaderClient客戶端，就可以將文件"Shiro教程.pdf"上傳到服務器上的指定存儲目錄了，如下圖所示：