java—（6）OpenAdaptor：基于webservice传输大文件

OpenAdaptor支持XFire和CXF开发的webservice，所以开发CXF webservice，基于myeclipse开发比较容易。参照网上webrvice传输大文件示例修改 http://blog.csdn.net/kongxx/article/details/7540930

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;

@WebService
public interface FileTransferService {
	@WebMethod
	void uploadFile(String address, String clientFile, String serverFile)
			throws FileTransferException;

	@WebMethod
	void uploadFile1(MyFile myFile, String address) throws FileTransferException;

	@WebMethod
	void uploadFile2(MyFile myFile) throws FileTransferException;

	@WebMethod
	void downloadFile(String address, String clientFile, String serverFile)
			throws FileTransferException;

	@WebMethod
	void downloadFile1(MyFile myFile, String address) throws FileTransferException;

	@WebMethod
	MyFile 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到size
				myFile.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;
	}
}

4. 一个简单的文件传输异常类

package com.cattsoft.baseplatform.webservice.fileltransfer;

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.cattsoft.baseplatform.webservice.fileltransfer;

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());
		// Endpoint.publish(args[0], new FileTransferServiceImpl());
	}
}

6. 最后是Client类，用来发送文件上传和下载请求。

package com.cattsoft.baseplatform.webservice.fileltransfer;

/*
 * uploadFile是从clientFile传到serverFile
 * downloadFile是从serverFile传到clientFile
 * 参数args[0], args[1],args[2]依次为address, clientFile, serverFile
 */
public class FileTransferClient {

	private static final String address = "http://192.168.100.169:9000/ws/jaxws/fileTransferService1";
	private static final String clientFile = "F:/ftp/test.txt";
	private static final String serverFile = "D:/share/portal_ESB/ftp/test.txt";

	public static void main(String[] args) throws Exception {
		long start = System.currentTimeMillis();
		FileTransferServiceImpl fts = new FileTransferServiceImpl();
		fts.uploadFile(args[0], args[1], args[2]);
		// downloadFile(args[0], args[1], args[2]);
		long stop = System.currentTimeMillis();
		System.out.println("Time: " + (stop - start));
	}

}

7、配置openAdaptor文件

<?xml version="1.0" encoding="UTF-8"?>
<!-- 
  $Id: step01.xml 696 2007-06-27 13:04:36Z higginse $
  $HeadURL: https://openadaptor3.openadaptor.org/svn/openadaptor3/tags/3.4.7/example/tutorial/step01.xml $
 -->
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">
 
  <description><![CDATA[
  Adaptor for step 1 of the tutorial.
  ]]></description>

  <bean id="Adaptor" class="org.openadaptor.core.adaptor.Adaptor">
    <property name="messageProcessor" ref="Router"/>
  </bean>
  
  <bean id="Router" class="org.openadaptor.core.router.Router">
    <property name="processors">
      <list>
        <ref bean="Reader"/>
		<ref bean="BuyWriter"/>
      </list>
    </property>
  </bean>
   
   <bean id="Reader" class="org.openadaptor.auxil.connector.soap.WebServiceCXFReadConnector">
    <property name="wsEndpoint" value="http://localhost:9000/ws/jaxws/fileTransferService1?wsdl"/>
	  <property name="serviceName">
      <bean class="javax.xml.namespace.QName">
        <constructor-arg type="java.lang.String" index="0" value="http://filetransfer.cxfstudy.garbagecan.googlecode.com/"></constructor-arg>
	    <constructor-arg type="java.lang.String" index="1" value="uploadFile"></constructor-arg>
      </bean>
    </property>
	<property name="parameters">
		<list>
			<value type="java.lang.String">http://localhost:9000/ws/jaxws/fileTransferService1</value>
			<value type="java.lang.String">F:/ftp/test.txt</value>
			<value type="java.lang.String">F:/ftp1/test1.txt</value>
		</list>
   </property>
  </bean>

 
  
  <bean id="Writer" class="org.openadaptor.auxil.connector.soap.WebServiceCXFWriteConnector">
    <property name="endpoint" value="http://192.168.223.142:9763/AddService_1.0.0/services/add_service?wsdl"/>
	<property name="methodName" value="add"/>
</bean>

  <bean id="BuyWriter" class="org.openadaptor.auxil.connector.iostream.writer.FileWriteConnector">
   <property name="filename" value="output/1.txt" />
  </bean>
</beans>