700字范文 > SpringBoot2 整合 AXIS 服务端和客户端

SpringBoot2 整合 AXIS 服务端和客户端

时间：2021-01-07 22:53:41

文章目录

一、服务端1. 版本选型2.导入依赖3. SERVLET4. 接口5.实现类6. 配置工厂7.启动类8. WEB-INF目录18. WEB-INF目录29. /目录19. /目录210. wsdd11. 测试验证二、客户端开源源码.

一、服务端

1. 版本选型

2.导入依赖

<dependency><groupId>org.apache.axis</groupId><artifactId>axis</artifactId><version>1.4</version></dependency><dependency><groupId>axis</groupId><artifactId>axis-jaxrpc</artifactId><version>1.4</version></dependency><dependency><groupId>commons-discovery</groupId><artifactId>commons-discovery</artifactId><version>0.2</version></dependency><dependency><groupId>wsdl4j</groupId><artifactId>wsdl4j</artifactId><version>1.6.3</version></dependency>

3. SERVLET

package com.gblfy.ws.servlet;import org.apache.axis.transport.http.AxisServlet;/*** AxisServlet** @author gblfy* @date -09-17*/@javax.servlet.annotation.WebServlet(urlPatterns = "/services/*",loadOnStartup = 1,name = "AxisServlet")public class AxisBootServlet extends AxisServlet {}

4. 接口

package com.gblfy.ws.service;/*** Axis接口** @author gblfy* @date -09-17*/public interface IAxisService {public String sayHello(String info);public String sayHello2(String info,String info2);}

5.实现类

package com.gblfy.ws.service.impl;import com.gblfy.ws.service.IAxisService;import org.springframework.stereotype.Service;/*** Axis接口实现类** @author gblfy* @date -09-17*/@Servicepublic class AxisServiceImpl implements IAxisService {/*** @param info* @return*/@Overridepublic String sayHello(String info) {return "sayHello:" + info;}@Overridepublic String sayHello2(String info, String info2) {return info + info2;}}

6. 配置工厂

新建org.apache.axis.configuration包

在新建的包下新建EngineConfigurationFactoryServlet类，集成EngineConfigurationFactoryDefault

第一种：目录为

String appWebInfPath = “/WEB-INF”;

第二种：目录为

String appWebInfPath = “/”;

