如何通过 Spring 集成连接 SOAP 服务器和 JSON 客户端

Question

美好的一天。我是春季集成的新手。我编写了一个简单的 SOAP 服务器，我需要连接一个通过 JSON 通信的客户端和一个通过 SOAP 通信的服务器，但我对这个框架提供的技术感到困惑。据我了解，有JsonToObjectTransformer和ObjectToMapTransformer。据我了解，有必要在将数据传输到控制器之前对其进行转换。是否可以在变压器的帮助下做到这一点，或者我可以在弹簧集成中使用其他技术。这只能在DSL的帮助下完成吗？

控制器：

@Endpoint
public class CityEndpoint {
    private static final String NAMESPACE_URI = "http://weather.com/senchenko";
    private CityRepository cityRepository;
    @Autowired
    public CityEndpoint(CityRepository cityRepository) {
        this.cityRepository = cityRepository;
    }
    @PayloadRoot(namespace = NAMESPACE_URI, localPart = "getCityRequest")
    @ResponsePayload
    public GetCityResponse getCityResponse(@RequestPayload GetCityRequest request){
        GetCityResponse response = new GetCityResponse();
        response.setCity(cityRepository.findCity(request.getName()));
        return response;
    }
}

配置：

@EnableWs
@Configuration
public class WebServiceConfig extends WsConfigurerAdapter {
    @Bean
    public ServletRegistrationBean messageDispatcherServlet(ApplicationContext applicationContext) {
        MessageDispatcherServlet servlet = new MessageDispatcherServlet();
        servlet.setApplicationContext(applicationContext);
        servlet.setTransformWsdlLocations(true);
        return new ServletRegistrationBean(servlet, "/ws/*");
    }
    @Bean(name = "city")
    public DefaultWsdl11Definition defaultWsdl11Definition(XsdSchema citySchema) {
        DefaultWsdl11Definition wsdl11Definition = new DefaultWsdl11Definition();
        wsdl11Definition.setPortTypeName("CityPort");
        wsdl11Definition.setLocationUri("/ws");
        wsdl11Definition.setTargetNamespace("http://weather.com/senchenko");
        wsdl11Definition.setSchema(citySchema);
        return wsdl11Definition;
    }
    @Bean
    public XsdSchema citySchema() {
        return new SimpleXsdSchema(new ClassPathResource("xsd/weather.xsd"));
    }
    @Bean
    @Transformer()
    JsonToObjectTransformer jsonToObjectTransformer() {
        return new JsonToObjectTransformer();
    }
    @Bean
    @Transformer()
    ObjectToMapTransformer objectToMapTransformer(){
        return new ObjectToMapTransformer();
    }
}

加法

我解决了重定向到 SOAP 的问题，但仍然不知道将 JSON 转换为 SOAP 信封并返回的最佳方法。

@Bean
    public IntegrationFlow httpProxyFlow() {
        return IntegrationFlows
                .from(Http.inboundGateway("/service"))
                .transform(t -> TEST_ENVOLOPE)
                .enrichHeaders(h -> h.header("Content-Type", "text/xml; charset=utf-8"))
                .handle(Http.outboundGateway("http://localhost:8080/ws")
                        .expectedResponseType(String.class))
                .transform(t -> TEST_RESPONSE)
                .get();
    }

Answer 1

您的问题不清楚，或者您不完全熟悉工作所需的技术。SOAP 完全是关于 XML 消息交换的。在服务器端，您有一个特定的MessageDispatcherServlet，它将传入的HTTP请求完全转换为XML中的SOAP信封。根本没有关于JSON的内容。

当传入的 SOAP 请求根据 XSD 定义和生成的模型通过 JaxB 从 XML 解组到域模型中时，您的CityEndpoint.getCityResponse()由 Spring WS 框架触发。根本没有关于Spring Integration的内容。

在这种情况下，您的JsonToObjectTransformer和ObjectToMapTransformer没有任何意义。它们不参与 SOAP 请求过程。

很抱歉让我的回答让您失望，但您的问题甚至不清楚当 JSON 和 XML 完全不同且不兼容的协议时，JSON 客户端将如何调用 SOAP 服务。