咨询：基于WebFlux从WSDL文件生成Reactive WebClients的工具

推荐的Maven插件及实现方式 #

Apache CXF Codegen Plugin（首选） #

Apache CXF原生支持生成适配WebFlux的响应式SOAP客户端，通过指定reactive参数即可生成返回Mono/Flux类型的客户端代码，完全契合WebFlux的响应式编程模型。

Maven配置示例

<plugin>
    <groupId>org.apache.cxf</groupId>
    <artifactId>cxf-codegen-plugin</artifactId>
    <version>3.6.2</version> <!-- 使用最新稳定版本 -->
    <executions>
        <execution>
            <id>generate-soap-reactive-client</id>
            <phase>generate-sources</phase>
            <goals>
                <goal>wsdl2java</goal>
            </goals>
            <configuration>
                <wsdlOptions>
                    <wsdlOption>
                        <wsdl>${project.basedir}/src/main/resources/your-service.wsdl</wsdl>
                        <extraargs>
                            <extraarg>-fe</extraarg>
                            <extraarg>reactive</extraarg> <!-- 开启响应式客户端生成 -->
                            <extraarg>-client</extraarg> <!-- 生成客户端类 -->
                            <extraarg>-p</extraarg>
                            <extraarg>com.your.package.soap.client</extraarg> <!-- 指定生成代码的包路径 -->
                        </extraargs>
                    </wsdlOption>
                </wsdlOptions>
            </configuration>
        </execution>
    </executions>
    <dependencies>
        <!-- 依赖CXF响应式客户端模块及WebFlux -->
        <dependency>
            <groupId>org.apache.cxf</groupId>
            <artifactId>cxf-rt-reactive-client</artifactId>
            <version>3.6.2</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-webflux</artifactId>
            <version>3.1.2</version> <!-- 匹配你的Spring Boot版本 -->
        </dependency>
    </dependencies>
</plugin>

执行mvn generate-sources后，插件会自动生成响应式客户端接口及实现类，直接注入Spring容器即可使用。

自定义封装方案（灵活适配） #

如果需要更自定义的逻辑，可以先生成SOAP模型，再基于WebFlux的WebClient手动封装响应式调用：

1. 用JAXB生成SOAP数据模型

<plugin>
    <groupId>org.codehaus.mojo</groupId>
    <artifactId>jaxb2-maven-plugin</artifactId>
    <version>2.5.0</version>
    <executions>
        <execution>
            <id>generate-soap-models</id>
            <goals>
                <goal>xjc</goal>
            </goals>
        </execution>
    </executions>
    <configuration>
        <schemaDirectory>${project.basedir}/src/main/resources</schemaDirectory>
        <schemaFiles>your-service.xsd</schemaFiles> <!-- 可直接用WSDL路径替代XSD -->
        <outputDirectory>${project.build.directory}/generated-sources/jaxb</outputDirectory>
        <packageName>com.your.package.soap.model</packageName>
    </configuration>
</plugin>

2. 基于WebClient封装响应式客户端

@Service
public class CustomSoapReactiveClient {
    private final WebClient webClient;
    private final Jaxb2Marshaller marshaller;

    public CustomSoapReactiveClient(WebClient.Builder webClientBuilder, Jaxb2Marshaller marshaller) {
        this.webClient = webClientBuilder.baseUrl("https://your-soap-service-endpoint").build();
        this.marshaller = marshaller;
    }

    public Mono<YourResponseType> invokeSoapOperation(YourRequestType request) {
        return webClient.post()
                .contentType(MediaType.TEXT_XML)
                .body(BodyInserters.fromValue(serializeRequest(request)))
                .retrieve()
                .bodyToMono(String.class)
                .map(this::deserializeResponse);
    }

    private String serializeRequest(YourRequestType request) {
        StringWriter writer = new StringWriter();
        try {
            marshaller.marshal(request, new StreamResult(writer));
        } catch (XmlMappingException e) {
            throw new RuntimeException("序列化SOAP请求失败", e);
        }
        return writer.toString();
    }

    private YourResponseType deserializeResponse(String xmlResponse) {
        try {
            return (YourResponseType) marshaller.unmarshal(new StreamSource(new StringReader(xmlResponse)));
        } catch (XmlMappingException e) {
            throw new RuntimeException("反序列化SOAP响应失败", e);
        }
    }
}

关键注意事项 #

• 确保Spring Boot与CXF版本兼容，避免依赖冲突
• 若WSDL包含多端口或自定义绑定，需在插件配置中补充对应参数
• 生成的响应式客户端默认依赖Reactor，与WebFlux生态无缝衔接
• 测试时需注意处理SOAP Header、命名空间等细节

内容的提问来源于stack exchange，提问作者SilverLuke