xfire--附件

 

---------spring+xfire进行附件传输

 

----------------------------------Server--------------------------------------------

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.cmhit.service.FileUpLoadService;

import com.cmhit.service.model.UploadFile;

 

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;

}

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("webservice服务产生异常！"));

}

 

}

}

 

 

---------------------------------CLIENT---------------------------------------------

import java.net.MalformedURLException;

import org.codehaus.xfire.client.Client;

import org.codehaus.xfire.client.XFireProxyFactory;

import org.codehaus.xfire.fault.XFireFault;

import org.codehaus.xfire.service.Service;

import org.codehaus.xfire.service.binding.ObjectServiceFactory;

import org.codehaus.xfire.transport.http.HttpTransport;

import com.cmhit.service.FileUpLoadService;

import com.cmhit.service.authentication.impl.ClientAuthHandler;

import com.cmhit.service.client.FileUpLoadServiceClient;

import com.cmhit.service.model.UploadFile;

import com.cmhit.services.exception.WebServiceAccessException;

public class FileUpLoadServiceClientImpl implements FileUpLoadServiceClient {

private String username;

private String password;

public FileUpLoadServiceClientImpl() {

}

public FileUpLoadServiceClientImpl(String username, String password) {

this.username = username;

this.password = password;

}

public void setPassword(String password) {

this.password = password;

}

public void setUsername(String username) {

this.username = username;

}

public boolean upload(String hostAddress, int port, UploadFile file)

throws WebServiceAccessException {

try {

Service serviceModel = new ObjectServiceFactory().create(

FileUpLoadService.class, "jones",

"http://cmhit.jack.com", null);

FileUpLoadService service = (FileUpLoadService) new XFireProxyFactory()

.create(serviceModel, "http://" + hostAddress + ":" + port

+ "/spring_webservice/services/FileUpLoadService");

Client client = Client.getInstance(service);

client.setProperty("mtom-enabled", "true");

client.setProperty(HttpTransport.CHUNKING_ENABLED, "true");

client.addOutHandler(new ClientAuthHandler(this.username,this.password));

boolean result = service.upload(file);

return result;

} catch (MalformedURLException e) {

e.printStackTrace();

throw new WebServiceAccessException("无法连接到web服务!");

} catch (XFireFault e) {

e.printStackTrace();

throw new WebServiceAccessException("服务器端XFireFault异常!");

}

}

}