文档章节

webservice客户端代码

罗文浩
 罗文浩
发布于 2015/12/24 16:42
字数 851
阅读 100
收藏 3
package com.miitgxt.webservices.client.rpc;

import javax.xml.rpc.ServiceException;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import org.apache.axis2.AxisFault;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

/**
 * webservice调用基类
 *
 *
 *
 * @author wenhao
 *
 */
public abstract class WebServiceFactoryClient {

    /**
     * @Title: WebServer_Init
     * @描述:(方法描述)
     * @作者: 客户端调用的方法
     * @参数: 传入参数定义
     * @返回值: Call 返回类型
     * @throws
     */
    public static Call WebServer_Init(String WebServerAddress, String CallOperationName) {
        Service service = new Service();
        Call call = null;
        try {
            call = (Call) service.createCall();
            call.setTargetEndpointAddress(WebServerAddress);
            call.setOperationName(CallOperationName);
        } catch (ServiceException e) {
            e.printStackTrace();
        }
        return call;
    }

    public abstract RPCServiceClient createRpcServiceClient(String url, String namespace, String method,int timeout) throws Exception;

    public abstract String WebPost(Long clientId, String pwd, String fileContent, String method, String url, String namespace,int timeout) throws Exception;

    public abstract OMFactory createOMFactory();


    public abstract OMElement netPost(String url, String action, String methodStr, String namespace, String tns, String[] pars, String[] vals,int timeout) throws AxisFault;


    public static String createXml(String yhm, String yhlb) {
        return null;
    }
}




package com.miitgxt.webservices.client.rpc;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.security.Security;

import javax.xml.namespace.QName;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
import org.apache.axis2.rpc.client.RPCServiceClient;
import org.apache.axis2.transport.http.HTTPConstants;
import org.apache.commons.lang.StringUtils;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;

import com.miitgxt.webservices.client.WebServiceParameters;

/**
 * webservice 请求
 *
 * @author wenhao 公共类
 *
 */
