文档章节

webservice客户端代码

罗文浩
 罗文浩
发布于 2015/12/24 16:42
字数 851
阅读 110
收藏 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.9K
0
WebService 问题

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

子木007
2011/08/07
1K
11
Webservice

最近系统集成经常调用webservice,都是用一些框架直接生成本地客户端代码,然后调用本地客户端方法,对webservice的的原理和基本实现并不清楚,前几天c#调用java端的webservice,因为涉及到h...

宿命panthers
2016/08/11
316
1
WebService之Axis2快速入门(5): 管理会话(Session)

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

吕兵阳
2016/05/08
23
0

没有更多内容

加载失败,请刷新页面

加载更多

数据库篇一

数据库篇 第1章 数据库介绍 1.1 数据库概述  什么是数据库(DB:DataBase) 数据库就是存储数据的仓库,其本质是一个文件系统,数据按照特定的格式将数据存储起来,用户可以对数据库中的数据...

stars永恒
10分钟前
0
0
Intellij IDEA中设置了jsp页面,但是在访问页面时却提示404

在Intellij IDEA中设置了spring boot的jsp页面,但是在访问时,却出现404,Not Found,经过查找资料后解决,步骤如下: 在Run/Debug Configurations面板中设置该程序的Working Directory选项...

uknow8692
昨天
2
0
day24:文档第五行增内容|每月1号压缩/etc/目录|过滤文本重复次数多的10个单词|人员分组|

1、在文本文档1.txt里第五行下面增加如下内容;两个方法; # This is a test file.# Test insert line into this file. 分析:给文档后增加内容,可以用sed 来搞定;也可以用while do done...

芬野de博客
昨天
2
0
深入理解JVM—JVM内存模型

深入理解JVM—JVM内存模型 我们知道,计算机CPU和内存的交互是最频繁的,内存是我们的高速缓存区,用户磁盘和CPU的交互,而CPU运转速度越来越快,磁盘远远跟不上CPU的读写速度,才设计了内存...

onedotdot
昨天
2
0
MVC、MVCS、MVVM、MVP、VIPER等这么多架构模式哪一个好呢?

在项目开启阶段,其中一个很重要的环节就是选架构。 那么面对目前已知的这么多架构模式我们该怎么选择呢?这确实是个很让人头疼的问题! 下面我就在这里梳理一下目前常见的一些架构模式。 先...

Java干货分享
昨天
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部