XFire客户端编程实现方式和及AJAX调用方法

2024-02-05 14:48

本文主要是介绍XFire客户端编程实现方式和及AJAX调用方法,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

 

1. 客户端拥有Web服务端的class字节码文件

条件:能拿到服务端提供的接口Class,包括启用代理模式的应用

private static void initWebServiceClient() {//Service srModel = new ObjectServiceFactory().create(TestDAOService.class);Service serviceModel = new ObjectServiceFactory().create(IHelloService.class);XFireProxyFactory factory = new XFireProxyFactory(XFireFactory.newInstance().getXFire());ResourceBundle rb = ResourceBundle.getBundle("com/sonyon/properties/config");//String endPoint = "http://80.80.100.186:80/xfire/services/IHelloService";String endPoint = rb.getString("service");boolean enableProxy = Boolean.valueOf(rb.getString("enableproxy")).booleanValue();String proxyAddress = rb.getString("proxyhost");String proxyPort = rb.getString("proxyport");try {//启用代理if(enableProxy){service = (IHelloService) factory.create(serviceModel,endPoint);//Client client = new Client(serviceModel,endPoint);Client client = Client.getInstance(service);//禁用默认代理Util类client.setProperty(CommonsHttpMessageSender.DISABLE_PROXY_UTILS,"true");client.setProperty(CommonsHttpMessageSender.DISABLE_KEEP_ALIVE,"true");//禁用100-continue协议client.setProperty(CommonsHttpMessageSender.DISABLE_EXPECT_CONTINUE,"true");client.setProperty(CommonsHttpMessageSender.HTTP_PROXY_HOST,proxyAddress);client.setProperty(CommonsHttpMessageSender.HTTP_PROXY_PORT,proxyPort);//client.setProperty(HttpTransport.CHUNKING_ENABLED,"true");} else {//service = (IHelloService) factory.create(serviceModel,endPoint);service = (IHelloService) factory.create(serviceModel,endPoint);//Client client = new Client(serviceModel,endPoint);Client client =  Client.getInstance(service);//禁用默认代理Util类client.setProperty(CommonsHttpMessageSender.DISABLE_PROXY_UTILS,"true");client.setProperty(CommonsHttpMessageSender.DISABLE_KEEP_ALIVE,"true");//禁用100-continue协议client.setProperty(CommonsHttpMessageSender.DISABLE_EXPECT_CONTINUE,"true");//client.setProperty(HttpTransport.CHUNKING_ENABLED,"true");}/*URL testurl = new URL(testwsdl);HttpURLConnection httpConnection = (HttpURLConnection)testurl.openConnection();  httpConnection.setReadTimeout(20000);//设置http连接的读超时,单位是毫秒  httpConnection.connect();Client testClient = new Client(httpConnection.getInputStream(), null);//Client testClient = new Client(new URL(testwsdl));if(enableProxy){testClient.setProperty(CommonsHttpMessageSender.DISABLE_PROXY_UTILS,"true");testClient.setProperty(CommonsHttpMessageSender.HTTP_PROXY_HOST,"10.60.1.33");testClient.setProperty(CommonsHttpMessageSender.HTTP_PROXY_PORT,"808");}*/String result = service.sayHi("test");logger.info("WebService测试程序返回字符串为:" + result);//Object[] results = testClient.invoke("getName",new Object[] {});if(result != null){logger.info("--------------WebService client Create and Test success----------------------------");} else {logger.warn("--------------WebService client Create success But Test failure---------------------");}} catch (Exception e) {logger.warn("WebService客户端连接服务器失败,请检查WebService服务器参数或网络连接!",e);}}// JSR181模式,注意这里Server端开发组需要向Client提供实现类,而不止于//接口,有点危险
Service srvcModel = new AnnotationServiceFactory().create(HelloServiceImpl.class);
XFireProxyFactory factory = new XFireProxyFactory(XFireFactory.newInstance().getXFire());
String helloWorldURL = "http://localhost:8080/webservice/services/Hello";
Hello hello = (Hello) factory.create(srvcModel,helloWorldURL);
System.out.println(hello.sayHi("test"));

 

2、 动态模式,不生成字节码,直接调用

动态模式不需要服务端的class,不过性能和复杂对象映射等估计做得不会太好。

Client client = new Client(new URL("http://localhost:8080/webservice/services/Hellowsdl"));
Object[] results = client.invoke("sayHello", new Object[] { "Cao," });
System.out.println((String) results[0]);

3、 通过开发工具、根据WSDL生成Client Stub 

   注:来源于网络仅作参考

//简单参数的HelloClient client=new HelloClient();HelloPortType port =client.getHelloHttpPort();System.out.println(port.sayHello("hi!"));//参数复杂的MemberServiceClient client = new MemberServiceClient();MemberService memberService = client.getMemberServiceHttpPort();User user = new User();/*JAXBElement<String> name = new JAXBElement<String>(new QName("http://memberService", "username"), String.class, "smallnest");JAXBElement<String> password = new JAXBElement<String>(new QName("http://memberService", "password"), String.class, "123456");*/ObjectFactory objFac=new ObjectFactory();JAXBElement<String> name = objFac.createUserUsername("smallnest");JAXBElement<String> password = objFac.createUserPassword("123456");user.setUsername(name);user.setPassword(password);Member oneMember = new Member();JAXBElement<String> memeberName = new JAXBElement<String>(new QName("http://memberService", "name"), String.class, "迈克");JAXBElement<String> email= new JAXBElement<String(newQName("http://memberService","email"), String.class,"micro@micro.com");
oneMember.setName(memeberName);
oneMember.setEmail(email);
oneMember.setRank(6);
// 调用方法memberService.addMember(oneMember, user);

4、通过Ajax调用(js+XML)

(1、)

写一个页面,发送Ajax请求,请求的URL即服务的地址,请求方式是POST,另外,还需要设置请求头,以及手动构造请求体。


<head><title>通过ajax调用webservice服务</title>
<script>
var xhr;
function sendAjaxWS(){xhr = new ActiveXObject("Microsoft.XMLHTTP");                 //指定ws的请求地址var wsUrl = "http://192.168.1.108:5678/hello";//手动构造请求体var requestBody = '<soapenv:Envelope             xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" ' + '         xmlns:q0="http://service.itcast.cn/" xmlns:xsd="http://www.w3.org/2001/XMLSchema "'+
' xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">'+'<soapenv:Body><q0:sayHello><arg0>'+
document.getElementById("msg").value+'</arg0> <arg1>10</arg1> </q0:sayHello></soapenv:Body></soapenv:Envelope>';
//打开连接
xhr.open("POST",wsUrl,true);
//重新设置请求头
xhr.setRequestHeader("content-type","text/xml;charset=utf8");
//设置回调函数
xhr.onreadystatechange = _back;
//发送请求
xhr.send(requestBody);
}//定义回调函数function _back(){if(xhr.readyState == 4){if(xhr.status == 200){var ret = xhr.responseXML;//解析xmlvar eles = ret.getElementsByTagName("return")[0];alert(eles.text);}}}</script>
</head>
<body><input type="text" id="msg" /><input type="button" onclick="sendAjaxWS();" value="通过ajax调用webservice服务"/>
</body>

由于使用ajax – js调用web服务完成不同于使用java代码调用。所以,必须要对SOAP文件非常的了解。

一般使用ajax调用,应该是在已经获知了以下信息以后才去调用:

获知请求(request)的soap文本。

获知响应(response)的soap文本。

请求文件和响应文本格式,一般会随web服务的发布一同发布。

我们可以通过WSExplorer获取上面两段文本。

5、 通过URLConnection调用

         1,指定WebService服务的请求地址:

        String wsUrl = "http:// 124.205.244.130:5678/hello";

     2,创建URL:URL url = new URL(wsUrl);

       3,建立连接,并将连接强转为Http连接

URLConnection conn = url.openConnection();

          HttpURLConnection con = (HttpURLConnection) conn;

       4,设置请求方式和请求头:

          con.setDoInput(true);                  //是否有入参

          con.setDoOutput(true);                //是否有出参

          con.setRequestMethod("POST");   // 设置请求方式

          con.setRequestProperty("content-type", "text/xml;charset=UTF-8");

      5,// 手动构造请求体

               String requestBody = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" "

                         + " xmlns:q0=\"http://service.itcast.cn/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema \" "

                         + " xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">"

                         + "<soapenv:Body><q0:sayHello><arg0>lisi</arg0> <arg1>10</arg1> </q0:sayHello></soapenv:Body></soapenv:Envelope>";

   6,通过流的方式将请求体发送出去:

         //获得输出流

         OutputStream out = con.getOutputStream();

         out.write(requestBody.getBytes());

         out.close();

    7,服务端返回正常:

   int code = con.getResponseCode();

       if(code == 200){//服务端返回正常

         InputStream is = con.getInputStream();

         byte[] b = new byte[1024];

         StringBuffer sb = new StringBuffer();

         int len = 0;

         while((len = is.read(b)) != -1){

             String str = new String(b,0,len,"UTF-8");

             sb.append(str);

        }

        System.out.println(sb.toString());

        is.close();

       }

       con.disconnect();

}

