WebService 及 CXF 的进阶讲解
Posted 阿肯新
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了WebService 及 CXF 的进阶讲解相关的知识，希望对你有一定的参考价值。
4.2. WebService请求深入分析
1). 分析WebService的WSDL文档结构
1.1). 实例截图
<definitions>
<types>
<schema>
<element>
<message>
<portType>
<operation>
<input>
<output>
<binding>
<operation>
<input>
<output>
<service>
<port>
binding属性
<address>
1.2). 文档结构
<definitions>
<types>
<schema>
<element>
</types>
<message>
<part>
</message>
<portType>
<operation>
<input>
<output>
</portType>
<binding>
<operation>
<input>
<output>
</binding>
<service>
<port>
<address>
</service>
</definitions>
1.3). 文档结构图
1.4). 重要标签的说明
- types - 数据类型(标签)定义的容器，里面使用schema
- 定义了一些标签结构供message引用
- 定义了一些标签结构供message引用
- message - 通信消息的数据结构的抽象类型化定义。
- 引用types中定义的标签
- 引用types中定义的标签
- operation - 对服务中所支持的操作的抽象描述，
- 一个operation描述了一个访问入口的请求消息与响应消息对。
- 一个operation描述了一个访问入口的请求消息与响应消息对。
- portType - 对于某个访问入口点类型所支持的操作的抽象集合，
- 这些操作可以由一个或多个服务访问点来支持。
- 这些操作可以由一个或多个服务访问点来支持。
- binding - 特定端口类型的具体协议和数据格式规范的绑定。
- service- 相关服务访问点的集合
- port - 定义为协议/数据格式绑定与具体Web访问地址组合的单个服务访问点。
2). 测试CXF支持的数据类型
- 基本类型
– int,float,boolean等
- 引用类型
– String
– 集合：数组，List, Set, Map
– 自定义类型 Student
Jdk:不支持 map.
3). 一次Web service请求的流程
一次web service请求的本质:
1)客户端向服务器端发送了一个soap消息(http请求+xml片断)
2) 服务器端处理完请求后, 向客户端返回一个soap消息
那么它的流程是怎样的呢？
4.3. CXF框架的深入使用
1).CXF的拦截器
1.1) 理解
- 为什么设计拦截器？
- 为了在webservice请求过程中,能动态操作请求和响应数据, CXF设计了拦截器.
- 拦截器分类：
- 按所处的位置分：服务器端拦截器，客户端拦截器
- 按消息的方向分：入拦截器，出拦截器
- 按定义者分：系统拦截器，自定义拦截器
- 拦截器API
Interceptor(拦截器接口)
AbstractPhaseInterceptor(自定义拦截器从此继承)
LoggingInInterceptor(系统日志入拦截器类)
LoggingOutInterceptor(系统日志出拦截器类)
1.2) 编码实现拦截器
- 使用日志拦截器，实现日志记录
– LoggingInInterceptor
– LoggingOutInterceptor
- 使用自定义拦截器，实现用户名与密码的检验
– 服务器端的in拦截器
– 客户端的out拦截器
1 服务端: 2 public class CheckUserInterceptor extends AbstractPhaseInterceptor<SoapMessage> { 3 4 public CheckUserInterceptor() { 5 super(Phase.PRE_PROTOCOL); 6 } 7 8 @Override 9 public void handleMessage(SoapMessage msg) throws Fault { 10 Header header = msg.getHeader(new QName("thecheck")); 11 if(header != null){ 12 Element chenkEle = (Element) header.getObject(); 13 String username = chenkEle.getElementsByTagName("username").item(0).getTextContent(); 14 String password = chenkEle.getElementsByTagName("password").item(0).getTextContent(); 15 16 if("ymmm".equals(username) && "123456".equals(password)){ 17 System.out.println("Client de "+username+" 通过了 服务器的检查"); 18 return; 19 } 20 } 21 System.out.println("client 没有通过拦截器检查"); 22 23 throw new Fault(new RuntimeException("请输入正确的用户名和密码!!!")); 24 25 } 26 27 } 28 29 30 客户端: 31 public class AddUserInterceptor extends AbstractPhaseInterceptor<SoapMessage> { 32 private String username; 33 private String password; 34 35 public AddUserInterceptor(String username , String password) { 36 super(Phase.PRE_PROTOCOL); 37 this.username = username; 38 this.password = password; 39 } 40 /* 41 <Envelope> 42 <head> 43 <chenkEle> 44 <name>xfzhang</name> 45 <password>123456</password> 46 </chenkEle> 47 <chenkEle2> 48 <name>xfzhang</name> 49 <password>123456</password> 50 </chenkEle2> 51 <head> 52 <Body> 53 <sayHello> 54 <arg0>BOB</arg0> 55 <sayHello> 56 </Body> 57 </Envelope> 58 */ 59 60 @Override 61 public void handleMessage(SoapMessage msg) throws Fault { 62 List<Header> list = msg.getHeaders(); 63 64 DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); 65 Document document; 66 try { 67 document = factory.newDocumentBuilder().newDocument(); 68 69 Element chenkEle = document.createElement("thecheck"); 70 71 Element usernameEle = document.createElement("username"); 72 usernameEle.setTextContent(username); 73 chenkEle.appendChild(usernameEle); 74 75 Element passwordEle = document.createElement("password"); 76 passwordEle.setTextContent(password); 77 chenkEle.appendChild(passwordEle); 78 79 list.add(new Header(new QName("thecheck"), chenkEle)); 80 } catch (ParserConfigurationException e) { 81 // TODO Auto-generated catch block 82 e.printStackTrace(); 83 } 84 } 85 }
1 public class TestService2 { 2 3 public static void main(String[] args) { 4 String address = "http://192.168.1.102:8787/webService_02_sayService/hellows"; 5 Endpoint publish = Endpoint.publish(address, new HelloWsImpl()); 6 EndpointImpl endImpl = (EndpointImpl) publish; 7 8 //添加日志入拦截器拦截器 9 List<Interceptor<? extends Message>> inList = endImpl.getInInterceptors(); 10 inList.add(new LoggingInInterceptor()); 11 inList.add(new CheckUserInterceptor()); 12 13 //添加日志出拦截器 14 List<Interceptor<? extends Message>> outIplm = endImpl.getOutInterceptors(); 15 outIplm.add(new LoggingOutInterceptor()); 16 17 18 System.out.println("发布 webService_01_cxf_sayService 成功"); 19 } 20 }
1 public class Test2 { 2 3 public static void main(String[] args) { 4 HelloWsImplService factory = new HelloWsImplService(); 5 HelloWs helloWs = factory.getHelloWsImplPort(); 6 7 Client client = ClientProxy.getClient(helloWs); 8 9 List<Interceptor<? extends Message>> outList = client.getOutInterceptors(); 10 outList.add(new AddUserInterceptor("ymmm", "123456")); 11 12 String string = helloWs.sayHello("cxf-client3 yyy"); 13 System.out.println(string); 14 } 15 }
2). 用CXF编写基于spring的web service
2.1). 编码实现
- Server端
– 创建spring的配置文件beans.xml,在其中配置SEI
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xmlns:jaxws="http://cxf.apache.org/jaxws" 5 xsi:schemaLocation="http://www.springframework.org/schema/beans 6 http://www.springframework.org/schema/beans/spring-beans.xsd 7 http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> 8 <!-- 如果是低版本,还要引入更多文件 --> 9 <import resource="classpath:META-INF/cxf/cxf.xml" /> 10 <!-- 配置终端 --> 11 <jaxws:endpoint 12 id="orderWS" 13 implementor="com.ittest.servcie_02_cxf_.ws.OrderWsImpl" 14 address="/orderws" > 15 <!-- 配置拦截器 --> 16 <jaxws:inInterceptors> 17 <bean class="com.ittest.ws.interceptor.CheckUserInterceptor"></bean> 18 </jaxws:inInterceptors> 19 20 </jaxws:endpoint> 21 </beans>
– 在web.xml中，配置上CXF的一些核心组件
1 <context-param> 2 <param-name>contextConfigLocation</param-name> 3 <param-value>classpath:applicationContext.xml</param-value> 4 </context-param> 5 6 <listener> 7 <listener-class> 8 org.springframework.web.context.ContextLoaderListener 9 </listener-class> 10 </listener> 11 12 <servlet> 13 <servlet-name>CXFServlet</servlet-name> 14 <servlet-class> 15 org.apache.cxf.transport.servlet.CXFServlet 16 </servlet-class> 17 <load-on-startup>1</load-on-startup> 18 </servlet> 19 20 <servlet-mapping> 21 <servlet-name>CXFServlet</servlet-name> 22 <url-pattern>/*</url-pattern> 23 </servlet-mapping>
注意:各种cxf版本在配置xml的时候有区别( 在Cxf的高版本中要引入的其它文件较少 ).
- Client端
– 生成客户端代码
– 创建客户端的spring配置文件beans-client.xml,并配置
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xmlns:jaxws="http://cxf.apache.org/jaxws" 5 xsi:schemaLocation="http://www.springframework.org/schema/beans 6 http://www.springframework.org/schema/beans/spring-beans.xsd 7 http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> 8 9 10 <jaxws:client id="orderClient" serviceClass="com.ittest.servcie_02_cxf_.ws.OrderWs" 11 address="http://localhost:8080/webService_02_cxf_sayService_spring/orderws" > 12 13 <!-- 添加拦截器 --> 14 <jaxws:outInterceptors> 15 <bean class="org.apache.cxf.interceptor.LoggingOutInterceptor"/> 16 <bean class="com.ittest.ws.client.intercepter.AddUserInterceptor"> 17 <constructor-arg name="username" value="ymmm"/> 18 <constructor-arg name="password" value="123456"/> 19 </bean> 20 </jaxws:outInterceptors> 21 22 </jaxws:client> 23 24 </beans>
– 编写测试类请求web service
1 public class Test1 { 2 3 4 public static void main(String[] args) { 5 String path = "classpath:applicationContext.xml"; 6 ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(path); 7 8 OrderWs orderWs = (OrderWs) applicationContext.getBean("orderClient"); 9 Order order = orderWs.getOrder(3); 10 System.out.println(order); 11 } 12 }
2.2). 添加自定义拦截器
- Server端
– 在beans.xml中，在endpoint中配置上入拦截器 (同上)
- Client端
– 通过Client对象设置出拦截器 (同上)
4.4. 其它调用WebService的方式
1). Ajax调用webService
跨域请求问题:
1. 什么是跨域请求? (jquery还要求都是 localhost)
1. sina.com--=->baidu.com/xxx.jsp
2. localhost----à192.168.42.165
2. 解决ajax跨域请求webservice的问题?
在客户端应用中使用java编码去请求webservice, 在页面中去请求自己的后台
2). Jquery调用WebService
3). HttpURLConnection调用WebService
以上三个的代码(一起):
1 <%@ page language="java" contentType="text/html; charset=UTF-8" 2 pageEncoding="UTF-8"%> 3 <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 4 <html> 5 <head> 6 <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 7 <title>Insert title here</title> 8 <script type="text/javascript" src="jquery-1.8.3.js" ></script> 9 <script type="text/javascript"> 10 11 $(document).ready(function(){ 12 13 $("#btn2").click(function(){ 14 var name = document.getElementById("name").value; 15 $.post( 16 "HttpURLConnectionServlet", 17 "name="+name, 18 function(msg){ 19 var $Result = $(msg); 20 var value = $Result.find("return").text(); 21 alert(value); 22 }, 23 "xml" 24 ); 25 }); 26 27 $("#btn1").click(function(){ 28 29 var name = document.getElementById("name").value; 30 var date = \'<soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Header><thecheck><username>ymmm</username><password>123456</password></thecheck></soap:Header><soap:Body><ns2:getOrder xmlns:ns2="http://ws.servcie_02_cxf_.ittest.com/"><arg0>3</arg0></ns2:getOrder></soap:Body></soap:Envelope>\'; 31 alert(name+" "+date); 32 $.ajax({ 33 type : "POST", 34 url : "http://localhost:8080/webService_02_cxf_sayService_spring/orderws", 35 data : date, 36 success : function(msg){ 37 alert("------"); 38 var $Result = $(msg); 39 var value = $Result.find("return").text(); 40 alert(value); 41 }, 42 error : function(msg) { 43 //alert("-----"+msg); 44 }, 45 dataType : "xml" 46 }); 47 }); 48 }); 49 50 51 function reqWebService() { 52 53 var name = document.getElementById("name").value; 54 var date = \'<soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/"><soap:Body><ns2:sayHello xmlns:ns2="http://service.ws.ittest.com/"><arg0>\' 55 + name + \'</arg0></ns2:sayHello></soap:Body></soap:Envelope>\'; 56 57 var xmlhttp = getRequest(); 58 alert("---"); 59 xmlhttp.onreadystatechange = function() { 60 if (xmlhttp.readyState == 4 && xmlhttp.status == 200) { 61 alert("前"); 62 var result = xmlhttp.responseXML; 63 alert("后"); 64 var returnEle = result.getElementsByTagName("return")[0]; 65 var vale = returnEle.firstChild.data; 66 alert(vale); 67 68 } 69 }; 70 71 xmlhttp.open("POST", 72 "http://192.168.1.102:8787/webService_02_sayService/hellows"); 73 74 xmlhttp.setRequestHeader("Content-type", 75 "application/x-www-form-urlencoded"); 76 77 xmlhttp.send(date); 78 79 } 80 81 function getRequest() { 82 var xmlhttp = null; 83 if (window.XMLHttpRequest) {// code for IE7+, Firefox, Chrome, Opera, Safari 84 xmlhttp = new XMLHttpRequest(); 85 } else {// code for IE6, IE5 86 xmlhttp = new ActiveXObject("Microsoft.XMLHTTP"); 87 } 88 return xmlhttp; 89 } 90 </script> 91 92 93 </head> 94 <body> 95 用户名: 96 <input type="text" id="name" name="username" /> 97 <br /> 98 <div> 99 <button onclick="reqWebService()">使用Ajax连接 webservice</button></div> 100 <button id="btn1">使用JQuery链接webService</button> 101 <button id="btn2">使用Connection链接webService</button> 102 103 </body> 104 </html>
cxf webservice生成客户端代码及调用服务端遇到的问题