Apache CXF實戰(zhàn)之七：使用Web Service傳輸文件

作者：kongxx 2012-05-07 14:15:41

首先聲明我知道有個協議叫ftp，也知道有種編程叫sock編程，但我就是碰到了server對外只開放80端口，并且還需要提供文件上傳和下載功能的應用，那好吧，開始干活。

1. 首先是一個封裝了服務器端文件路徑，客戶端文件路徑和要傳輸的字節(jié)數組的MyFile類。

package com.googlecode.garbagecan.cxfstudy.filetransfer;  
 
 
public class MyFile {  
      
    private String clientFile;  
      
    private String serverFile;  
      
    private long position;  
      
    private byte[] bytes;  
 
    public String getClientFile() {  
        return clientFile;  
    }  
 
    public void setClientFile(String clientFile) {  
        this.clientFile = clientFile;  
    }  
 
    public String getServerFile() {  
        return serverFile;  
    }  
 
    public void setServerFile(String serverFile) {  
        this.serverFile = serverFile;  
    }  
 
    public long getPosition() {  
        return position;  
    }  
 
    public void setPosition(long position) {  
        this.position = position;  
    }  
 
    public byte[] getBytes() {  
        return bytes;  
    }  
 
    public void setBytes(byte[] bytes) {  
        this.bytes = bytes;  
    }  
}

2. 文件傳輸的Web Service接口

package com.googlecode.garbagecan.cxfstudy.filetransfer;  
 
import javax.jws.WebMethod;  
import javax.jws.WebService;  
 
@WebService 
public interface FileTransferService {  
      
    @WebMethod 
    void uploadFile(MyFile myFile) throws FileTransferException;  
 
    @WebMethod 
    MyFile downloadFile(MyFile myFile) throws FileTransferException;  
}

3. 文件傳輸的Web Service接口實現類，主要是一些流的操作

package com.googlecode.garbagecan.cxfstudy.filetransfer;  
 
import java.io.File;  
import java.io.FileInputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
import java.util.Arrays;  
 
import org.apache.commons.io.FileUtils;  
import org.apache.commons.io.IOUtils;  
 
public class FileTransferServiceImpl implements FileTransferService {  
 
    public void uploadFile(MyFile myFile) throws FileTransferException {  
        OutputStream os = null;  
          
        try {  
            if (myFile.getPosition() != 0) {  
                os = FileUtils.openOutputStream(new File(myFile.getServerFile()), true);  
            } else {  
                os = FileUtils.openOutputStream(new File(myFile.getServerFile()), false);  
            }  
            os.write(myFile.getBytes());  
        } catch(IOException e) {  
            throw new FileTransferException(e.getMessage(), e);  
        } finally {  
            IOUtils.closeQuietly(os);  
        }  
    }  
 
    public MyFile downloadFile(MyFile myFile) throws FileTransferException {  
        InputStream is = null;  
          
        try {  
            is = new FileInputStream(myFile.getServerFile());  
            is.skip(myFile.getPosition());  
            byte[] bytes = new byte[1024 * 1024];  
            int size = is.read(bytes);  
            if (size > 0) {  
                byte[] fixedBytes = Arrays.copyOfRange(bytes, 0, size);  
                myFile.setBytes(fixedBytes);  
            } else {  
                myFile.setBytes(new byte[0]);  
            }  
        } catch(IOException e) {  
            throw new FileTransferException(e.getMessage(), e);  
        } finally {  
            IOUtils.closeQuietly(is);  
        }  
        return myFile;  
    }  
}

4. 一個簡單的文件傳輸異常類

package com.googlecode.garbagecan.cxfstudy.filetransfer;  
 
public class FileTransferException extends Exception {  
 
    private static final long serialVersionUID = 1L;  
 
    public FileTransferException() {  
        super();  
    }  
 
    public FileTransferException(String message, Throwable cause) {  
        super(message, cause);  
    }  
 
    public FileTransferException(String message) {  
        super(message);  
    }  
 
    public FileTransferException(Throwable cause) {  
        super(cause);  
    }  
}

5. 下面是Server類用來發(fā)布web service

package com.googlecode.garbagecan.cxfstudy.filetransfer;  
 
import javax.xml.ws.Endpoint;  
 
public class FileTransferServer {  
      
    public static void main(String[] args) throws Exception {  
        Endpoint.publish("http://localhost:9000/ws/jaxws/fileTransferService", new FileTransferServiceImpl());  
    }  
}

