发布于 2017-11-02 00:20:59 | 135 次阅读 | 评论: 0 | 来源: 网友投递
Spring Integration Spring消息通信
Spring Integration能在基于Spring的应用中进行简单的消息通信，并通过简单的适配器与外部系统集成。这些适配器提供了一个更高级别的抽象，超越 了Spring对远程调用、消息和调度的支持。其主要目标是在保持关注点分离的同时，为构建企业集成解决方案提供一个简单的模型，该模型对产出可维护、可 测试的代码来说是必不可少的。
Spring Integration 5.0 rc1 发布了。
该版本包含 20 处的改进和修复，主页更新内容如下：
Java DSL 解析器填充的组件现在在应用程序上下文中注册为 BeanDefinitions
IntegrationFlows.from(Class<?> serviceInterface) 现在使用附加的 beanName 参数重载版本
@Bean public IntegrationFlow uppercaseFlow() { return IntegrationFlows.from(MessageFunction.class, "uppercase") .<String, String>transform(String::toUpperCase) .get(); }
HTTP 入站端点（包括WebFlux）现在可以正确处理回复消息中的 ResponseEntity：
@Bean public WebFluxInboundEndpoint errorInboundEndpoint() { WebFluxInboundEndpoint endpoint = new WebFluxInboundEndpoint(); RequestMapping requestMapping = new RequestMapping(); requestMapping.setPathPatterns("/error"); endpoint.setRequestMapping(requestMapping); endpoint.setRequestChannelName("errorServiceChannel"); return endpoint; } @ServiceActivator(inputChannel = "errorServiceChannel") public ResponseEntity<String> processHttpRequest() { return new ResponseEntity<>("<500 Internal Server Error,{}>", HttpStatus.INTERNAL_SERVER_ERROR); }
详细更新内容请查看发行日志。