java - 如何通过Spring Integration连接SOAP服务器和JSON客户端？

Question

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

Controller :

@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 解码到域模型时，Spring WS 框架会触发您的 CityEndpoint.getCityResponse() 。根本就没有关于 Spring Integration 的任何内容。

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

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