Java Webservice调用总结

xiaodong*

浏览: 41602 次
性别:
来自: 北京

最近访客更多访客>>

qda3314195

xiaoyoue

suixiang2017

fengyonglei

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

WebService 访问

一、调用ASP.NET发布的WebService服务

以下是SOAP1.2请求事例

    POST /user/yfengine.asmx HTTP/1.1
    Host: oserver.palm-la.com
    Content-Type: application/soap+xml; charset=utf-8
    Content-Length: length
    <?xml version="1.0" encoding="utf-8"?>
    <soap12:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:soap12="http://www.w3.org/2003/05/soap-envelope">
          <soap12:Body>
            <Login xmlns="Loginnames">
                  <userId>string</userId>
                  <password>string</password>
            </Login>
          </soap12:Body>
    </soap12:Envelope>

1、方式一：通过AXIS调用

String serviceEpr = "http://127.0.0.1/rightproject/WebServices/RightService.asmx";

public String callWebServiceByAixs(String userId, String password, String serviceEpr){

        try {
               Service service = new Service();
               Call call = (Call)service.createCall();
               call.setTargetEndpointAddress(new java.net.URL(serviceEpr));
               //服务名
               call.setOperationName(new QName("http://tempuri.org/", "Login"));
               //定义入口参数和参数类型
               call.addParameter(new QName("http://tempuri.org/", "userId"),XMLType.XSD_STRING, ParameterMode.IN);
               call.addParameter(new QName("http://tempuri.org/", "password"),XMLType.XSD_STRING, ParameterMode.IN);
               call.setUseSOAPAction(true);
               //Action地址
               call.setSOAPActionURI("http://tempuri.org/Login");
               //定义返回值类型
               call.setReturnType(XMLType.XSD_INT);

               //调用服务获取返回值
               String result = String.valueOf(call.invoke(new Object[]{userId, password}));
               System.out.println("返回值： " + result);
               return result;
              } catch (ServiceException e) {
               e.printStackTrace();
              } catch (RemoteException e) {
               e.printStackTrace();
              } catch (MalformedURLException e) {
               e.printStackTrace();
              }

        return null;
    }

2、方式二：通过HttpClient调用webservice

soapRequest 为以下Xml,将请求的入口参数输入

<?xml version="1.0" encoding="utf-8"?>
        <soap12:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:soap12="http://www.w3.org/2003/05/soap-envelope">
          <soap12:Body>
            <Login xmlns="Loginnames">
                  <userId>张氏</userId>
                  <password>123456</password>
            </Login>
          </soap12:Body>
    </soap12:Envelope>

String serviceEpr = "http://127.0.0.1/rightproject/WebServices/RightService.asmx";

String contentType = "application/soap+xml; charset=utf-8";

public static String callWebService(String soapRequest, String serviceEpr, String contentType){

        PostMethod postMethod = new PostMethod(serviceEpr);
        //设置POST方法请求超时
        postMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT, 5000);

        try {

            byte[] b = soapRequest.getBytes("utf-8");
            InputStream inputStream = new ByteArrayInputStream(b, 0, b.length);
            RequestEntity re = new InputStreamRequestEntity(inputStream, b.length, contentType);
            postMethod.setRequestEntity(re);

            HttpClient httpClient = new HttpClient();
            HttpConnectionManagerParams managerParams = httpClient.getHttpConnectionManager().getParams();
            // 设置连接超时时间(单位毫秒)
            managerParams.setConnectionTimeout(30000);
            // 设置读数据超时时间(单位毫秒)
            managerParams.setSoTimeout(600000);
            int statusCode = httpClient.executeMethod(postMethod);
            if (statusCode != HttpStatus.SC_OK)
                throw new IllegalStateException("调用webservice错误 : " + postMethod.getStatusLine());

            String soapRequestData =  postMethod.getResponseBodyAsString();
            inputStream.close();
            return soapRequestData;
        } catch (UnsupportedEncodingException e) {
            return "errorMessage : " + e.getMessage();
        } catch (HttpException e) {
            return "errorMessage : " + e.getMessage();
        } catch (IOException e) {
            return "errorMessage : " + e.getMessage();
        }finally{
             postMethod.releaseConnection();
        }
    }

