package cn.mr.rw.service.orderSynchronize.emos.failureOrder; import java.net.MalformedURLException; import java.rmi.remoteexception; import java.util.Date; import javax.xml.namespace.QName; import javax.xml.rpc.ServiceException; import org.apache.axis.AxisFault; import org.apache.axis.client.Call; import org.apache.axis.client.Service; import org.apache.axis2.addressing.EndpointReference; import org.apache.axis2.client.Options; import org.apache.axis2.rpc.client.RPCServiceClient; import org.apache.commons.lang3.StringUtils; import org.apache.commons.logging.LogFactory; import cn.mr.common.exception.InvokeWebServiceException; import cn.mr.rw.system.core.utils.LogUtils; /** * WebService调用接口，无需事务控制。 * 2013-11-7 下午6:38:12 */ public class InvokeWebService { private static final org.apache.commons.logging.Log log = LogFactory.getLog(InvokeWebService.class); /** * 使用拼装好的接口报文，调用指定WSDL路径的指定方法。该客户端使用AXIS1实现。 * @param xmlRequest 接口报文字符串。 * @param url 服务器端WSDL路径 * @param methodName 服务器端方法名 * @return 响应报文字符串。 * @throws InvokeWebServiceException */ public String callAxis(String xmlRequest,String url,String methodName) throws InvokeWebServiceException{ String resObj = ""; try { if(StringUtils.isBlank(url)){ throw new InvokeWebServiceException("请提供访问WebService接口方法的URL"); } if(StringUtils.isBlank(methodName)){ throw new InvokeWebServiceException("请提供要调用的WebService接口方法!"); } Service service = new Service(); Call call = (Call) service.createCall(); call.setTargetEndpointAddress(new java.net.URL(url)); call.setoperationName(methodName); call.addParameter("xml",org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN); call.setUseSOAPAction(true); call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING); Object[] obj = new Object[] {xmlRequest}; resObj = (String) call.invoke(obj); } catch (ServiceException e) { e.printstacktrace(); throw new InvokeWebServiceException("创建服务出错！"); } catch (AxisFault e) { e.printstacktrace(); throw new InvokeWebServiceException("网络异常连接超时！"); } catch (remoteexception e) { e.printstacktrace(); throw new InvokeWebServiceException("调用远程方法出错！"); } catch(MalformedURLException e){ e.printstacktrace(); throw new InvokeWebServiceException("不能解析的URL！"); } catch (Exception e) { throw new InvokeWebServiceException("调用Webservice接口方法出现未知异常!"); } return resObj; } /** * 用多个参数调用webservice。 * 使用拼装好的接口报文，调用指定WSDL路径的指定方法。该客户端使用AXIS1实现。 * @param xmlRequest * @param url * @param methodName * @return * @throws InvokeWebServiceException */ public String callAxisWithMultiParam(Object[] xmlRequest,String namespace,String methodName) throws InvokeWebServiceException{ String resObj = ""; try { if(StringUtils.isBlank(url)){ throw new InvokeWebServiceException("请提供访问WebService接口方法的URL"); } if(StringUtils.isBlank(methodName)){ throw new InvokeWebServiceException("请提供要调用的WebService接口方法!"); } Service service = new Service(); Call call = (Call) service.createCall(); call.setTargetEndpointAddress(new java.net.URL(url)); call.setoperationName(new QName(namespace,methodName)); for(int i = 0; i < xmlRequest.length; i++){ call.addParameter("xml",javax.xml.rpc.ParameterMode.IN); } call.setUseSOAPAction(true); call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING); resObj = (String) call.invoke(xmlRequest); } catch (ServiceException e) { e.printstacktrace(); throw new InvokeWebServiceException("创建服务出错！"); } catch (AxisFault e) { e.printstacktrace(); throw new InvokeWebServiceException("网络异常连接超时！"); } catch (remoteexception e) { e.printstacktrace(); throw new InvokeWebServiceException("调用远程方法出错！"); } catch(MalformedURLException e){ e.printstacktrace(); throw new InvokeWebServiceException("不能解析的URL！"); } catch (Exception e) { throw new InvokeWebServiceException("调用Webservice接口方法出现未知异常!"); } return resObj; } /** * 如果服务器端是用Axis2实现的，客户端用Axis可能需要很长时间 * @param wsdlUrl * @param nameSpace * @param method * @param param * @return * @throws AxisFault * @throws org.apache.axis2.AxisFault * @throws InvokeWebServiceException */ public String invokeAxis2MultiParam(String wsdlUrl,String nameSpace,String method,Object[] xmlRequest) throws InvokeWebServiceException { String response = ""; try { RPCServiceClient client; client = new RPCServiceClient(); Options options = client.getoptions(); options.setTo(new EndpointReference(wsdlUrl)); Object[] result; Date d1 = new Date(); log.error("开始调用" + method + ",请求参数为" + xmlRequest); result = client.invokeBlocking(new QName(nameSpace,method),xmlRequest,new Class[]{String.class }); response = (String) result[0]; log.error("结束调用" + method +",耗时" + (new Date().getTime() - d1.getTime())/1000 + "秒,返回结果为" + response); } catch (org.apache.axis2.AxisFault e) { LogUtils.failureOrderClientLog.error(e.getMessage(),e); throw new InvokeWebServiceException("网络异常连接超时！"); } return response; } /** * 如果服务器端是用Axis2实现的，客户端用Axis可能需要很长时间 * @param wsdlUrl * @param nameSpace * @param method * @param param * @return * @throws AxisFault * @throws org.apache.axis2.AxisFault */ public String invokeAxis2(String wsdlUrl,String param,Long timeOut) throws InvokeWebServiceException { try { RPCServiceClient client; client = new RPCServiceClient(); Options options = client.getoptions(); options.setTo(new EndpointReference(wsdlUrl)); if(timeOut != null && timeOut.longValue() > 0) { options.setTimeOutInMilliSeconds(timeOut); } Object[] result; // Date d1 = new Date(); // log.error("开始调用" + method + ",请求参数为" + param); result = client.invokeBlocking(new QName(nameSpace,new Object[] {param},new Class[]{String.class }); String response = (String) result[0]; // log.error("结束调用" + method +",返回结果为" + response); return response; } catch (Exception e) { throw new InvokeWebServiceException("调用Axis2的服务器端失败",e); } } /** * 该构造方法针对java 客户端调用.net服务端时，必须传递namespace和soapURI参数 * 使用拼装好的接口报文，调用指定WSDL路径的指定方法。该客户端使用AXIS1实现。 * @param xmlRequest 接口报文字符串。 * @param url 服务器端WSDL路径 * @param methodName 服务器端方法名 * @return 响应报文字符串。 * @throws InvokeWebServiceException */ public String callAxis(String namespace,String xmlRequest,String methodName,String soapURI) throws InvokeWebServiceException{ String resObj = ""; try { if(StringUtils.isBlank(url)){ throw new InvokeWebServiceException("请提供访问WebService接口方法的URL"); } if(StringUtils.isBlank(methodName)){ throw new InvokeWebServiceException("请提供要调用的WebService接口方法!"); } if (StringUtils.isBlank(namespace)) { throw new InvokeWebServiceException("请提供访问WebService接口命名空间的namespace!"); } if (StringUtils.isBlank(soapURI)) { throw new InvokeWebServiceException("请提供访问WebService接口参数soapURI!"); } Service service = new Service(); Call call = (Call) service.createCall(); call.setTargetEndpointAddress(new java.net.URL(url)); call.setoperationName(new QName(namespace,methodName)); call.addParameter(new QName(namespace,"xml"),javax.xml.rpc.ParameterMode.IN); call.setUseSOAPAction(true); call.setSOAPActionURI(soapURI); call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING); Object[] obj = new Object[] {xmlRequest}; resObj = (String) call.invoke(obj); } catch (ServiceException e) { e.printstacktrace(); throw new InvokeWebServiceException("创建服务出错！"); } catch (AxisFault e) { e.printstacktrace(); throw new InvokeWebServiceException("网络异常连接超时！"); } catch (remoteexception e) { e.printstacktrace(); throw new InvokeWebServiceException("调用远程方法出错！"); } catch(MalformedURLException e){ e.printstacktrace(); throw new InvokeWebServiceException("不能解析的URL！"); } catch (Exception e) { throw new InvokeWebServiceException("调用Webservice接口方法出现未知异常!"); } return resObj; } }
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