6. 最后是Client類，用來發(fā)送文件上傳和下載請求。

package com.googlecode.garbagecan.cxfstudy.filetransfer;  
 
import java.io.File;  
import java.io.FileInputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
import java.util.Arrays;  
 
import org.apache.commons.io.FileUtils;  
import org.apache.commons.io.IOUtils;  
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;  
 
public class FileTransferClient {  
      
    private static final String address = "http://localhost:9000/ws/jaxws/fileTransferService";  
      
    private static final String clientFile = "/home/fkong/temp/client/test.zip";  
    private static final String serverFile = "/home/fkong/temp/server/test.zip";  
      
    public static void main(String[] args) throws Exception {  
        long start = System.currentTimeMillis();  
//      uploadFile();  
//      downloadFile();  
        long stop = System.currentTimeMillis();  
        System.out.println("Time: " + (stop - start));  
    }  
      
    private static void uploadFile() throws FileTransferException {  
        InputStream is = null;  
        try {  
            MyFile myFile = new MyFile();  
            is = new FileInputStream(clientFile);  
            byte[] bytes = new byte[1024 * 1024];  
            while (true) {  
                int size = is.read(bytes);  
                if (size <= 0) {  
                    break;  
                }  
                  
                byte[] fixedBytes = Arrays.copyOfRange(bytes, 0, size);  
                myFile.setClientFile(clientFile);  
                myFile.setServerFile(serverFile);  
                myFile.setBytes(fixedBytes);  
                  
                uploadFile(myFile);  
                  
                myFile.setPosition(myFile.getPosition() + fixedBytes.length);  
            }  
        } catch(IOException e) {  
            throw new FileTransferException(e.getMessage(), e);  
        } finally {  
            IOUtils.closeQuietly(is);  
        }  
    }  
      
    private static void uploadFile(MyFile myFile) throws FileTransferException {  
        JaxWsProxyFactoryBean factoryBean = new JaxWsProxyFactoryBean();  
        factoryBean.setAddress(address);  
        factoryBean.setServiceClass(FileTransferService.class);  
        Object obj = factoryBean.create();  
 
        FileTransferService service = (FileTransferService) obj;  
        service.uploadFile(myFile);  
    }  
      
    private static void downloadFile() throws FileTransferException {  
        MyFile myFile = new MyFile();  
        myFile.setServerFile(serverFile);  
        long position = 0;  
        while (true) {  
            myFile.setPosition(position);  
            myFile = downloadFile(myFile);  
            if (myFile.getBytes().length <= 0) {  
                break;  
            }  
              
            OutputStream os = null;  
            try {  
                if (position != 0) {  
                    os = FileUtils.openOutputStream(new File(clientFile), true);  
                } else {  
                    os = FileUtils.openOutputStream(new File(clientFile), false);  
                }  
                os.write(myFile.getBytes());  
            } catch(IOException e) {  
                throw new FileTransferException(e.getMessage(), e);  
            } finally {  
                IOUtils.closeQuietly(os);  
            }  
              
            position += myFile.getBytes().length;  
        }  
    }  
      
    private static MyFile downloadFile(MyFile myFile) throws FileTransferException {  
        JaxWsProxyFactoryBean factoryBean = new JaxWsProxyFactoryBean();  
        factoryBean.setAddress(address);  
        factoryBean.setServiceClass(FileTransferService.class);  
        Object obj = factoryBean.create();  
 
        FileTransferService service = (FileTransferService) obj;  
        return service.downloadFile(myFile);  
    }  
}

首先需要準備一個大一點的文件，然后修改代碼中的clientFile和serverFile路徑，然后分別打開uploadFile和downloadFile注釋，運行程序，檢查目標文件查看結果。

這個程序還是比較簡單的，但基本生完成了文件上傳下載功能，如果需要，也可以對這個程序再做點修改使其支持斷點續(xù)傳。

原文鏈接：http://blog.csdn.net/kongxx/article/details/7540930

【系列文章】

Apache CXF實戰(zhàn)之六：創(chuàng)建安全的Web Service
Apache CXF實戰(zhàn)之五:壓縮Web Service數據
Apache CXF實戰(zhàn)之四:構建RESTful Web Service
Apache CXF實戰(zhàn)之三:傳輸Java對象
Apache CXF實戰(zhàn)之二:集成Sping與Web容器
Apache CXF實戰(zhàn)之一:Hello World Web Service

責任編輯：林師授來源： kongxx的博客