OpenAdaptor支持XFire和CXF开发的webservice，所以开发CXF webservice，基于myeclipse开发比较容易。参照网上webrvice传输大文件示例修改
1. 首先是一个封装了服务器端文件路径，客户端文件路径和要传输的字节数组的MyFile类。
package com.cattsoft.baseplatform.webservice.fileltransfer;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.cattsoft.baseplatform.webservice.fileltransfer;import javax.jws.WebMethod;import javax.jws.WebService;@WebServicepublic interface FileTransferService {@WebMethodvoid uploadFile(String address, String clientFile, String serverFile)throws FileTransferException;@WebMethodvoid uploadFile1(MyFile myFile, String address) throws FileTransferException;@WebMethodvoid uploadFile2(MyFile myFile) throws FileTransferException;@WebMethodvoid downloadFile(String address, String clientFile, String serverFile)throws FileTransferException;@WebMethodvoid downloadFile1(MyFile myFile, String address) throws FileTransferException;@WebMethodMyFile downloadFile2(MyFile myFile) throws FileTransferException;}
3. 文件传输的Web Service接口实现类，主要是一些流的操作
package com.cattsoft.baseplatform.webservice.fileltransfer;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 javax.jws.WebService;import org.apache.commons.io.FileUtils;import org.apache.commons.io.IOUtils;import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;@WebService(endpointInterface = "com.cattsoft.baseplatform.webservice.fileltransfer.FileTransferService", serviceName = "FileTransferService")public class FileTransferServiceImpl {// 以byte[]传输文件，每次传输1024*1024，传输完后myFile.setPosition记录总共传输的字节数public void uploadFile(String address, String clientFile, String serverFile)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);// 从输入流读取数据存储在缓冲数组bytes，，返回读取的字节数，直到检测到文件结束。读取最多等同于read(bytes,// 0, bytes.length)if (size <= 0) {// 返回-1表示文件结束break;}byte[] fixedBytes = Arrays.copyOfRange(bytes, 0, size);// 将bytes数组拷贝到fixedBytes数组，从0到sizemyFile.setClientFile(clientFile);myFile.setServerFile(serverFile);myFile.setBytes(fixedBytes);uploadFile1(myFile, address);myFile.setPosition(myFile.getPosition() + fixedBytes.length);// 总共传输的字节数}} catch (IOException e) {throw new FileTransferException(e.getMessage(), e);} finally {IOUtils.closeQuietly(is);}}public void uploadFile1(MyFile myFile, String address) throws FileTransferException {JaxWsProxyFactoryBean factoryBean = new JaxWsProxyFactoryBean();factoryBean.setAddress(address);factoryBean.setServiceClass(FileTransferService.class);Object obj = factoryBean.create();FileTransferService service = (FileTransferService) obj;service.uploadFile2(myFile);}public void uploadFile2(MyFile myFile) throws FileTransferException {OutputStream os = null;try {if (myFile.getPosition() != 0) {// 使用Apache commons-io的FileUtils工具类// 打开流，如果不存在创建文件及其目录结构，第二个参数表示 文件流是否是追加方式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 void downloadFile(String address, String clientFile, String serverFile)throws FileTransferException {MyFile myFile = new MyFile();myFile.setServerFile(serverFile);long position = 0;while (true) {myFile.setPosition(position);myFile = downloadFile1(myFile, address);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;}}public MyFile downloadFile1(MyFile myFile, String address) throws FileTransferException {JaxWsProxyFactoryBean factoryBean = new JaxWsProxyFactoryBean();factoryBean.setAddress(address);factoryBean.setServiceClass(FileTransferService.class);Object obj = factoryBean.create();FileTransferService service = (FileTransferService) obj;return service.downloadFile2(myFile);}public MyFile downloadFile2(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;}}用最多的梦面对未来
