zhangxiaocc 2019-12-06
服务端(CXF发布webservice):
1、 http://cxf.apache.org/download.html下载 cxf文件包(3.1.18必须使用Java 7或Java 8)。
2、 将下载包的lib文件夹下的jar全部拷贝到spring项目中的lib目录下,注意删除相同的jar包(版本号不同拷贝不会替换)。
3、 删除以下4个jar包:
cxf-services-ws-discovery-api-3.1.5.jar
cxf-services-ws-discovery-service-3.1.5.jar
cxf-services-wsn-api-3.1.5.jar
cxf-services-wsn-core-3.1.5.jar
4、 web.xml配置如下:
<!-- 配置cxf框架 cxf-servlet.xml --> <servlet> <servlet-name>cxf</servlet-name> <servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class> <init-param> <param-name>config-location</param-name> <param-value>classpath:conf/cxf-servlet.xml</param-value> </init-param> </servlet> <servlet-mapping> <servlet-name>cxf</servlet-name> <url-pattern>/webservice/*</url-pattern> </servlet-mapping>
5、 conf目录下添加cxf-servlet.xml文件, cxf-servlet.xml配置如下:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> <!-- 加载提供的服务 --> <jaxws:endpoint id="helloService" address="/MyWebService" implementor="net.evecom.hr.MyWebService"></jaxws:endpoint> </beans>
7、 在net.evecom.hr目录下创建MyWebService类,如下:
package net.evecom.hr; import javax.jws.WebParam; import javax.jws.WebService; @WebService public class MyWebService { public String hiMyService(@WebParam(name = "content") String content) { System.out.println("客户端发送过来了:" + content); return "服务器返回:" + content; } }
8、启动tomcat,访问localhost:8080/项目名/webservice/,查看是否正常启动。
客户端(axis2获取webservice):
1、 http://axis.apache.org/axis2/java/core/download.html下载axis2-1.7.9;
2、 将下载包lib文件夹下的jar包复制到另一个项目lib目录下;
3、 测试代码如下:
package net.evecom.hr; import java.util.Iterator; 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 com.alibaba.fastjson.JSONObject; public class Test { public static void main(String[] args) { // TODO Auto-generated method stub String url = "http://localhost:8080/项目名/webservice/MyWebService?wsdl"; sendWsdl(url, "啊啊啊啊啊"); } public static void sendWsdl(String url, String xmlStr) { JSONObject res = new JSONObject(); try { String endpoint = url.replace("?wsdl", "");// 不需要传?wsdl // 直接引用远程的wsdl文件 Options options = new Options(); options.setTo(new EndpointReference(endpoint)); ServiceClient sender = new ServiceClient(); sender.setOptions(options); OMFactory fac = OMAbstractFactory.getOMFactory(); OMNamespace omNs = fac.createOMNamespace("http://hr.evecom.net/", "");// 参数1(uri)=即为wsdl文档的targetNamespace;参数2(prefix)=可不填 OMElement method = fac.createOMElement("hiMyService", omNs);// 方法名 QName qname = new QName("content"); OMElement in0 = fac.createOMElement(qname);// 方法参数 in0.setText(xmlStr); // 参数值 method.addChild(in0); // 添加参数 OMElement resultEle = sender.sendReceive(method);// 调用wsdl System.out.println("调用接口结果:" + resultEle.toString()); Iterator<?> iterator = resultEle.getChildElements(); OMElement result1 = null; while (iterator.hasNext()) { result1 = (OMElement) iterator.next(); System.out.println(result1.getText()); } } catch (AxisFault ex) { ex.printStackTrace(); } } }
4、运行代码,查看是否正常返回
至此,简单的webservice与Spring整合部署完成。
=====================================我是一条分割线============================================
添加拦截器:
a) cxf-servlet.xml配置如下:
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> <bean id="webServiceInterceptor" class="net.evecom.common.interceptors.WebServiceInterceptor"></bean> <bean id="loggingInInterceptor" class="org.apache.cxf.interceptor.LoggingInInterceptor"></bean> <bean id="loggingOutInterceptor" class="org.apache.cxf.interceptor.LoggingOutInterceptor"></bean> <!-- 加载提供的服务 --> <jaxws:endpoint id="webServiceTest" address="/MyWebService" implementor="net.evecom.webservice.hr.MyWebService"> <!-- 添加in拦截器 --> <jaxws:inInterceptors> <ref bean="loggingInInterceptor" /> <ref bean="webServiceInterceptor" /> </jaxws:inInterceptors> <!-- 添加out拦截器 --> <jaxws:outInterceptors> <ref bean="loggingOutInterceptor" /> </jaxws:outInterceptors> </jaxws:endpoint> <!-- <jaxws:server id="webServiceTest" serviceClass="net.evecom.webservice.hr.MyWebService" address="/MyWebService"> <jaxws:serviceBean> <ref bean="MyWebService" /> </jaxws:serviceBean> </jaxws:server> --> </beans>
b) 添加WebServiceInterceptor,代码如下:
/* * Copyright (c) 2005, 2016, EVECOM Technology Co.,Ltd. All rights reserved. * EVECOM PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. * */ package net.evecom.common.interceptors; import java.util.List; import org.apache.cxf.binding.soap.SoapMessage; import org.apache.cxf.headers.Header; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.phase.AbstractPhaseInterceptor; import org.apache.cxf.phase.Phase; import org.w3c.dom.Element; import net.evecom.common.util.MD5; public class WebServiceInterceptor extends AbstractPhaseInterceptor<SoapMessage> { private static final String TOKEN = "test"; public WebServiceInterceptor(String phase) { super(phase); } public WebServiceInterceptor() { super(Phase.PRE_INVOKE); } public void handleMessage(SoapMessage message) throws Fault { List<Header> headers = message.getHeaders(); if (headers == null || headers.size() == 0) { throw new Fault(new IllegalArgumentException("没有Header,拦截器实施拦截")); } Header firstHeader = headers.get(0); Element ele = (Element) firstHeader.getObject(); String token = ele.getFirstChild().getTextContent(); if (!token.equals(MD5.parseMD5(TOKEN))) { throw new Fault(new IllegalArgumentException("token不正确")); } } }
// 创建消息头:token=evecomoa SOAPFactory soapFactory = OMAbstractFactory.getSOAP11Factory(); // SOAPHeaderBlock soapHeader = soapFactory.createSOAPHeaderBlock("RequestHeader", omNamespace); // 添加头消息内容 SOAPHeaderBlock soapHeaderBlock = soapFactory.createSOAPHeaderBlock("token", omNamespace); soapHeaderBlock.addChild(soapFactory.createOMText(MD5.parseMD5("test"))); // soapHeader.addChild(soapHeaderBlock); // 将消息头加入到当前消息中 sender.addHeader(soapHeaderBlock);
的错误。geronimo-servlet_2.5_spec-1.2.jar (or Sun's Servlet jar). <?xml version="1.0" encoding="UTF-8"?>