axis,jax-ws,xfire客户端调用

Java代码<?xml version="1.0" encoding="UTF-8"?><!-- Published by JAX-WS RI at . RI's version is JAX-WS RI 2.1.1 in JDK 6. --><!-- Generated by JAX-WS RI at . RI's version is JAX-WS RI 2.1.1 in JDK 6. --><definitions xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/" xmlns:tns="http://www.hua-xia.com.cn/ZySearch" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns="http://schemas.xmlsoap.org/wsdl/" targetNamespace="http://www.hua-xia.com.cn/ZySearch" >
<types></types>
<message >
<part type="xsd:string"></part>
</message>
<message >
<part type="xsd:string"></part>
</message>
<portType >
<operation parameterOrder="linkNo">
<input message="tns:getUserLink"></input>
<output message="tns:getUserLinkResponse"></output>
</operation>
</portType>
<binding type="tns:UserLinkWebService">
<soap:binding transport="http://schemas.xmlsoap.org/soap/http" style="rpc"></soap:binding>
<operation >
<soap:operation soapAction="getUserLink"></soap:operation>
<input>
<soap:body use="literal" namespace=">
</input>
<output>
<soap:body use="literal" namespace=">
</output>
</operation>
</binding>
<service >
<port binding="tns:UserLinkWebServicePortBinding">
<soap:address location=">
</port>
</service>
</definitions>

?

1.xfire调用
对方给我们的client是使用xfire的client调用,代码如下:

Java代码

package com.zhongying.bussserv.common;

import java.net.URL;
import java.util.Map;
import org.codehaus.xfire.client.Client;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.io.xml.DomDriver;

public class Test {

?public static void main(String[] args) {

??????? String url = "http://192.168.1.1:8000/RES_Searcher/service/IUserLinkWebService?wsdl";
???????
??????? Client client;
??try {
???client = new Client(new URL(url));
???Object params[] = {"123456"};
???????? String result = (String)client.invoke("getUserLink",params)[0];
???????? XStream xStream = new XStream(new DomDriver());
???????? Map map = (Map)xStream.fromXML(result);
??} catch (Exception e) {

???e.printStackTrace();
??}
?}

}

?

2.axis调用


但是由于jar包的原因,我们不能使用上面的方法,想出的第一个解决方案是使用axis的客户端来调用接口,代码如下:

Java代码

import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import javax.xml.namespace.QName;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.io.xml.DomDriver;

public class TestReflection {

?public static void main(String[] arg) {

??String url = "http://192.168.1.1:9010/ZySearch";

??try {

???Service service = new Service();
???Call call = (Call) service.createCall();
???// 设置调用服务地址
???call.setTargetEndpointAddress(new java.net.URL(url));

???//此处一定要配置wsdl的namespace参数http://www.hua-xia.com.cn/ZySearch
???call.setOperationName(new QName("http://www.hua-xia.com.cn/ZySearch","getUserLink"));

???//此处需要配置传入参数类型与参数名称,如果未设置jax-ws则无法接受参数,会认为传入的参数为null
???call.addParameter("linkNo",org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);
???//如果设置类传入参数类型,此处也需要设置返回参数类型
???call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);
???call.setUseSOAPAction(true);
???call.setSOAPActionURI(url);

???String result = (String) call.invoke(new Object[] { "AD0006526305" });

???XStream xStream = new XStream(new DomDriver());
???Map map = (Map) xStream.fromXML(result);

???Iterator it = map.entrySet().iterator();

???while (it.hasNext()) {

????Map.Entry enty = (Entry) it.next();

????System.out.println(enty.getKey() + ":" + enty.getValue());

???}
??} catch (Exception e) {

???e.printStackTrace();
??}

?

3.http模拟调用


由于开始对axis的了解有限,在写axis调用是总是有问题,于是便想了另外一个方法,这个方法有点剑走偏锋.但是适用性却很强,因为调用的是java自带的api不会产生兼容性问题.
大家知道webservice请求实际上也就是一个http请求,将数据通过xml文件进行交换.
既然知道了原理我们就可以模拟一个http请求来调用webservice.

Java代码

try{
???? ???
???? ??? String url2 = "http://192.168.1.1:9010/ZySearch?wsdl";

??????????? URL getUrl = new URL(url2);

??????????? HttpURLConnection connection = (HttpURLConnection) getUrl.openConnection();
??????????? connection.setDoOutput(true);
??????????? connection.setDoInput(true);
??????????? connection.setRequestMethod("POST");
??????????? connection.setRequestProperty("Content-type","text/xml");
???????????
?????????????
??????????? connection.setRequestProperty("Accept","text/xml");
??????????? connection.setRequestProperty("User-Agent","JAX-WS RI 2.1.3-hudson-390-");

??????????? String send="<soap:Envelope xmlns:soap="" xmlns:xsd="" xmlns:xsi=" xmlns:ns1=" xmlns="">"+par+"</linkNo></ns1:getUserLink></soap:Body></soap:Envelope>";
??????????? connection.getOutputStream().write(send.getBytes());
??????????? connection.getOutputStream().flush();
??????????? connection.getOutputStream().close();
??????????? connection.connect();
??????????? // 取得输入流，并使用Reader读取
??????????? BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(),"utf-8"));//设置编码,否则中文乱码
??????????? System.out.println("=============================");
??????????? System.out.println("Contents of get request");
??????????? System.out.println("=============================");
??????????? String lines="";
??????????? String reuslts = "";
??????????? while ((lines = reader.readLine()) != null){
??????????????????? //lines = new String(lines.getBhqytes(),"utf-8");
???????? ??? reuslts+=lines.replaceAll("<","<").replaceAll(">",">");
??????????????
??????????? }
??????????? reader.close();
???????????
???????????
???????????
??????????? System.out.println("type:"+connection.getContentType());
??????????? // 断开连接
??????????? connection.disconnect();
???????????
??????????? System.out.println(reuslts);
??????????? System.out.println("=============================");
??????????? System.out.println("Contents of get request ends");
??????????? System.out.println("=============================");
???????????
??????????? XStream xStream = new XStream(new DomDriver());
???????????
??????????? reuslts = reuslts.substring(reuslts.indexOf("<returnVal>")+11);
???????????
??????????? reuslts = reuslts.substring(0,reuslts.indexOf("</returnVal>"));
???????????
??????????? System.out.println(reuslts);
???????????
??????????? Map result =? (Map)xStream.fromXML(reuslts);
???????????
??????????? Iterator it = result.entrySet().iterator();
??? ??
??? ???? while(it.hasNext()){
??? ???
??? ???Map.Entry enty = (Entry) it.next();
??? ???
??? ???System.out.println(enty.getKey()+":"+enty.getValue());
??? ???
??? ??? }
???? ???
??????? }catch(Exception e){
???? ???
???? ??? e.printStackTrace();
??????? }

