美文网首页
springBoot整合cxf开发webService接口

springBoot整合cxf开发webService接口

作者: junstack | 来源:发表于2020-09-11 15:47 被阅读0次

    1.导入jar包

    <dependency>
   <groupId>org.apache.cxf</groupId>
   <artifactId>cxf-spring-boot-starter-jaxws</artifactId>
   <version>3.4.0</version>
 </dependency>

    2.新建接口

    package com.das.consultation.webService.service;

import com.das.consultation.webService.config.SoapConst;

import javax.jws.WebMethod;
import javax.jws.WebParam;
import javax.jws.WebService;

/**
 * created by jun on 2020/9/8
 * describe:webservice接口
 * version 1.0
 */
@WebService(targetNamespace = SoapConst.NAMESPACE_URI,name = "claSoap")
public interface ScheduleService {
    @WebMethod
    String HPS_getSchedule(@WebParam(name = "xmlStr") String xmlStr);
}

    3.接口实现（具体接口实现根据自己的来）

    package com.das.consultation.webService.service.Impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.das.consultation.entity.XmlMessage;
import com.das.consultation.entity.app.ScheduleInfo;
import com.das.consultation.util.JsonXmlUtils;
import com.das.consultation.util.PublicMethodUtil;
import com.das.consultation.webService.config.SoapConst;
import com.das.consultation.webService.service.ScheduleService;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.RequestBody;

import javax.jws.WebService;
import java.util.ArrayList;
import java.util.List;

/**
 * created by jun on 2020/9/11
 * describe:
 * version 1.0
 */
@WebService(
        targetNamespace = SoapConst.NAMESPACE_URI, //wsdl命名空间
        name = "claSoap",                  //portType名称 客户端生成代码时 为接口名称
        serviceName = "claSoapSoapService",    //服务name名称
        portName = "claSoapPortName",          //port名称
        endpointInterface = "com.das.consultation.webService.service.ScheduleService")
public class ScheduleServiceImpl implements ScheduleService {
    @Override
    public String HPS_getSchedule(@RequestBody String xmlStr) {
        JSONObject jsonObject = JsonXmlUtils.xmlToJson(xmlStr);
        JSONObject request = jsonObject.getJSONObject("request");
        JSONObject data = request.getJSONObject("data");
        String orgCode = data.getString("orgcode");
        String depId = data.getString("depid");
        String doctorId = data.getString("doctorid");
        String beginDate = data.getString("begindate");
        String endDate = data.getString("enddate");
        List<ScheduleInfo> scheduleInfos = new ArrayList<>();
        ScheduleInfo scheduleInfo = new ScheduleInfo();
        scheduleInfo.setScheduleid("213142494");
        scheduleInfo.setDepid("12542076");
        scheduleInfo.setDepname("眼科");
        scheduleInfo.setDoctorid("235t32723115");
        scheduleInfo.setDoctorname("曾医生");
        scheduleInfo.setVisitdate(PublicMethodUtil.ToDateTime("2020-8-12",4));
        scheduleInfo.setIsyuyue("1");
        scheduleInfo.setTimetype("白班");
        scheduleInfo.setReglevel("普通门诊");
        String str = PublicMethodUtil.getStringDate();
        scheduleInfo.setBegintime(PublicMethodUtil.strToDate(str));
        scheduleInfo.setEndtime(PublicMethodUtil.strToDate(str));
        scheduleInfo.setGuahaoamt((float) 23.21);
        scheduleInfo.setVisitamt((float) 30.34);
        scheduleInfo.setYuyuemax(214);
        scheduleInfo.setYuyuenum(143);
        scheduleInfos.add(scheduleInfo);
        XmlMessage xmlMessage = new XmlMessage();
        JSONArray array = null;
        try {
            array = (JSONArray) JSON.toJSON(scheduleInfos);
            if (!StringUtils.isEmpty(orgCode) && !StringUtils.isEmpty(depId)&& !StringUtils.isEmpty(doctorId) && !StringUtils.isEmpty(beginDate) && !StringUtils.isEmpty(endDate)) {
                if (array.size() != 0) {
                    xmlMessage.setResult("0");
                    xmlMessage.setDesc("查询成功");
                } else {
                    xmlMessage.setResult("1");
                    xmlMessage.setDesc("失败");
                    return JsonXmlUtils.jsonToXml(null,xmlMessage);
                }
            } else {
                xmlMessage.setResult("1");
                xmlMessage.setDesc("参数错误");
                return JsonXmlUtils.jsonToXml(null,xmlMessage);
            }
        } catch (Exception e) {
            e.printStackTrace();
            xmlMessage.setResult("1");
            xmlMessage.setDesc("查询异常");
            return JsonXmlUtils.jsonToXml(null,xmlMessage);
        }
        return JsonXmlUtils.jsonArrayToXml(array,xmlMessage,"schedule",null,null);
    }

}

    4.发布webservice配置类

    package com.das.consultation.webService.config;