二、调用其他WebService服务

1、方式一：通过AIXS2调用

serviceEpr:服务地址

nameSpace:服务命名空间

methodName:服务名称

Object[] args = new Object[]{"请求的数据"};

DataHandler dataHandler = new DataHandler(new FileDataSource("文件路径"));

传文件的话,"请求的数据"可以用DataHandler对象,但是WebService服务需提供相应的处理即:

InputStream inputStream = DataHandler.getInputStream();

然后将inputStream写入文件即可。还可以将文件读取为二进制流进行传递。

public static String callWebService(String serviceEpr, String nameSpace, Object[] args, String methodName){
        try{

            RPCServiceClient serviceClient = new RPCServiceClient();
            Options options = serviceClient.getOptions();
            EndpointReference targetEPR = new EndpointReference(serviceEpr);
            options.setTo(targetEPR);

            //===========可以解决多次调用webservice后的连接超时异常========
            options.setManageSession(true);
            options.setProperty(HTTPConstants.REUSE_HTTP_CLIENT,true);

            //设置超时
            options.setTimeOutInMilliSeconds(60000L);
            // 设定操作的名称
            QName opQName = new QName(nameSpace, methodName);
            // 设定返回值
            // 操作需要传入的参数已经在参数中给定，这里直接传入方法中调用
            Class[] opReturnType = new Class[] { String[].class };
            //请求并得到返回值
            Object[] response = serviceClient.invokeBlocking(opQName, args, opReturnType);
            String sResult = ((String[]) response[0])[0];
            //==========可以解决多次调用webservice后的连接超时异常=======
            serviceClient.cleanupTransport();
            return sResult;

        }catch(AxisFault af){
            return af.getMessage();
        }
    }

2、方式二：

serviceEpr:服务器地址

nameSpace:服务命名空间
methodName:服务名称

private static void callWebService(String serviceEpr, String nameSpace, String methodName) {
        try {
            EndpointReference endpointReference = new EndpointReference(serviceEpr);
            // 创建一个OMFactory，下面的namespace、方法与参数均需由它创建
            OMFactory factory = OMAbstractFactory.getOMFactory();
            // 创建命名空间
            OMNamespace namespace = factory.createOMNamespace(nameSpace, "urn");
            // 参数对数
            OMElement nameElement = factory.createOMElement("arg0", null);
            nameElement.addChild(factory.createOMText(nameElement, "北京"));
            // 创建一个method对象
            OMElement method = factory.createOMElement(methodName, namespace);
            method.addChild(nameElement);
            Options options = new Options();
            // SOAPACTION
            //options.setAction("sayHi");
            options.setTo(endpointReference);

            options.setSoapVersionURI(org.apache.axiom.soap.SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI);
            ServiceClient sender = new ServiceClient();
            sender.setOptions(options);
            // 请求并得到结果
            OMElement result = sender.sendReceive(method);
            System.out.println(result.toString());
        } catch (AxisFault ex) {
            ex.printStackTrace();
        }
    }

3、方式三：通过CXF调用

serviceEpr:服务器地址
nameSpace:服务命名空间
methodName:服务名称

public static String callWebService(String serviceEpr, String nameSpace, String methodName){

        JaxWsDynamicClientFactory clientFactory = JaxWsDynamicClientFactory.newInstance();
        Client client = clientFactory.createClient(serviceEpr);
        Object[] resp = client.invoke(methodName, new Object[]{"请求的内容"});
        System.out.println(resp[0]);
    }

    //传文件,将文件读取为二进制流进行传递,“请求内容”则为二进制流
    private byte[] getContent(String filePath) throws IOException{

FileInputStream inputStream = new FileInputStream(filePath);
ByteArrayOutputStream outputStream = new ByteArrayOutputStream(1024);
        System.out.println("bytes available: " + inputStream.available());

  byte[] b = new byte[1024];
        int size = 0;

        while((size = inputStream.read(b)) != -1)
            outputStream.write(b, 0, size);

inputStream.close();
        byte[] bytes = outputStream.toByteArray();
  outputStream.close();

  return bytes;
    }

分享到：