?

?

4.jax-ws调用

最后再写上一个jax-ws的client代码

Java代码

import javax.xml.namespace.QName;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPBody;
import javax.xml.soap.SOAPBodyElement;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPMessage;
import javax.xml.ws.BindingProvider;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Service;
import javax.xml.ws.WebServiceException;
import javax.xml.ws.soap.SOAPBinding;

public class Client {
?// 名字空间
??? public static final String targetNamespace = "http://www.hua-xia.com.cn/ZySearch";
??? //服务名
??? public static final String serName = "UserLinkWebServiceService";
??? //端口名
??? public static final String pName = "UserLinkWebServicePort";
??? //服务地址
??? public static final String endpointAddress = "http://192.168.1.1:9010/ZySearch?wsdl";
??? //方法名
??? public static final String OPER_NAME = "getUserLink";
??? //参数名
??? public static final String INPUT_NMAE = "linkNo";
?/**
? * @param args
? * @throws MalformedURLException
? * @throws Exception
? */
?public static void main(String[] args) throws MalformedURLException,Exception {
??// TODO Auto-generated method stub

??QName serviceName = new QName(targetNamespace,serName);
???????
??????? QName portName = new QName(targetNamespace,pName);
??????
??????? javax.xml.ws.Service service = Service.create(serviceName);
??????? service.addPort(portName,SOAPBinding.SOAP11HTTP_BINDING,endpointAddress);
??????
??????? Dispatch<SOAPMessage> dispatch = service.createDispatch(portName,
??????? SOAPMessage.class,Service.Mode.MESSAGE);
?????
??????? BindingProvider bp = (BindingProvider) dispatch;
??????? Map<String,Object> rc = bp.getRequestContext();
??????? rc.put(BindingProvider.SOAPACTION_USE_PROPERTY,Boolean.TRUE);
??????? rc.put(BindingProvider.SOAPACTION_URI_PROPERTY,OPER_NAME);
??????? MessageFactory factory = ((SOAPBinding)bp.getBinding()).getMessageFactory();
??????
??????? SOAPMessage request = factory.createMessage();
??????? SOAPBody body = request.getSOAPBody();
??????? QName payloadName = new QName(targetNamespace,OPER_NAME,"ns1");
??????? SOAPBodyElement payload = body.addBodyElement(payloadName);
??????
??????? SOAPElement message = payload.addChildElement(INPUT_NMAE);
??????? message.addTextNode("AD0006526305");
??????? SOAPMessage reply = null;
???????
??????? try
??????? {
?????????? reply = dispatch.invoke(request);
??????? }
??????? catch (WebServiceException wse)
??????? {
?????????? wse.printStackTrace();
??????? }
??????? SOAPBody soapBody = reply.getSOAPBody();
??????? SOAPBodyElement nextSoapBodyElement = (SOAPBodyElement)soapBody.getChildElements().next ();?????????????
??????? SOAPElement soapElement = (SOAPElement)nextSoapBodyElement.getChildElements().next();
?
??????? System.out.println("获取回应信息为：" + soapElement.getValue());?

?}

}