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#实现将Excel表格转换为图片(JPG/ PNG)

《C#实现将Excel表格转换为图片(JPG/PNG)》Excel表格可能会因为不同设备或字体缺失等问题,导致格式错乱或数据显示异常,转换为图片后,能确保数据的排版等保持一致,下面我们看看如何使用C... 目录通过C# 转换Excel工作表到图片通过C# 转换指定单元格区域到图片知识扩展C# 将 Excel

基于Java实现回调监听工具类

《基于Java实现回调监听工具类》这篇文章主要为大家详细介绍了如何基于Java实现一个回调监听工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录监听接口类 Listenable实际用法打印结果首先,会用到 函数式接口 Consumer, 通过这个可以解耦回调方法,下面先写一个

使用Java将DOCX文档解析为Markdown文档的代码实现

《使用Java将DOCX文档解析为Markdown文档的代码实现》在现代文档处理中,Markdown(MD)因其简洁的语法和良好的可读性,逐渐成为开发者、技术写作者和内容创作者的首选格式,然而,许多文... 目录引言1. 工具和库介绍2. 安装依赖库3. 使用Apache POI解析DOCX文档4. 将解析

Qt中QGroupBox控件的实现

《Qt中QGroupBox控件的实现》QGroupBox是Qt框架中一个非常有用的控件,它主要用于组织和管理一组相关的控件,本文主要介绍了Qt中QGroupBox控件的实现,具有一定的参考价值,感兴趣... 目录引言一、基本属性二、常用方法2.1 构造函数 2.2 设置标题2.3 设置复选框模式2.4 是否

C++使用printf语句实现进制转换的示例代码

《C++使用printf语句实现进制转换的示例代码》在C语言中,printf函数可以直接实现部分进制转换功能,通过格式说明符(formatspecifier)快速输出不同进制的数值,下面给大家分享C+... 目录一、printf 原生支持的进制转换1. 十进制、八进制、十六进制转换2. 显示进制前缀3. 指

springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法

《springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法》:本文主要介绍springboot整合阿里云百炼DeepSeek实现sse流式打印,本文给大家介绍的非常详细,对大... 目录1.开通阿里云百炼,获取到key2.新建SpringBoot项目3.工具类4.启动类5.测试类6.测

Python列表去重的4种核心方法与实战指南详解

《Python列表去重的4种核心方法与实战指南详解》在Python开发中,处理列表数据时经常需要去除重复元素,本文将详细介绍4种最实用的列表去重方法,有需要的小伙伴可以根据自己的需要进行选择... 目录方法1:集合(set)去重法(最快速)方法2:顺序遍历法(保持顺序)方法3:副本删除法(原地修改)方法4:

pytorch自动求梯度autograd的实现

《pytorch自动求梯度autograd的实现》autograd是一个自动微分引擎,它可以自动计算张量的梯度,本文主要介绍了pytorch自动求梯度autograd的实现,具有一定的参考价值,感兴趣... autograd是pytorch构建神经网络的核心。在 PyTorch 中,结合以下代码例子,当你

Python中判断对象是否为空的方法

《Python中判断对象是否为空的方法》在Python开发中,判断对象是否为“空”是高频操作,但看似简单的需求却暗藏玄机,从None到空容器,从零值到自定义对象的“假值”状态,不同场景下的“空”需要精... 目录一、python中的“空”值体系二、精准判定方法对比三、常见误区解析四、进阶处理技巧五、性能优化

SpringBoot集成Milvus实现数据增删改查功能

《SpringBoot集成Milvus实现数据增删改查功能》milvus支持的语言比较多,支持python,Java,Go,node等开发语言,本文主要介绍如何使用Java语言,采用springboo... 目录1、Milvus基本概念2、添加maven依赖3、配置yml文件4、创建MilvusClient