XFire 传输文件--文件上传与下载

定义服务接口

public interface IFileLoadService { public String uploadFile(String fileName) throws Exception; public String downloadFile(String fileName) throws Exception; }

服务实现

public class FileLoadService implements IFileLoadService { private static int BUFFER_LENGTH = 1024 * 20; public String downloadFile(String fileName) throws Exception { String ret = null; if (fileName != null) { File file = new File("E://Dev//Test",fileName); if (file.exists()) { FileInputStream fis = null; StringBuffer sb = new StringBuffer(); try { fis = new FileInputStream(file); byte[] buffer = new byte[BUFFER_LENGTH]; int count; while ((count = fis.read(buffer)) != -1) { sb.append(Base64.encode(buffer)); } ret = sb.toString(); } catch (FileNotFoundException e) { e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); throw new Exception("出错啦！",e); } catch (IOException e) { e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); throw new Exception("出错啦！",e); } catch (Exception e) { throw new Exception("出错啦！",e); } finally { fis.close(); } } } return ret; } public String uploadFile(String fileName) throws Exception { return null; } }

xml文件

<import resource="cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>ath:org/codehaus/xfire/spring/xfire.xml" /> <bean id="fileLoadService" class="com.jastar.test.ws.file.FileLoadService"></bean> <bean name="fileLoadingService" class="org.codehaus.xfire.spring.remoting.XFireExporter"> <property name="serviceFactory" ref="xfire.serviceFactory" /> <property name="xfire" ref="xfire" /> <property name="name" value="FileLoadService" /> <property name="serviceBean" ref="fileLoadService"/> <property name="serviceClass" value="com.jastar.test.ws.file.IFileLoadService"/> </bean>

Client测试代码

Service serviceModel = new ObjectServiceFactory().create(IFileLoadService.class); XFireProxyFactory facotry = new XFireProxyFactory(XFireFactory.newInstance().getXFire()); String endpoint = "https://192.168.1.2:8443/ws-test/services/FileLoadService"; try { IFileLoadService service = (IFileLoadService) facotry.create(serviceModel,endpoint); Client client = Client.getInstance(service); client.setProperty("mtom-enabled","true"); client.setProperty(HttpTransport.CHUNKING_ENABLED,"true"); String data = service.downloadFile("kobe.gif"); byte[] bytes = Base64.decode(data); FileOutputStream data_fos = new FileOutputStream("e:/jastar.gif"); data_fos.write(bytes); data_fos.flush(); data_fos.close(); } catch (MalformedURLException e) { e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); } catch (Exception e) { e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); } }

测试时发现传输大文件时会出现java.lang.OutOfMemoryError: Java heap space异常，暂时还没有解决，如果非得传输大文件。考虑别的方案，不要用Webservice，毕竟这不是Webservice干的事。

另外javax.activation.DataHandler也可以用来文件传输，没试过。

uploadFile没有实现，以后有机会再补充。

XFire 传输文件--文件上传与下载

相关推荐