<!-- CXF webservice -->
<dependency>
    <groupId>org.apache.cxf</groupId>
    <artifactId>cxf-spring-boot-starter-jaxws</artifactId>
    <version>3.4.5</version>
</dependency>

@Data
@Builder
public class UserDto {
    private Long id;
    private String name;
    private Integer age;
    private String address;
}

public interface IUserServer {
     UserDto getUser(Long str)；
}

@Service
@WebService
public class UserServerImpl implements IUserServer {

    @Override
    public UserDto getUser(Long id) {
        return UserDto.builder()
                .id(id)
                .address("上海市浦東新區(qū)")
                .age(25)
                .name("laJi").build();
    }
}

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE})
public @interface WebService {
    String name() default "";

    String targetNamespace() default "";

    String serviceName() default "";

    String portName() default "";

    String wsdlLocation() default "";

    String endpointInterface() default "";
}

@Configuration
@RequiredArgsConstructor
public class CxfConfig {
    private final IUserServer userServer;

    /**
     * 注入Servlet，注意beanName不能為dispatcherServlet
     * @author Fang Ruichuan
     * @date 2022/11/14 19:16
     */
    @Bean
    public ServletRegistrationBean cxfServlet() {
        return new ServletRegistrationBean(new CXFServlet(), "/webservice/*");
    }

    @Bean(name = Bus.DEFAULT_BUS_ID)
    public SpringBus springBus() {
        return new SpringBus();
    }

    @Bean
    public Endpoint endpoint() {
        EndpointImpl endpoint = new EndpointImpl(springBus(), userServer);
        endpoint.publish("/api");
        return endpoint;
    }
}

public class WebserviceClient {
    public static void main(String[] args) {
        JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
        Client client = dcf.createClient("http://localhost:8080/webservice/api?wsdl");
        final ObjectMapper mapper = new ObjectMapper();
        try {
            Object[] objects = client.invoke("getUser", 99L);
            System.out.println(mapper.writeValueAsString(objects[0]));
        } catch (Exception e) {
            e.printStackTrace();;
        }
    }
}

{"address":"上海市浦東新區(qū)","age":25,"id":99,"name":"laJi"}

/**
 * WebService涉及到的有這些 "四解三類 ", 即四個注解，三個類
 * @WebMethod
 * @WebService
 * @WebResult
 * @WebParam
 * SpringBus
 * Endpoint
 * EndpointImpl
 *
 * 一般我們都會寫一個接口，然后再寫一個實(shí)現(xiàn)接口的實(shí)現(xiàn)類，但是這不是強(qiáng)制性的
 * @WebService 注解表明是一個webservice服務(wù)。
 *      name：對外發(fā)布的服務(wù)名, 對應(yīng)于<wsdl:portType name="ServerServiceDemo"></wsdl:portType>
 *      targetNamespace：命名空間,一般是接口的包名倒序, 實(shí)現(xiàn)類與接口類的這個配置一定要一致這種錯誤
 *              Exception in thread "main" org.apache.cxf.common.i18n.UncheckedException: No operation was found with the name xxxx
 *              對應(yīng)于targetNamespace="http://server.webservice.example.com"
 *      endpointInterface：服務(wù)接口全路徑（如果是沒有接口，直接寫實(shí)現(xiàn)類的，該屬性不用配置）, 指定做SEI（Service EndPoint Interface）服務(wù)端點(diǎn)接口
 *      serviceName：對應(yīng)于<wsdl:service name="ServerServiceDemoImplService"></wsdl:service>
 *      portName：對應(yīng)于<wsdl:port binding="tns:ServerServiceDemoImplServiceSoapBinding" name="ServerServiceDemoPort"></wsdl:port>
 *
 * @WebMethod 表示暴露的服務(wù)方法, 這里有接口ServerServiceDemo存在，在接口方法已加上@WebMethod, 所以在實(shí)現(xiàn)類中不用再加上，否則就要加上
 *      operationName: 接口的方法名
 *      action: 沒發(fā)現(xiàn)又什么用處
 *      exclude: 默認(rèn)是false, 用于阻止將某一繼承方法公開為web服務(wù)
 *
 * @WebResult 表示方法的返回值
 *      name：返回值的名稱
 *      partName：
 *      targetNamespace:
 *      header: 默認(rèn)是false, 是否將參數(shù)放到頭信息中，用于保護(hù)參數(shù)，默認(rèn)在body中
 *
 * @WebParam
 *       name：接口的參數(shù)
 *       partName：
 *       targetNamespace:
 *       header: 默認(rèn)是false, 是否將參數(shù)放到頭信息中，用于保護(hù)參數(shù)，默認(rèn)在body中
 *       model：WebParam.Mode.IN/OUT/INOUT
 */

