JAVA应用XFire框架来实现WebServie的大文件传输功能之一（下载）

下面是文件下载功能，可以实现大文件的断点续传，其原理是把服务端先把文件内容Byte[]转换成Base64编码字符串返回给客户端，然后客户端接收到后再把该Base64编码过的字符串转换成Byte[]，最后写入文件。

      至于断点续传的设计很简单，服务端留有一个定位参数，每次读取文件之前，都先定位，然后客户端在调用WebService接口之前，先取得本地该文件的大小，再把该值作为定位参数传过去就OK，最后根据接收到的字符串的长度为0时作为文件传输完毕的判断依据。

      另外如果想做到实时取得文件传输的进度的话，可以设计一个地址参数，根据累计传输大小来返回即可，在这里略过。

文件上传部分代码反过来即可，这里也略过。

xml文件：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://xfire.codehaus.org/config/1.0">

    <service>

       <name>HelloWorldService</name>

       <namespace>http://localhost:8090/WebServiceTest

       </namespace>

       <serviceClass>service.IHelloWorld</serviceClass>

       <implementationClass>service.HelloWorldImpl

       </implementationClass>

    </service>

</beans>
 

接口文件：

package service;

 

public interface IHelloWorld { 

    //sayHello 方法声明了Web服务对外暴露的接口

    public String download(String filename,long startpost) throws Exception ;

}

服务端文件：

package service;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.RandomAccessFile;

import javax.activation.DataHandler;
import javax.servlet.http.HttpServletRequest;

import org.codehaus.xfire.transport.http.XFireServletController;
import org.codehaus.xfire.util.Base64;

public class HelloWorldImpl implements IHelloWorld {
 private RandomAccessFile raf=null;
 
 /**
  * @filename:要下载的文件名（全名）;
  * @startpost:由于WebService不能一次性传输大文件，所以使用startpost定位参数来实现断点续传；
  * @return:把文件内容Byte[]转换成Base64编码返回；
  */
 public String download(String filename,long startpost) throws Exception {
  //System.out.println("要下载的文件名是："+filename);
  int BUFFER_LENGTH = 1024 * 20;//一次性读入大小
  int SLEEP_TIME=250;//循环读次数
  int time=0;
  long filesize=0;
  String ret=null;
  String str=null;
  File file=new File("e://",filename);
  if (file.exists()) {
   filesize=file.length();
            FileInputStream fis = null;   
            try {   
                fis = new FileInputStream(file); 

                StringBuffer sb = new StringBuffer();   
               //System.out.println("定位："+startpost);
                fis.skip(startpost);//先定位
                byte[] buffer = new byte[BUFFER_LENGTH];   
                int count;   
                while (time<SLEEP_TIME && (count = fis.read(buffer)) != -1 ) {
                    sb.append(Base64.encode(buffer,0,count));  
                    time++;
                }   
                ret = sb.toString();  
               //System.out.println("输出："+ret.length());
            } catch (FileNotFoundException e) {   
                e.printStackTrace();   
                throw new Exception("出错啦！", e);   
            } catch (IOException e) {   
                e.printStackTrace();   
                throw new Exception("出错啦！", e);   
            } catch (Exception e) {   
                throw new Exception("出错啦！", e);   
            } finally {   
                fis.close();   
            }   
        }  

  return ret;
 }
 

}

 

客户端文件：

package service;

import java.io.File;
import java.io.RandomAccessFile;
import java.net.MalformedURLException;
import java.net.URL;

import org.codehaus.xfire.client.Client;
import org.codehaus.xfire.transport.http.HttpTransport;
import org.codehaus.xfire.util.Base64;

public class DynamicClientTest {
 public Object[] getWebService(String surl,String saction,Object[] objarr) throws MalformedURLException,Exception
 {
   Client client = new Client(new URL(surl));
   //client.setProperty("mtom-enabled", "true");
   client.setProperty(HttpTransport.CHUNKING_ENABLED,"true"); 
   Object[] results = client.invoke(saction, objarr);
   return results;

 }
    public static void main(String[] args) throws MalformedURLException,Exception {
     String surl="http://localhost:8080/WebServiceTest/services/HelloWorldService?wsdl";

     Long start=System.currentTimeMillis();
     File file=new File("e://","test.rar");
     RandomAccessFile raf=new RandomAccessFile(file,"rw");
     //System.out.println("文件大小："+file.length());
     raf.seek(file.length());//先定位
     boolean isend=false;
     while (!isend){

      DynamicClientTest web = new DynamicClientTest();
      Object[] results3=web.getWebService(surl, "download", new Object[]{"GMS.rar",file.length()});
      String data=(String)results3[0];
      //System.out.println("返回大小："+data.length());
      byte[] bytes = Base64.decode(data);
      raf.write(bytes);
      raf.skipBytes(data.length());//顺序写
      if(data.length()<=0){isend=true;}
     }
     raf.close();

  Long end=System.currentTimeMillis();
  System.out.println("用时："+(end-start));
}
}