import com.das.consultation.webService.service.Impl.ScheduleServiceImpl;
import com.das.consultation.webService.service.ScheduleService;
import org.apache.cxf.Bus;
import org.apache.cxf.bus.spring.SpringBus;
import org.apache.cxf.jaxws.EndpointImpl;
import org.apache.cxf.transport.servlet.CXFServlet;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.xml.ws.Endpoint;

/**
 * created by jun on 2020/9/11
 * describe:
 * version 1.0
 */
@Configuration
public class CxfConfig {
    @Bean("cxfServletRegistration")
    public ServletRegistrationBean dispatcherServlet() {
        //注册servlet 拦截/NBA 开头的请求 不设置 默认为：/services/*
        return new ServletRegistrationBean(new CXFServlet(), "/cla/*");
    }
    /**
     * 申明业务处理类 当然也可以直接 在实现类上标注 @Service
     * @author ShiFan
     */
    @Bean
    public ScheduleService scheduleService() {
        return new ScheduleServiceImpl();
    }

    /**
     * 非必要项
     */
    @Bean(name = Bus.DEFAULT_BUS_ID)
    public SpringBus springBus() {
        return new SpringBus();
    }
    /**
     * 发布endpoint
     */
    @Bean
    public Endpoint endpoint(ScheduleService scheduleService) {
        EndpointImpl endpoint = new EndpointImpl(springBus(), scheduleService);
        //发布地址
        endpoint.publish("/claService");
        return endpoint;
    }


}

    5.命名空间类

    package com.das.consultation.webService.config;

/**
 * created by jun on 2020/9/2
 * describe:空间名
 * version 1.0
 */
public class SoapConst {
    public static final String NAMESPACE_URI = "http://service.webService.consultation.das.com";
}

    访问地址：[http://localhost:8083/cla/claService?wsdl
    (http://localhost:8083/cla/claService?wsdl)出现以下画面则成功发布：

    1.png

    如果运行出现以下错误：

    Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2020-09-11 13:23:44.965 ERROR 28612 --- [           main] o.s.b.d.LoggingFailureAnalysisReporter   : 

***************************

APPLICATION FAILED TO START

***************************

Description:

The Bean Validation API is on the classpath but no implementation could be found

Action:

Add an implementation, such as Hibernate Validator, to the classpath


Process finished with exit code 1

    说明是springBoot版本和cxf版本不匹配比如我的版本是2.3.2对应cxf版本应是3.4.0如下：

    springboot版本

    <parent>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-parent</artifactId>
   <version>2.3.2.RELEASE</version>
   <relativePath /> <!-- lookup parent from repository -->
</parent>

    cxf版本

    <dependency>
   <groupId>org.apache.cxf</groupId>
   <artifactId>cxf-spring-boot-starter-jaxws</artifactId>
   <version>3.4.0</version>
</dependency>

    服务端项目结构：

    image1.png

    6.测试cxf根据wsdl生成客户端代码

    进入cxf安装目录如下：

    2.png

    进入cmd命令输入如下命令则生成如上图红色框的客户段代码：

    wsdl2java -encoding utf8 -p com.das.webservice.cxf -d D:\MyStudySpace\webservice\webserviceClient\src\main\java\com\das\webservice\cxf http://localhost:8083/cla/claService?wsdl

    7.新建项目webserviceClient

    拷贝生成的代码到客户端如下:

    3.png

    8.新建测试类ClientTest

    package com.das.webservice.cxf;

/**
 * created by jun on 2020/9/11
 * describe:
 * version 1.0
 */
public class ClientTest {
    public static void main(String[] args) {
        ClaSoap claSoap =  new ClaSoapSoapService().getClaSoapPortName();
        String result = claSoap.hpsGetSchedule("<request><head></head><data><orgcode>231434123122319645</orgcode><depid>123123</depid><doctorid>1435425998</doctorid><begindate>2018-10-3</begindate><enddate>2018-10-3</enddate></data></request>");
        System.out.println(result);
    }
}

    运行代码打印如下：

    <?xml version="1.0" encoding="utf-8"?><request><head><result>0</result><desc>查询成功</desc></head><data><schedule><isyuyue>1</isyuyue><visitdate>Wed Aug 12 00:00:00 CST 2020</visitdate><endtime>Fri Sep 11 15:14:05 CST 2020</endtime><visitamt>30.34</visitamt><begintime>Fri Sep 11 15:14:05 CST 2020</begintime><doctorname>曾医生</doctorname><reglevel>普通门诊</reglevel><guahaoamt>23.21</guahaoamt><doctorid>235t32723115</doctorid><yuyuemax>214</yuyuemax><depid>12542076</depid><timetype>白班</timetype><yuyuenum>143</yuyuenum><depname>眼科</depname><scheduleid>213142494</scheduleid></schedule></data></request>

    生命不息学习不止，代码是开源的！各位加油。

    相关文章

      网友评论

          本文标题：springBoot整合cxf开发webService接口

          本文链接：https://www.haomeiwen.com/subject/zlqbektx.html

          延伸阅读

          深度阅读

          • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

          栏目导航

          热点阅读

          关于我们|服务条款|联系我们|springBoot整合cxf开发webService接口|投稿指南|网站地图|RSS订阅|排版工具|手机版

          提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

          Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

          备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

          本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

          所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！