@WebService(name = "UserSSSS" ,targetNamespace ="http://data.fucker.mother.com")
public interface UserService {
        
        User getUser(String userName);
}

@Service
@WebService(name = "UserSSSS" ,
            targetNamespace ="http://data.fucker.mother.com",
            endpointInterface = "com.mother.fucker.data.service.UserService")
public class UserServerImpl implements UserService {
    
    @Override
    @WebMethod(operationName = "getUser")
    @WebResult(name = "User")
    public User getUser(@WebParam(name = "userName") String userName) {
        return new User("姓名","年齡","性別","工作");
    }
}

import lombok.extern.slf4j.Slf4j;
import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.binding.soap.saaj.SAAJInInterceptor;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.springframework.stereotype.Component;
import org.w3c.dom.NodeList;

import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPMessage;

@Component
@Slf4j
public class WebServiceAuthInterceptor extends AbstractPhaseInterceptor<SoapMessage> {

    /**
     * 用戶名
     */
    private static final String USER_NAME = "wangdi";
    /**
     * 密碼
     */
    private static final String USER_PASSWORD = "wangdi.com";
    private static final String NAME_SPACE_URI = "http://data.fucker.mother.com";
    /**
     * 創(chuàng)建攔截器
     */
    private SAAJInInterceptor interceptor = new SAAJInInterceptor();

    public WebServiceAuthInterceptor() {
        super(Phase.PRE_PROTOCOL);
        //添加攔截
        super.getAfter().add(SAAJInInterceptor.class.getName());
    }

    @Override
    public void handleMessage(SoapMessage message) throws Fault {
        //獲取指定消息
        SOAPMessage soapMessage = message.getContent(SOAPMessage.class);
        if (null == soapMessage) {
            this.interceptor.handleMessage(message);
            soapMessage = message.getContent(SOAPMessage.class);
        }
        //SOAP頭信息
        SOAPHeader header = null;
        try {
            header = soapMessage.getSOAPHeader();
        } catch (SOAPException e) {
            e.printStackTrace();
        }
        if (null == header) {
            throw new Fault(new IllegalAccessException("沒有Header信息，無法實(shí)現(xiàn)用戶認(rèn)證處理!"));
        }
        //SOAP是基于XML文件結(jié)構(gòu)進(jìn)行傳輸?shù)?，所以如果要想獲取認(rèn)證信息就必須進(jìn)行相關(guān)的結(jié)構(gòu)約定
        NodeList usernameNodeList = header.getElementsByTagNameNS(NAME_SPACE_URI, "username");
        NodeList passwordNodeList = header.getElementsByTagNameNS(NAME_SPACE_URI, "password");
        if (usernameNodeList.getLength() < 1) {
            throw new Fault(new IllegalAccessException("沒有用戶信息，無法實(shí)現(xiàn)用戶認(rèn)證處理!"));
        }
        if (passwordNodeList.getLength() < 1) {
            throw new Fault(new IllegalAccessException("沒有密碼信息，無法實(shí)現(xiàn)用戶認(rèn)證處理!"));
        }
        String username = usernameNodeList.item(0).getTextContent().trim();
        String password = passwordNodeList.item(0).getTextContent().trim();
        if (USER_NAME.equals(username) && USER_PASSWORD.equals(password)) {
            log.info("用戶訪問認(rèn)證成功!");
        } else {
            SOAPException soapException = new SOAPException("用戶認(rèn)證失敗!");
            log.info("用戶認(rèn)證失敗!");
            throw new Fault(soapException);
        }
    }
}

import com.mother.fucker.data.AuthInterceptor.WebServiceAuthInterceptor;
import com.mother.fucker.data.service.UserService;
import lombok.RequiredArgsConstructor;
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.beans.factory.annotation.Autowired;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.xml.ws.Endpoint;

@Configuration
@RequiredArgsConstructor
public class CxfConfig {
    private final UserService userServer;

