Spring Integration 6.4.0

扩展 Spring 编程模型以支持众所周知的企业集成模式。Spring 集成在基于 Spring 的应用程序内支持轻量级消息传递，并支持通过声明式适配器与外部系统集成。这些适配器提供了比 Spring 对远程处理、消息传递和调度的支持更高级别的抽象。Spring 集成的主要目标是提供一个简单的模型来构建企业集成解决方案，同时保持关注点分离，这对于生成可维护、可测试的代码至关重要。

介绍

使用 Spring 框架鼓励开发人员使用接口进行编码，并使用依赖关系注入 （DI） 为普通旧 Java 对象 （POJO） 提供执行其任务所需的依赖关系。Spring 集成将这个概念更进一步，其中 POJO 使用消息传递范式连接在一起，并且单个组件可能不知道应用程序中的其他组件。这样的应用程序是通过组装细粒度的可重用组件来构建更高级别的功能。通过精心设计，这些流程可以模块化，也可以在更高的级别上重用。

除了将细粒度组件连接在一起之外， Spring 集成还提供了多种通道适配器和网关来与外部系统进行通信。通道适配器用于单向集成（发送或接收）;网关用于请求/回复场景（入站或出站）。有关适配器和网关的完整列表，请参阅参考文档。

Spring Cloud Stream 项目基于 Spring 集成构建，其中 Spring 集成用作消息驱动微服务的引擎。

特征

• 大多数 Enterprise Integration Patterns 的实现

• 端点

• 频道 （点对点和发布/订阅）

• 聚合

• 滤波器

• 变压器

• 控制总线

• …

• 与外部系统集成

• ReST/HTTP 协议

• FTP/SFTP 端口

• 踩

• Web服务（SOAP 和 RESTful）

• TCP/UDP 协议

• JMS 公司

• RabbitMQ 函数

• 电子邮件

• …

• 该框架具有广泛的 JMX 支持

• 将框架组件公开为 MBean

• 用于从 MBean 获取属性、调用操作、发送/接收通知的适配器

例子

在下面的 “quick start” 应用程序中，您可以看到同一个网关接口被用来调用两个完全不同的服务实现。要构建和运行此程序，您将需要如上所述的spring-integration-ws和spring-integration-xml模块。

public class Main {

	public static void main(String... args) throws Exception {
		ApplicationContext ctx =
			new ClassPathXmlApplicationContext("context.xml");
		// Simple Service
		TempConverter converter =
			ctx.getBean("simpleGateway", TempConverter.class);
		System.out.println(converter.fahrenheitToCelcius(68.0f));
		// Web Service
		converter  = ctx.getBean("wsGateway", TempConverter.class);
		System.out.println(converter.fahrenheitToCelcius(68.0f));
	}
}

public interface TempConverter {

	float fahrenheitToCelcius(float fahren);

}

<!-- Simple Service -->

<int:gateway id="simpleGateway"
	service-interface="foo.TempConverter"
	default-request-channel="simpleExpression" />

<int:service-activator id="expressionConverter"
	input-channel="simpleExpression"
	expression="(payload - 32) / 9 * 5"/>

<!-- Web Service -->

<int:gateway id="wsGateway" service-interface="foo.TempConverter"
	default-request-channel="viaWebService" />

<int:chain id="wsChain" input-channel="viaWebService">
	<int:transformer
	   expression="'&lt;FahrenheitToCelsius xmlns=&quot;https://www.w3schools.com/xml/&quot;&gt;&lt;Fahrenheit&gt;XXX&lt;/Fahrenheit&gt;&lt;/FahrenheitToCelsius&gt;'.replace('XXX', payload.toString())" />
	<int-ws:header-enricher>
		<int-ws:soap-action value="https://www.w3schools.com/xml/FahrenheitToCelsius"/>
	</int-ws:header-enricher>
	<int-ws:outbound-gateway
		uri="https://www.w3schools.com/xml/tempconvert.asmx"/>
	<int-xml:xpath-transformer
		xpath-expression="/*[local-name()='FahrenheitToCelsiusResponse']/*[local-name()='FahrenheitToCelsiusResult']"/>
</int:chain>

这是使用 Java DSL（和 Spring Boot）的相同应用程序（Web 服务部分）。如果您不使用 Spring Boot，您将直接需要 spring-boot-starter-integration 依赖项或 spring-integration-core：

@SpringBootApplication
public class Application {

  public static void main(String[] args) {
    ConfigurableApplicationContext ctx = SpringApplication.run(Application.class, args);
    TempConverter converter = ctx.getBean(TempConverter.class);
    System.out.println(converter.fahrenheitToCelcius(68.0f));
    ctx.close();
  }

  @MessagingGateway
  public interface TempConverter {

    @Gateway(requestChannel = "convert.input")
    float fahrenheitToCelcius(float fahren);

  }

  @Bean
  public IntegrationFlow convert() {
      return f -> f
        .transform(payload ->
              "<FahrenheitToCelsius xmlns=\"https://www.w3schools.com/xml/\">"
            +     "<Fahrenheit>" + payload + "</Fahrenheit>"
            + "</FahrenheitToCelsius>")
        .enrichHeaders(h -> h
            .header(WebServiceHeaders.SOAP_ACTION,
                "https://www.w3schools.com/xml/FahrenheitToCelsius"))
        .handle(new SimpleWebServiceOutboundGateway(
            "https://www.w3schools.com/xml/tempconvert.asmx"))
        .transform(Transformers.xpath("/*[local-name()=\"FahrenheitToCelsiusResponse\"]"
            + "/*[local-name()=\"FahrenheitToCelsiusResult\"]"));
  }

}