public class WebServiceClient extends WebServiceFactoryClient {
    /**
     * 代理类编写
     */
    @Override
    public RPCServiceClient createRpcServiceClient(String url, String namespace, String method, int timeout) throws Exception {
        RPCServiceClient serviceClient = null;
        try {
            serviceClient = new RPCServiceClient();
            EndpointReference targetEPR = new EndpointReference(url);
            Options options = new Options();
            options.setTo(targetEPR);
            options.setTimeOutInMilliSeconds(timeout);
            options.setProperty(HTTPConstants.CHUNKED, "false");// 把chunk关掉后,会自动加上Content-Length。
            serviceClient.setOptions(options);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {

        }
        return serviceClient;
    }

    /**
     * 请求发送
     */
    @SuppressWarnings("rawtypes")
    @Override
    public String WebPost(Long clientId, String pwd, String fileContent, String method, String url, String namespace, int timeout) throws Exception {
        RPCServiceClient serviceClient = null;
        try {
            serviceClient = createRpcServiceClient(url, namespace, method, timeout);
            // 在创建QName对象时,QName类的构造方法的第一个参数表示WSDL文件的命名空间名,也就是<wsdl:definitions>元素的targetNamespace属性值
            QName opAddEntry = new QName(namespace, method);
            // 参数,如果有多个,继续往后面增加即可,不用指定参数的名称
            Object[] opAddEntryArgs = new Object[] { clientId, pwd, fileContent };
            Class[] classes = new Class[] { String.class };
            fileContent = (String) serviceClient.invokeBlocking(opAddEntry, opAddEntryArgs, classes)[0];
        } catch (Exception e) {
            e.printStackTrace();
            fileContent = WebServiceParameters.JG_FAIL;
            throw new RuntimeException("调用远程接口 链接失败");
        } finally {
            serviceClient.cleanupTransport();
        }
        return fileContent;
    }

    /**
     * .net与Java的区别 createOMFactory(这里用一句话描述这个方法的作用) (这里描述这个方法适用条件 – 可选)
     *
     * @return OMFactory
     * @author wenhao
     * @exception
     * @since 1.0.0
     */
    public OMFactory createOMFactory() {
        OMFactory fac = OMAbstractFactory.getOMFactory();
        return fac;
    }

    public OMElement getOMMethod(String methodStr, String namespace, String tns, String[] pars, String[] vals) {
        OMFactory fac = createOMFactory();
        // 创建命名空间
        OMNamespace nms = fac.createOMNamespace(namespace, tns);
        // 创建OMElement方法 元素,并指定其在nms指代的名称空间中
        OMElement method = fac.createOMElement(methodStr, nms);
        // 添加方法参数名和参数值
        for (int i = 0; i < pars.length; i++) {
            // 创建方法参数OMElement元素
            OMElement param = fac.createOMElement(pars[i], nms);
            // 设置键值对 参数值
            param.setText(vals[i]);
            // 讲方法元素 添加到method方法元素中
            method.addChild(param);
        }
        return method;
    }

    public OMElement netPost(String url, String action, String methodStr, String namespace, String tns, String[] pars, String[] vals, int timeout) {
        OMElement result = null;
        ServiceClient client = null;
        try {
            client = new ServiceClient();
            client.setOptions(getClientOptions(action, url, timeout));
            result = client.sendReceive(getOMMethod(methodStr, namespace, tns, pars, vals));
        } catch (AxisFault e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            try {
                client.cleanupTransport();
            } catch (AxisFault e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return result;
    }

    public Options getClientOptions(String action, String url, int timeout) {
        // 创建request soap包 请求选项
        Options options = new Options();
        // 设置request soap包的端点引用(接口地址)
        EndpointReference targetEpr = new EndpointReference(url);
        // 设置options的soapAction
        options.setAction(action);
        options.setTo(targetEpr);
        // 如果报错提示Content-Length,请求内容长度
        options.setProperty(HTTPConstants.CHUNKED, "false");// 把chunk关掉后,会自动加上Content-Length。
        options.setTimeOutInMilliSeconds(timeout);
        return options;
    }

    // 安全机制 添加协议
    public void sslSecurity() throws Exception {
        File file = null;
        try {
            System.clearProperty("javax.net.ssl.trustStore");
            Resource resource = new ClassPathResource("com/miitgxt/webservices/xml/client.truststore");
            file = resource.getFile();
            System.setProperty("javax.net.ssl.trustStore", "d:/testclientjdk.truststore");
            System.setProperty("javax.net.ssl.trustStorePassword", "changeit");
            System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol");
            Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider());
        } catch (IOException e) {
            e.printStackTrace();
            throw new Exception("安全认证失败!");
        }
    }

    public void deleteFile(String path) {
        File file = null;
        try {
            if (StringUtils.trimToNull(path) != null) {
                file = new File(path);
                if (file != null) {
                    if (file.isFile()) {
                        file.delete();
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
        }
    }
}

© 著作权归作者所有

共有 人打赏支持
罗文浩
粉丝 21
博文 138
码字总数 223451
作品 0
海淀
架构师
WebService学习总结(三)--使用JDK开发WebService

一、WebService的开发手段   使用Java开发WebService时可以使用以下两种开发手段     1、 使用JDK开发(1.6及以上版本)     2、使用CXF框架开发(工作中) 二、使用JDK开发WebServic...

JAVA_NINA
2016/05/02
135
1
Spring的WebServiceTemplate访问WebService的方法及其本质原理

WebService客户端调用的本质就是将SAOP格式的XML通过通信协议发送到WebService的服务器端,然后接收服务器端返回的XML. 本文简单介绍一下如何通过Spring提供的WebServiceTemplate访问Webserv...

晨曦之光
2012/04/25
2.4K
0
WebService 问题

初次使用 WebService (JAXWS RI + jdk 6的WebService 注释) 有些疑问请各位指教。 1. 有2个class 里面都用到了某个JavaBean, 把这2个class发布为WebService。生成客户端代码后,能否也共用此...

子木007
2011/08/07
1K
11
webService服务端Couldn't parse stream

各位好!我在写一个webService的测试桩(完善代码覆盖),调用端的请求方式和处理暂时不能做修改,现在是webservice服务能发布成功,但是请求过来出现Couldn't parse stream的错误。 1.服务端...

fgod
2017/09/11
141
0
WebService之Axis2快速入门(5): 管理会话(Session)

WebService给人最直观的感觉就是由一个个方法组成,并在客户端通过SOAP协议调用这些方法。这些方法可能有返回值,也可能没有返回值。虽然这样可以完成一些工具,但这些被调用的方法是孤立的,...

吕兵阳
2016/05/08
23
0

没有更多内容

加载失败,请刷新页面

加载更多

你为什么在Redis里读到了本应过期的数据

一个事故的故事 晚上睡的正香突然被电话吵醒,对面是开发焦急的声音:我们的程序在访问redis的时候读到了本应过期的key导致整个业务逻辑出了问题,需要马上解决。 看到这里你可能会想:这是不...

IT--小哥
今天
2
0
祝大家节日快乐,阖家幸福! centos GnuTLS 漏洞

yum update -y gnutls 修复了GnuTLS 漏洞。更新到最新 gnutls.x86_64 0:2.12.23-22.el6 版本

yizhichao
昨天
5
0
Scrapy 1.5.0之选择器

构造选择器 Scrapy选择器是通过文本(Text)或 TextResponse 对象构造的 Selector 类的实例。 它根据输入类型自动选择最佳的解析规则(XML vs HTML): >>> from scrapy.selector import Sele...

Eappo_Geng
昨天
4
0
Windows下Git多账号配置,同一电脑多个ssh-key的管理

Windows下Git多账号配置,同一电脑多个ssh-key的管理   这一篇文章是对上一篇文章《Git-TortoiseGit完整配置流程》的拓展,所以需要对上一篇文章有所了解,当然直接往下看也可以,其中也有...

morpheusWB
昨天
5
0
中秋快乐!!!

HiBlock
昨天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部