server对外只开放80端口，并且还需要提供文件上传和下载功能的应用，下面yjbys小编为大家准备了关于如何使用Web Service传输文件的文章，欢迎阅读。

　　1. 首先是一个封装了服务器端文件路径，客户端文件路径和要传输的字节数组的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类用来发布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类，用来发送文件上传和下载请求。

　　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注释，运行程序，检查目标文件查看结果。

　　这个程序还是比较简单的，但基本生完成了文件上传下载功能，如果需要，也可以对这个程序再做点修改使其支持断点续传。