文档章节

webservice客户端代码

罗文浩
 罗文浩
发布于 2015/12/24 16:42
字数 851
阅读 99
收藏 3
点赞 0
评论 0
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
博文 85
码字总数 215918
作品 0
海淀
架构师
WebService学习总结(三)--使用JDK开发WebService

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

JAVA_NINA ⋅ 2016/05/02 ⋅ 1

Spring的WebServiceTemplate访问WebService的方法及其本质原理

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

晨曦之光 ⋅ 2012/04/25 ⋅ 0

使用JDK自带的WebService

WebService是个好东西,话不多说,干净利落 服务器端 来看下服务器端的结构: 先定义一个接口,用于暴露: package com.abc.webservice;/** * 对外暴露的接口。 */public interface IWebSer...

摆渡者 ⋅ 2015/08/24 ⋅ 0

WebService 问题

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

子木007 ⋅ 2011/08/07 ⋅ 11

webService服务端Couldn't parse stream

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

fgod ⋅ 2017/09/11 ⋅ 0

WebService之Axis2快速入门(5): 管理会话(Session)

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

吕兵阳 ⋅ 2016/05/08 ⋅ 0

Webservice

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

宿命panthers ⋅ 2016/08/11 ⋅ 1

webservice笔记

概念: 1、WebService,顾名思义就是基于Web的服务。它使用Web(HTTP)方式,接收和响应外部系统的某种请求。从而实现远程调用. 2、我们可以调用互联网上查询天气信息Web服务,然后将它嵌入到我...

包包大人 ⋅ 2014/04/04 ⋅ 0

WebService之Axis2快速入门(8): WebService的异步调用

在前面几篇文章中都是使用同步方式来调用WebService。也就是说,如果被调用的WebService方法长时间不返回,客户端将一直被阻塞,直到该方法返回为止。使用同步方法来调用WebService虽然很直观...

吕兵阳 ⋅ 2016/05/08 ⋅ 0

CXF学习笔记(2)-HelloWorld!-客户端调用

上一节中已经成功的发布了一个服务端webservice,这一部分将默认客户端调用webservice 这里我们重新建立了一个新的工程CXF-Client,把上一节中列举的jar包都搞过来即可,调用方式采用了和RMI类...

鉴客 ⋅ 2011/08/18 ⋅ 2

没有更多内容

加载失败,请刷新页面

加载更多

下一页

JAVA RMI

什么是JAVA RMI Java RMI (Remote Method Invocation) 远程方法调用,能够让客户端像使用本地调用一样调用服务端 Java 虚拟机中的对象方法。RMI 是面向对象语言领域对 RPC (Remote Proced...

saulc ⋅ 27分钟前 ⋅ 0

Linux系统工程狮养成记

如今的社会,随着时代的发展,出现了很多职业,像电子类,计算机类的专业,出现了各种各样的工程师,有算法工程师,java工程师,前端工程师,后台工程师,Linux工程师,运维工程师等等,不同...

linux-tao ⋅ 37分钟前 ⋅ 0

进入编辑模式 vim命令模式 vim实践

1.

oschina130111 ⋅ 37分钟前 ⋅ 0

mysql用户管理、常用sql语句、mysql数据库备份恢复

1. mysql用户管理 mysql默认有一个root超级管理员账户,实际工作环境中不可能每个人都用此root权限,防止误操作、误删除,可以给单独的用户进行授权。 Mysql创建用户以及授权: grant all on...

laoba ⋅ 38分钟前 ⋅ 0

类型后面三个点(String...)和数组(String[])的区别

类型后面三个点(String…),是从Java 5开始,Java语言对方法参数支持一种新写法,叫可变长度参数列表,其语法就是类型后跟…,表示此处接受的参数为0到多个Object类型的对象,或者是一个Obj...

流氓兔- ⋅ 43分钟前 ⋅ 0

JEPLUS表格组件之表格合并——JEPLUS软件快速开发平台

JEPLUS表格组件之表格合并 我们在列表配置时会遇见这样的一种情况,需要对个人的数据进行统一化,对一些数据进行归类,这样展示出来美观又直观,在这篇笔记中我来给大家介绍下如何配置出来专...

JEPLUS ⋅ 45分钟前 ⋅ 0

golang 并发中全局唯一操作

package main// go 携程共享 数据// 加锁解锁操作// 同步锁import ("sync""fmt")// 创建Once结构var once = sync.Once{}func computed(data *int, lock *sync.Mut...

304158 ⋅ 45分钟前 ⋅ 0

Mobx入门之二:asynchronous actions

这一节主要看mobx怎么实现asynchronous actions 1 要实现的demo功能 输入地名,查询天气,利用openweathermap api 2 思想 observable观察数据:location地点、temperature温度 observer响应式...

pengqinmm ⋅ 48分钟前 ⋅ 0

【2018.0620学习笔记】【linux高级知识 13.4-13.6】

13.4 mysql用户管理 创建用户并授权: grant all on *.* to '用户名'@'ip' identified by '密码' //all是操作权限,*.*是库.表,指定格式是'用户名'@'localhost'才能用socket登录本地 gra...

lgsxp ⋅ 今天 ⋅ 0

Java强弱引用示例

package jdk;import java.lang.ref.PhantomReference;import java.lang.ref.ReferenceQueue;import java.lang.ref.SoftReference;import java.lang.ref.WeakReference;public ......

月下狼 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部