    @Autowired
    private WebServiceAuthInterceptor interceptor;
    /**
     * 注入Servlet，注意beanName不能為dispatcherServlet
     * @author Fang Ruichuan
     * @date 2022/11/14 19:16
     */
    @Bean
    public ServletRegistrationBean cxfServlet() {
        return new ServletRegistrationBean(new CXFServlet(), "/webservice/*");
    }

    @Bean(name = Bus.DEFAULT_BUS_ID)
    public SpringBus springBus() {
        return new SpringBus();
    }

    @Bean
    public Endpoint endpoint() {
        EndpointImpl endpoint = new EndpointImpl(springBus(), userServer);
        endpoint.publish("/api");
        endpoint.getInInterceptors().add(this.interceptor);
        return endpoint;
    }

    /*用于發(fā)布多個WebService*/
//    @Bean
//    public Endpoint messageEndPoint2() {
//        EndpointImpl endpoint = new EndpointImpl(springBus(), this.ageInfoService);
//        endpoint.publish("/userInfoService");
        endpoint.getInInterceptors().add(this.interceptor);
//        return endpoint;
//    }

}

import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.helpers.DOMUtils;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.apache.cxf.headers.Header;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import javax.xml.namespace.QName;
import java.util.List;

public class ClientLoginInterceptor extends AbstractPhaseInterceptor<SoapMessage> {

    private String username;
    private String password;
    private static final String NAME_SPACE_URI = "http://data.fucker.mother.com";

    public ClientLoginInterceptor(String username, String password) {
        super(Phase.PREPARE_SEND);
        this.username = username;
        this.password = password;
    }

    @Override
    public void handleMessage(SoapMessage soapMessage) throws Fault {
        List<Header> headers = soapMessage.getHeaders();
        Document document = DOMUtils.createDocument();
        Element authority = document.createElementNS(NAME_SPACE_URI, "authority");
        Element username = document.createElementNS(NAME_SPACE_URI, "username");
        Element password = document.createElementNS(NAME_SPACE_URI, "password");
        username.setTextContent(this.username);
        password.setTextContent(this.password);
        authority.appendChild(username);
        authority.appendChild(password);
        headers.add(0, new Header(new QName("authority"), authority));
    }
}

    /**
     * 用戶名
     */
    private static final String USER_NAME = "wangdi";
    /**
     * 密碼
     */
    private static final String USER_PASSWORD = "wangdi.com";
    private static final String NAME_SPACE_URI = "http://server.webservice.gtp.sinotrans.com";


    public static void main(String[] args) {
        
        //打印日志
        LoggerContext loggerContext = (LoggerContext) LoggerFactory.getILoggerFactory();
        List<Logger> loggerList = loggerContext.getLoggerList();
        loggerList.forEach(logger -> {logger.setLevel(Level.INFO);    });


        JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
        Client client = dcf.createClient("http://localhost:8001/webservice/api?wsdl");
        try {
            client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME, USER_PASSWORD));
            Object[] objects = client.invoke("getUser","aaa");
            System.out.println(JSON.toJSONString(objects[0]));
        } catch (Exception e) {
            e.printStackTrace();;
        }

    }

    @Override
    @WebMethod(operationName = "getUser")
    public User getUser(@WebParam(name = "userName") User userName) {
        return new User("姓名","年齡","性別","工作");
    }

        //打印日志
//        LoggerContext loggerContext = (LoggerContext) LoggerFactory.getILoggerFactory();
//        List<Logger> loggerList = loggerContext.getLoggerList();
//        loggerList.forEach(logger -> {logger.setLevel(Level.INFO);    });
        
        JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
        Client client = dcf.createClient("http://localhost:1001/webservice/api?wsdl");
        try {

            //通過反射，創(chuàng)建OrderInfo對象，com.limp.service.OrderInfo 這個包名稱必須和webservice的中的order路徑一致
            Object user = Thread.currentThread().getContextClassLoader().
                    loadClass("com.mother.fucker.data.User").newInstance();

            //初始化實(shí)體對象
            Method m = user.getClass().getMethod("setName", String.class);

            m.invoke(user, "uuid213-281heq-2131");

            Object[] objects = client.invoke("getUser",user);
            System.out.println(JSON.toJSONString(objects[0]));
        } catch (Exception e) {
            e.printStackTrace();;
        }