基於hessian的文件傳輸 (轉)

基於hessian的文件傳輸

一般文件傳輸建議仍是經過 ftp ，只有當 ftp 知足不了需求時，才考慮 hessian 的傳輸方案。

Hessian 傳文件的應用場景有好比兩臺須要傳輸文件的服務器之間的網絡狀況限制比較嚴格，不容許 ftp 或新開端口之類；兩臺服務器之間傳文件必須通過一臺中間機器中轉。還有就是得到比 ftp 傳輸更大的靈活性。上面的一些應用場景，都是在項目裏實際遇到的。

Hessian 是不支持 File 的直接傳輸的，因此採起的方案是將 File 讀到 byte[] 再用 hessian 傳輸。
   不過最新的 hessian4.0 已經支持 InputStream 做爲參數或返回值進行傳輸。

    public  String uploadStream(String filename, InputStream data)
     {
        HessianInerface hessianInerface  =  (HessianInerface) getHessianInterface();
         return  hessianInerface.uploadStream(filename, data);

    }

可是以上2中方法都會有個問題，就是當文件比較大的時候，會報java.lang.OutOfMemoryError。

基於 byte[] 的方法的解決辦法是將大的文件分紅一小塊一小塊進行傳輸。

   public  String uploadSingleFiles(File file)
     {
        String logicPath  =   "" ;
        InputStream is  =   null ;

         try 
          {

             byte [] buffer  =   null ;

            HessianInerface hessianInerface  =  (HessianInerface) getHessianInterface();

            is  =   new  FileInputStream(file);
             long  size  =  file.length();
             long  perSize  =  onePerSize;
             if  (size  >  onePerSize)
             {
                 long  index  =  size  /  perSize;
                 if  (size  >  perSize  *  index)
                 {
                    index  =  index  +   1 ;
                } 
 
                 for  ( long  j  =   1 ; j  <=  index; j ++ )
                 {
                     long  curPerSize  =  perSize;
                     if  (j  ==  index)
                     {
                        curPerSize  =  size  -  perSize  *  (j  -   1 );
                    } 
 
                    buffer  =   new   byte [( int ) curPerSize];
                    is.read(buffer);


                     if  (j  ==   1 )
                     {

                        logicPath  =  hessianInerface.uploadSingleBigFile(buffer,
                                file.getName(),  false );
                    }   else 
                      {
                        logicPath  =  hessianInerface.uploadSingleBigFile(buffer,
                                file.getName(),  true );

                    } 
 
                } 
 
            }   else 
              {
                buffer  =   new   byte [is.available()];
                is.read(buffer);

                logicPath  =  hessianInerface.uploadSingleFile(buffer, file
                        .getName());

            } 
 
        }   catch  (IOException e)
         {
             throw   new  RuntimeException(e);
        }   finally 
          {
            IOUtils.closeQuietly(is);
        } 
 
         return  logicPath;
    } 

基於 InputStream 的解決辦法，最初想法講 InputStream 分塊讀出傳輸，不過沒成功，若是誰成功，請告訴我一聲。

總結，若是 jvm 的內存設置比較大， InputStream 的方式是能夠直接傳輸的，而 byte[] 的方式超過必定的大小就報錯，在個人機器上大概 20M 左右。因此基於 byte[] 的分塊傳輸是目前比較合理的解決辦法。

代碼比較多，我就不一一帖出了，在最後放出下載的連接，在服務端的實現類請根據本身的需求稍微修改下就能運行起來。

使用方法示例以下 :

 HessianClient cl  =   new  HessianClient();

 cl.setHessianserviceurl( http://127.0.0.1:80/hessianService );

 

             long  onePerSize  =   2080000 ;

          cl.setOnePerSize(onePerSize);

         File file1  =   new  File( " d:\\tddownload\\CJT.rar " );

        cl.uploadSingleFiles(file1)  ;

 

        File ff =    cl.downloadSingleBigFile( 23884L , " 中文9999.rar " )  ;

 

代碼還能夠繼續完善的地方，好比加入文件的完整性校驗，壓縮傳輸等。
代碼下載地址：http://www.blogjava.net/Files/magicdoom/hessianTransferFile.rar