fileuploadserviceimpl.java

Java使用webservice上传文件的例子

package com.jones.web.service.impl;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import org.apache.log4j.Logger;
import org.codehaus.xfire.fault.XFireFault;

import com.jones.web.service.FileUpLoadService;
import com.jones.web.service.model.UploadFile;

/**
 * web 服务提供者
 * 
 * @author gubiao
 *
 */
public class FileUpLoadServiceImpl implements FileUpLoadService {
	
	private static final Logger logger = Logger.getLogger(FileUpLoadServiceImpl.class);
	
	private String fileSavePath;
	
	public void setFileSavePath(String fileSavePath) {
		this.fileSavePath = fileSavePath;
	}
	
	/**
	 * 上传指定文件
	 * 
	 * @author gubiao
	 * 
	 * @param UploadFile file 待上传的文件
	 * 
	 * @return boolean web service 回执
	 */
	public boolean upload(UploadFile file)throws XFireFault{
		
		logger.info("开始接收上传的文件...............");
		
		if(file == null && file.getFile() == null){
			
			throw new XFireFault(new Exception("上传文件不能为NULL"));
			
		}
		
		String title = file.getTitle();

		try {
			
			InputStream in = file.getFile().getInputStream();
			
			if(this.fileSavePath != null && (!this.fileSavePath.equals(""))){
				
				File fileDirectory = new File(this.fileSavePath);
				
				if(!fileDirectory.exists()){
					
					fileDirectory.mkdir();
					
				}
				
			}
			OutputStream out = new FileOutputStream(new File(this.fileSavePath + title));
			
			if(in != null){
				
				int s = -1;
				
				while((s = in.read())!= -1){
					
					out.write(s);
					
				}
				
				in.close();
				
			}
			
			out.close();
			
			logger.info("文件："+title+"上传成功！");
			
			return true;
			
		} catch (IOException e) {
		
			e.printStackTrace();
			
			throw new XFireFault(new Exception("web服务异常！"));
			
		}

	}
	
}