集成图控制器

如果您的应用程序是基于 Web 的(或构建在带有嵌入式 Web 容器的 Spring Boot 之上),并且 Spring Integration HTTP 或 WebFlux 模块(分别参见HTTP 支持WebFlux 支持)存在于类路径上,则可以使用IntegrationGraphControllerIntegrationGraphServer功能作为 REST 服务公开。为此,@EnableIntegrationGraphController@Configuration类注解以及<int-http:graph-controller/>XML 元素在 HTTP 模块中可用。结合@EnableWebMvc注解(或用于 XML 定义的<mvc:annotation-driven/>),此配置注册了一个IntegrationGraphController @RestController,其@RequestMapping.path可以在@EnableIntegrationGraphController注解或<int-http:graph-controller/>元素上配置。默认路径为/integration

IntegrationGraphController @RestController提供以下服务

  • @GetMapping(name = "getGraph"):检索自上次IntegrationGraphServer刷新以来 Spring Integration 组件的状态。o.s.i.support.management.graph.Graph作为 REST 服务的@ResponseBody返回。

  • @GetMapping(path = "/refresh", name = "refreshGraph"):刷新当前Graph以获取实际运行时状态并将其作为 REST 响应返回。无需为指标刷新图形。在检索图形时实时提供它们。如果自上次检索图形以来已修改应用程序上下文,则可以调用刷新。在这种情况下,图形将完全重建。

您可以使用 Spring Security 和 Spring MVC 项目提供的标准配置选项和组件为IntegrationGraphController设置安全和跨源限制。以下示例实现了这些目标

<mvc:annotation-driven />

<mvc:cors>
	<mvc:mapping path="/myIntegration/**"
				 allowed-origins="https://127.0.0.1:9090"
				 allowed-methods="GET" />
</mvc:cors>

<security:http>
    <security:intercept-url pattern="/myIntegration/**" access="ROLE_ADMIN" />
</security:http>


<int-http:graph-controller path="/myIntegration" />

以下示例显示了如何使用 Java 配置执行相同的操作

@Configuration
@EnableWebMvc // or @EnableWebFlux
@EnableWebSecurity // or @EnableWebFluxSecurity
@EnableIntegration
@EnableIntegrationGraphController(path = "/testIntegration", allowedOrigins="https://127.0.0.1:9090")
public class IntegrationConfiguration extends WebSecurityConfigurerAdapter {

    @Override
    protected void configure(HttpSecurity http) throws Exception {
	    http
            .authorizeRequests()
               .antMatchers("/testIntegration/**").hasRole("ADMIN")
            // ...
            .formLogin();
    }

    //...

}

请注意,为了方便起见,@EnableIntegrationGraphController注解提供了allowedOrigins属性。这为path提供了GET访问权限。为了获得更复杂的功能,您可以使用标准的 Spring MVC 机制配置 CORS 映射。