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

相关文章

C# 比较两个list 之间元素差异的常用方法

《C#比较两个list之间元素差异的常用方法》:本文主要介绍C#比较两个list之间元素差异,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录1. 使用Except方法2. 使用Except的逆操作3. 使用LINQ的Join,GroupJoin

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os

MySQL查询JSON数组字段包含特定字符串的方法

《MySQL查询JSON数组字段包含特定字符串的方法》在MySQL数据库中,当某个字段存储的是JSON数组,需要查询数组中包含特定字符串的记录时传统的LIKE语句无法直接使用,下面小编就为大家介绍两种... 目录问题背景解决方案对比1. 精确匹配方案(推荐)2. 模糊匹配方案参数化查询示例使用场景建议性能优

关于集合与数组转换实现方法

《关于集合与数组转换实现方法》:本文主要介绍关于集合与数组转换实现方法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、Arrays.asList()1.1、方法作用1.2、内部实现1.3、修改元素的影响1.4、注意事项2、list.toArray()2.1、方

使用Python实现可恢复式多线程下载器

《使用Python实现可恢复式多线程下载器》在数字时代,大文件下载已成为日常操作,本文将手把手教你用Python打造专业级下载器,实现断点续传,多线程加速,速度限制等功能,感兴趣的小伙伴可以了解下... 目录一、智能续传:从崩溃边缘抢救进度二、多线程加速:榨干网络带宽三、速度控制:做网络的好邻居四、终端交互

Python中注释使用方法举例详解

《Python中注释使用方法举例详解》在Python编程语言中注释是必不可少的一部分,它有助于提高代码的可读性和维护性,:本文主要介绍Python中注释使用方法的相关资料,需要的朋友可以参考下... 目录一、前言二、什么是注释?示例:三、单行注释语法:以 China编程# 开头,后面的内容为注释内容示例:示例:四

java实现docker镜像上传到harbor仓库的方式

《java实现docker镜像上传到harbor仓库的方式》:本文主要介绍java实现docker镜像上传到harbor仓库的方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录1. 前 言2. 编写工具类2.1 引入依赖包2.2 使用当前服务器的docker环境推送镜像2.2

C++20管道运算符的实现示例

《C++20管道运算符的实现示例》本文简要介绍C++20管道运算符的使用与实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录标准库的管道运算符使用自己实现类似的管道运算符我们不打算介绍太多,因为它实际属于c++20最为重要的

一文详解Git中分支本地和远程删除的方法

《一文详解Git中分支本地和远程删除的方法》在使用Git进行版本控制的过程中,我们会创建多个分支来进行不同功能的开发,这就容易涉及到如何正确地删除本地分支和远程分支,下面我们就来看看相关的实现方法吧... 目录技术背景实现步骤删除本地分支删除远程www.chinasem.cn分支同步删除信息到其他机器示例步骤

Java easyExcel实现导入多sheet的Excel

《JavaeasyExcel实现导入多sheet的Excel》这篇文章主要为大家详细介绍了如何使用JavaeasyExcel实现导入多sheet的Excel,文中的示例代码讲解详细,感兴趣的小伙伴可... 目录1.官网2.Excel样式3.代码1.官网easyExcel官网2.Excel样式3.代码