说明:整合两篇文章的特点,把client编程和交互模式做一个统一

参考:

1、http://www.cnblogs.com/yolanda-lee/p/4907380.html#3916174

2、https://blog.csdn.net/javalearning1014/article/details/2667974

这篇关于XFire客户端编程实现方式和及AJAX调用方法的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/681254

相关文章

Java实现字节字符转bcd编码

《Java实现字节字符转bcd编码》BCD是一种将十进制数字编码为二进制的表示方式,常用于数字显示和存储,本文将介绍如何在Java中实现字节字符转BCD码的过程,需要的小伙伴可以了解下... 目录前言BCD码是什么Java实现字节转bcd编码方法补充总结前言BCD码(Binary-Coded Decima

python获取指定名字的程序的文件路径的两种方法

《python获取指定名字的程序的文件路径的两种方法》本文主要介绍了python获取指定名字的程序的文件路径的两种方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要... 最近在做项目,需要用到给定一个程序名字就可以自动获取到这个程序在Windows系统下的绝对路径,以下

SpringBoot全局域名替换的实现

《SpringBoot全局域名替换的实现》本文主要介绍了SpringBoot全局域名替换的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录 项目结构⚙️ 配置文件application.yml️ 配置类AppProperties.Ja

JavaScript中的高级调试方法全攻略指南

《JavaScript中的高级调试方法全攻略指南》什么是高级JavaScript调试技巧,它比console.log有何优势,如何使用断点调试定位问题,通过本文,我们将深入解答这些问题,带您从理论到实... 目录观点与案例结合观点1观点2观点3观点4观点5高级调试技巧详解实战案例断点调试:定位变量错误性能分

Python实现批量CSV转Excel的高性能处理方案

《Python实现批量CSV转Excel的高性能处理方案》在日常办公中,我们经常需要将CSV格式的数据转换为Excel文件,本文将介绍一个基于Python的高性能解决方案,感兴趣的小伙伴可以跟随小编一... 目录一、场景需求二、技术方案三、核心代码四、批量处理方案五、性能优化六、使用示例完整代码七、小结一、

Python中 try / except / else / finally 异常处理方法详解

《Python中try/except/else/finally异常处理方法详解》:本文主要介绍Python中try/except/else/finally异常处理方法的相关资料,涵... 目录1. 基本结构2. 各部分的作用tryexceptelsefinally3. 执行流程总结4. 常见用法(1)多个e

Java实现将HTML文件与字符串转换为图片

《Java实现将HTML文件与字符串转换为图片》在Java开发中,我们经常会遇到将HTML内容转换为图片的需求,本文小编就来和大家详细讲讲如何使用FreeSpire.DocforJava库来实现这一功... 目录前言核心实现:html 转图片完整代码场景 1:转换本地 HTML 文件为图片场景 2:转换 H

C#使用Spire.Doc for .NET实现HTML转Word的高效方案

《C#使用Spire.Docfor.NET实现HTML转Word的高效方案》在Web开发中,HTML内容的生成与处理是高频需求,然而,当用户需要将HTML页面或动态生成的HTML字符串转换为Wor... 目录引言一、html转Word的典型场景与挑战二、用 Spire.Doc 实现 HTML 转 Word1

C#实现一键批量合并PDF文档

《C#实现一键批量合并PDF文档》这篇文章主要为大家详细介绍了如何使用C#实现一键批量合并PDF文档功能,文中的示例代码简洁易懂,感兴趣的小伙伴可以跟随小编一起学习一下... 目录前言效果展示功能实现1、添加文件2、文件分组(书签)3、定义页码范围4、自定义显示5、定义页面尺寸6、PDF批量合并7、其他方法

SpringBoot实现不同接口指定上传文件大小的具体步骤

《SpringBoot实现不同接口指定上传文件大小的具体步骤》:本文主要介绍在SpringBoot中通过自定义注解、AOP拦截和配置文件实现不同接口上传文件大小限制的方法,强调需设置全局阈值远大于... 目录一  springboot实现不同接口指定文件大小1.1 思路说明1.2 工程启动说明二 具体实施2