package org.apache.axis.configuration;/** Copyright 2002- The Apache Software Foundation.** Licensed under the Apache License, Version 2.0 (the "License");* you may not use this file except in compliance with the License.* You may obtain a copy of the License at**/licenses/LICENSE-2.0** Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an "AS IS" BASIS,* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.* See the License for the specific language governing permissions and* limitations under the License.*/import org.apache.axis.AxisProperties;import org.apache.axis.ConfigurationException;import org.apache.axis.EngineConfiguration;import org.apache.axis.EngineConfigurationFactory;import org.ponents.logger.LogFactory;import org.apache.axis.server.AxisServer;import org.apache.axis.utils.ClassUtils;import org.apache.axis.utils.Messages;import mons.logging.Log;import javax.servlet.ServletConfig;import java.io.InputStream;/*** This is a default implementation of ServletEngineConfigurationFactory.* It is user-overrideable by a system property without affecting* the caller. If you decide to override it, use delegation if* you want to inherit the behaviour of this class as using* class extension will result in tight loops. That is, your* class should implement EngineConfigurationFactory and keep* an instance of this class in a member field and delegate* methods to that instance when the default behaviour is* required.** @author Richard A. Sitze* @author Davanum Srinivas (dims@)*/public class EngineConfigurationFactoryServletextends EngineConfigurationFactoryDefault {protected static Log log =LogFactory.getLog(EngineConfigurationFactoryServlet.class.getName());private ServletConfig cfg;/*** Creates and returns a new EngineConfigurationFactory.* If a factory cannot be created, return 'null'.* <p>* The factory may return non-NULL only if:* - it knows what to do with the param (param instanceof ServletContext)* - it can find it's configuration information** @see EngineConfigurationFactoryFinder*/public static EngineConfigurationFactory newFactory(Object param) {/*** Default, let this one go through if we find a ServletContext.** The REAL reason we are not trying to make any* decision here is because it's impossible* (without refactoring FileProvider) to determine* if a *.wsdd file is present or not until the configuration* is bound to an engine.** FileProvider/EngineConfiguration pretend to be independent,* but they are tightly bound to an engine instance...*/return (param instanceof ServletConfig)? new EngineConfigurationFactoryServlet((ServletConfig) param): null;}/*** Create the default engine configuration and detect whether the user* has overridden this with their own.*/protected EngineConfigurationFactoryServlet(ServletConfig conf) {super();this.cfg = conf;}/*** Get a default server engine configuration.** @return a server EngineConfiguration*/public EngineConfiguration getServerEngineConfig() {return getServerEngineConfig(cfg);}/*** Get a default server engine configuration in a servlet environment.* <p>* //* @param ctx a ServletContext** @return a server EngineConfiguration*/private static EngineConfiguration getServerEngineConfig(ServletConfig cfg) {String configFile = cfg.getInitParameter(OPTION_SERVER_CONFIG_FILE);if (configFile == null)configFile =AxisProperties.getProperty(OPTION_SERVER_CONFIG_FILE);if (configFile == null) {configFile = SERVER_CONFIG_FILE;}// String appWebInfPath = "/";String appWebInfPath = "/WEB-INF";//由于部署方式变更为jar部署，此处不可以使用改方式获取路径// ServletContext ctx = cfg.getServletContext();// String realWebInfPath = ctx.getRealPath(appWebInfPath);FileProvider config = null;String realWebInfPath = EngineConfigurationFactoryServlet.class.getResource(appWebInfPath).getPath();InputStream iss = ClassUtils.getResourceAsStream(EngineConfigurationFactoryServlet.class, appWebInfPath + "/" + SERVER_CONFIG_FILE);if (iss != null) {// FileProvider assumes responsibility for 'is':// do NOT call is.close().config = new FileProvider(iss);}if (config == null) {log.error(Messages.getMessage("servletEngineWebInfError03", ""));}/*** Couldn't get data OR file does exist.* If we have a path, then attempt to either open* the existing file, or create an (empty) file.*/if (config == null && realWebInfPath != null) {try {config = new FileProvider(realWebInfPath, configFile);} catch (ConfigurationException e) {log.error(Messages.getMessage("servletEngineWebInfError00"), e);}}/*** Fall back to config file packaged with AxisEngine*/if (config == null) {log.warn(Messages.getMessage("servletEngineWebInfWarn00"));try {InputStream is =ClassUtils.getResourceAsStream(AxisServer.class,SERVER_CONFIG_FILE);config = new FileProvider(is);} catch (Exception e) {log.error(Messages.getMessage("servletEngineWebInfError02"), e);}}return config;}}

7.启动类

@ServletComponentScan //扫描自定义的WebFilter和WebListener,否则无法扫描到

8. WEB-INF目录1

如果上面工厂的静态目录选择WEB-INF，请认真阅读这一小节，如果选择/则可以跳过这一小节，静态目录选择WEB-INF有以下二种场景：

第一种：在main目录下，创建webapp/WEB-INF目录

调整目录属性

8. WEB-INF目录2

第二种：在resources目录下面WEB-INF目录

9. /目录1

如果 6. 配置工厂选择的静态目录为/,请认真阅读这一小节，有以下二种场景：

第一种：在resources下面存放server-config.wsdd文件

9. /目录2

第二种：在webapp下面存放server-config.wsdd文件

，若果选择在webapp下面存放server-config.wsdd文件，请调整目录属性

10. wsdd

根据上面选择的场景，在指定的目录下面创建server-config.wsdd文件，内容如下：

第一种：在webapp的WEB-INF目录下面

第二种：在webapp目录下面

第三种：在resources的WEB-INF目录下面

第四种：在resources目录下面

<?xml version="1.0" encoding="UTF-8"?><deployment xmlns="/axis/wsdd/"xmlns:java="/axis/wsdd/providers/java"><handler type="java:org.apache.axis.handlers.http.URLMapper"name="URLMapper"/><service name="AxisServiceShell" provider="java:RPC"><parameter name="className" value="com.gblfy.ws.service.impl.AxisServiceImpl"/><parameter name="allowedMethods" value="sayHello"/></service><transport name="http"><requestFlow><handler type="URLMapper"/></requestFlow></transport></deployment>

11. 测试验证

http://localhost:8080/services/AxisServiceShell?wsdl

二、客户端

package com.gblfy.ws.client;import org.apache.axis.client.Call;import org.apache.axis.client.Service;import mons.lang3.StringUtils;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.ponent;import org.springframework.util.ObjectUtils;import javax.xml.namespace.QName;import javax.xml.rpc.ParameterMode;import java.rmi.RemoteException;/*** Axis客户端** @author guobin* @date -09-17*/@Componentpublic class AxisClient {private final static Logger log = LoggerFactory.getLogger(AxisClient.class);public static void main(String[] args) throws Exception {String axisUrl = "http://localhost:8080/services/axisServiceShell?wsdl";String namespaceURI = "http://localhost:8080/services/axisServiceShell";// String method = "sayHello";String method = "sayHello2";String reqXml = "1";String reqXml2 = "2";//调用axis服务// AxisClient.axisSendMsg(axisUrl, namespaceURI, method, reqXml);AxisClient.axisSendMsg(axisUrl, namespaceURI, method, reqXml, reqXml2);}/*** @param url WebService地址* @param namespace 命名空间* @param method 方法* @param tReqXml 请求报文* @return* @throws Exception*/public static String axisSendMsg(String url, String namespace, String method, String tReqXml)throws Exception {Service service = new Service();Call call;String res = null;call = (Call) service.createCall();long forStrTime = 0L;if (StringUtils.isBlank(url)) {throw new RuntimeException("调用url地址等于空，请核实地址是否正确！");}if (StringUtils.isBlank(namespace)) {throw new RuntimeException("调用namespace等于空，请核实命名空间是否正确！");}if (StringUtils.isBlank(method)) {throw new RuntimeException("调用method等于空，请核实方法名是否正确！");}if (ObjectUtils.isEmpty(tReqXml)) {throw new RuntimeException("调发送报文等于空，请核实发送内容是否正确！");}call.setTargetEndpointAddress(new .URL(url));//特殊处理部分 startString subUrl = url.substring(url.lastIndexOf("/"));log.info("转发路径标志 {}", subUrl.substring(1, subUrl.length()));//针对xxx需求添加单独逻辑判断if ("ws_fxhx_ws".equals(subUrl.substring(1, subUrl.length()))) {call.addParameter("xmlStr", org.apache.axis.Constants.XSD_STRING, ParameterMode.IN);call.setReturnType(org.apache.axis.Constants.XSD_STRING);}//特殊处理部分 endcall.setOperationName(new QName(namespace, method));// 这是要调用的方法log.info("开始转发请求报文");forStrTime = System.currentTimeMillis();log.info("开始转发时间: {}-毫秒", forStrTime);try {res = (String) call.invoke(new Object[]{tReqXml});} catch (RemoteException e) {e.printStackTrace();throw e;}long forEndTime = System.currentTimeMillis();log.info("转发结束时间: {}-毫秒", forEndTime);long endToStart = (long) (forEndTime - forStrTime);log.info("转发消耗的时间:: {}-毫秒", endToStart);log.info("响应报文: {}", res);return res;}public static String axisSendMsg(String url, String namespace, String method, String tReqXml, String tReqXml2)throws Exception {Service service = new Service();Call call;String res = null;call = (Call) service.createCall();long forStrTime = 0L;if (StringUtils.isBlank(url)) {throw new RuntimeException("调用url地址等于空，请核实地址是否正确！");}if (StringUtils.isBlank(namespace)) {throw new RuntimeException("调用namespace等于空，请核实命名空间是否正确！");}if (StringUtils.isBlank(method)) {throw new RuntimeException("调用method等于空，请核实方法名是否正确！");}if (ObjectUtils.isEmpty(tReqXml)) {throw new RuntimeException("调发送报文等于空，请核实发送内容是否正确！");}call.setTargetEndpointAddress(new .URL(url));//特殊处理部分 startString subUrl = url.substring(url.lastIndexOf("/"));log.info("转发路径标志 {}", subUrl.substring(1, subUrl.length()));//针对xxx需求添加单独逻辑判断if ("ws_fxhx_ws".equals(subUrl.substring(1, subUrl.length()))) {call.addParameter("xmlStr", org.apache.axis.Constants.XSD_STRING, ParameterMode.IN);call.setReturnType(org.apache.axis.Constants.XSD_STRING);}//特殊处理部分 endcall.setOperationName(new QName(namespace, method));// 这是要调用的方法log.info("开始转发请求报文");forStrTime = System.currentTimeMillis();log.info("开始转发时间: {}-毫秒", forStrTime);try {res = (String) call.invoke(new Object[]{tReqXml, tReqXml2});} catch (RemoteException e) {e.printStackTrace();throw e;}long forEndTime = System.currentTimeMillis();log.info("转发结束时间: {}-毫秒", forEndTime);long endToStart = (long) (forEndTime - forStrTime);log.info("转发消耗的时间:: {}-毫秒", endToStart);log.info("响应报文: {}", res);return res;}}

开源源码.

/gb_90/unified-access-center

本内容不代表本网观点和政治立场，如有侵犯你的权益请联系我们处理。

网友评论

网友评论仅供其表达个人看法，并不表明网站立场。