webservice之jax-ws實現方式(服務端)

1.什么是webservice?

webservice是一種遠程資源調用技術，它的實現方式主要分為兩種，

第一種是jaxws方式,它是面向方法的，它的數據類型是xml是基於soap實現傳輸；

第二種是jaxrs方式,它是面向資源的，它的數據類型是xml或json是基於http協議實現傳輸。

2.jaxws簡單應用

  服務端：

第一步：創建一個簡單的web項目，略 

第二步：添加webService的依賴jar包，配置web.xml

 <dependency>
        <groupId>org.apache.cxf</groupId>
        <artifactId>cxf-rt-frontend-jaxws</artifactId>
        <version>3.0.1</version>
    </dependency> 注：版本需與springboot對應 否則啟動就會報錯 在https://mvnrepository.com/artifact/org.apache.cxf/cxf-spring-boot-starter-jaxws查找到jaxws的各種版本，進入之后可以看到對應的springboot版本

問題詳情：
Description:

Parameter 1 of constructor in org.springframework.boot.autoconfigure.web.servlet.error.ErrorMvcAutoConfiguration required a bean of type ‘org.springframework.boot.autoconfigure.web.servlet.DispatcherServletPath’ that could not be found.

The following candidates were found but could not be injected:
- Bean method ‘dispatcherServletRegistration’ in ‘DispatcherServletAutoConfiguration.DispatcherServletRegistrationConfiguration’ not loaded because DispatcherServlet Registration found non dispatcher servlet dispatcherServlet

Action:

Consider revisiting the entries above or defining a bean of type ‘org.springframework.boot.autoconfigure.web.servlet.DispatcherServletPath’ in your configuration.

Process finished with exit code 1
 

第三步：編寫代碼

import com.test.demo.service.IDataReceiverService;
import org.apache.cxf.Bus;
import org.apache.cxf.jaxws.EndpointImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.xml.ws.Endpoint;

/**
 * 〈cxf配置〉
 * 默認:services
 * http://127.0.0.1:6689/services/receiveData
 * cxf-path配置路徑：
 * http://127.0.0.1:6689/soap/receiveData
 */
@Configuration
public class CxfConfig {

    @Autowired
    private Bus bus;

    @Autowired
    private IDataReceiverService dataReceiverService;


    /**
     * 數據站點服務（總入口）
     *
     * @return
     */
    @Bean
    public Endpoint getReceiveData() {
        EndpointImpl endpoint = new EndpointImpl(bus, dataReceiverService);
        endpoint.publish("/receiveData");
        return endpoint;
    }

}

package com.test.demo.service;


import com.test.demo.entity.ReceiveMsg;

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

/**
 * 接收數據處理服務類
 *
 * @Author: zhangt
 * @Date: 2021/9/11 11:46
 */

@WebService
public interface IDataReceiverService {


    /**
     * 接收數據接口
     *
     * @param receiveMsg 數據
     * @return
     */
    @WebMethod
    String getReceiveMsg(@WebParam(name = "ROOT") ReceiveMsg receiveMsg);

}

package com.test.demo.service.impl;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import com.test.demo.entity.ReceiveMsg;
import com.test.demo.entity.ResultMsg;
import com.test.demo.entity.UploadData;
import com.test.demo.service.IDataReceiverService;
import com.test.demo.util.ReceiveMsgUtil;
import lombok.extern.slf4j.Slf4j;
import org.dom4j.DocumentException;
import org.springframework.stereotype.Component;

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

@WebService(serviceName = "receiverService", // 與接口中指定的name一致
        targetNamespace = "http://service.demo.test.com", // 與接口中的命名空間一致,一般是接口的包名倒序排
        endpointInterface = "com.test.demo.service.IDataReceiverService"// 接口地址
)
@Slf4j
@Component
public class DataReceiverServiceImpl implements IDataReceiverService {

    /**
     * 接收數據接口
     *
     * @param receiveMsg 數據
     * @return
     */
    @Override
    public String getReceiveMsg(ReceiveMsg receiveMsg) {

        //解析報文，轉化為需要寫成文件的數據
        UploadData uploadData = new UploadData();
        String dataId = receiveMsg.getDATAID();
        uploadData.setDataId(dataId);
        //是否加密 （1 表示業務數據為密文傳輸，0 表示明文）
        int sec = Convert.toInt(receiveMsg.getSEC());
        uploadData.setHavePwd(sec);

        //數據為明文時
        if (1 == sec) {
            //解碼業務報文
            try {
                //獲取解密后的業務數據
                String data = ReceiveMsgUtil.decodeStr(receiveMsg.getBUSINESSCONTENT());
                List<Map<String, Object>> list = ReceiveMsgUtil.xmlToList(data);
                log.info("數據為list：{}", list);
                uploadData.setBusinessData(list);
                if (CollUtil.isEmpty(list)) {
                    return ResultMsg.getMessage(ResultMsg.BUSINESS_DATA_ANALYZE_ERROR);
                }
            } catch (DocumentException e) {
                log.info("xml數據格式不正確！", e);
                return ResultMsg.getMessage(ResultMsg.XML_ERROR);
            } catch (Exception e) {
                log.info("base64解碼錯!", e);
                return ResultMsg.getMessage(ResultMsg.BASE64_ERROR);
            }
        }

        return ResultMsg.getMessage(ResultMsg.SUCCESS);
//        return uploadData.getReplyData();
    }

}

server:
  port: 6689
spring:
  application:
    name: cxfDemo
#  profiles:
#    active: dev
cxf:
  path: /soap #默認services

 

 第四步：啟動項目，查看wsdl說明書

 這里面的路徑注意cxf在web中的配置：

 

 

參數說明：

@WebService：在接口上申明，表示該接口是一個webService服務；
@WebMethod：在接口方法上聲明，表示該方法是一個webService服務方法；

@WebService(endpointInterface="cn.linc.cxf.interfaces.ServiceUI",serviceName="userService")：在該接口實現類定義；

endpointInterface：表示接口服務終端接口名；
serviceName:服務名稱；
wsdl解讀：有五個節點：服務視圖，服務協議和參數的描述，服務實現，參數描述，參數類型描述。

 

調用展示：

 

 

 

原理解析：
　　可以分為三個角色：服務提供者，服務消費者，服務注冊中心uddi
　　首先由服務提供者發布服務並且在注冊中心uddi進行注冊
　　然后由服務消費者訂閱服務，在注冊中心uddi上查詢到符合條件的服務
　　服務注冊中心返回服務條件服務的描述文件給服務訂閱者
　　訂閱者根據描述文件進行服務端的服務調用，並返回數據。

 

工具：

加解密：https://tool.oschina.net/encrypt

soapUI:https://www.soapui.org/downloads/soapui/

 

 

參考：

https://blog.csdn.net/qiaodaima0/article/details/100765613

https://www.cnblogs.com/xiechenglin/p/10500558.html

https://www.cnblogs.com/shuaijie/articles/5913750.html