当前位置:主页 > java教程 > Spring Integration使用

Spring Integration概述与怎么使用详解

发布:2023-03-25 10:15:02 59


为找教程的网友们整理了相关的编程文章,网友鄂映易根据主题投稿了本篇教程内容,涉及到Spring、integration、教程、spring、integration入门、Spring、integration、Spring Integration使用相关内容,已被987网友关注,涉猎到的知识点内容可以在下方电子书获得。

Spring Integration使用

一、Spring Integration是什么?

spring-integration是一个功能强大的EIP(Enterprise Integration Patterns),即企业集成模式。多个系统或者功能,少不了消息交互 ,Spring intergration的出现解决了系统与系统之间的功能之间消息交互的问题。

二、为什么要用Spring Integration?

目标和原则

Spring集成的动机是以下目标:

  • 为实现复杂的企业集成解决方案提供一个简单的模型。

  • 在基于Spring的应用程序中促进异步、消息驱动的行为。

促进对现有Spring用户的直观、增量采用。

Spring集成遵循以下原则:

  • 为了模块化和可测试性,组件应该是松散耦合的。

  • 框架应该执行业务逻辑和集成逻辑之间的关注点分离。

  • 扩展点在本质上应该是抽象的(但在定义良好的边界内),以促进重用和可移植性。

三、怎么使用

我们首先看一下它的核心api

1. Message

Message,用来传输消息体的对象,所有的流程都围绕着Message运转。Message分为两部分,header和payload。header是头部信息通常用来保存如Id,时间戳,相关Id和返回地址等信息。payload是用来装载数据的,它可以携带的任何类型对象。

2.MessageChannel

消息通道表示管道和过滤器体系结构的“管道”。生产者向通道发送消息,消费者从通道接收消息。因此,消息通道对消息传递组件进行了解耦,并提供了一个方便的点来拦截和监视消息。

(1)MessageChannel顶级接口

public interface MessageChannel {
boolean send(Message message);
boolean send(Message message, long timeout);
}

发送消息时,返回值是true消息发送成功。如果发送呼叫超时或被中断,它将返回false

(2)PollableChannel,MessageChannel的子接口

public interface PollableChannel extends MessageChannel {
    Message<?> receive();
    Message<?> receive(long timeout);
}

此消息通道会缓存消息(可轮询),与send方法一样,当接收到消息时,如果发生超时或中断,则返回值为null。

(3)SubscribableChannel,MessageChannel的子接口

public interface SubscribableChannel extends MessageChannel {
    boolean subscribe(MessageHandler handler);
    boolean unsubscribe(MessageHandler handler);
}

因为SubscribableChannel基本接口是由将消息直接发送到其订阅的频道实施MessageHandler的实例,因此消息通道不会缓存消息。

3.Message Endpoint

(1)Message Router

 路由器,用来管理一个消息应该被发送到哪个channel中。相当于JAVA里面的switch case语句吧。判断条件很多,可是使用header里面的参数具体值(比如header里面有个定义为testRouter的参数,数值为A,那么消息经过路由会发送到判断为A的通道内,后面使用中再详细讲解)

(2)Message Filter

过滤器,用来判断一个消息是否应该被传输。

(3)Service Activator

服务激活器是用于将服务实例连接到消息传递系统的通用端点。必须配置输入消息通道,并且,如果要调用的服务方法能够返回值,则还可以提供输出消息通道。

(4)Message Transformer

消息转换器负责转换消息的内容或结构并返回修改后的消息。可能最常见的一种转换器是将消息的有效负载从一种格式转换为另一种格式(例如,从XML转换为java.lang.String)的一种。同样,转换器可以添加,删除或修改消息的标头值。

(5) Channel Adapter

通道适配器是将消息通道连接到其他系统或传输的终结点。通道适配器可以是入站的或出站的。通常,通道适配器在消息与从其他系统接收或发送到其他系统的任何对象或资源(文件,HTTP请求,JMS消息等)之间进行一些映射。根据传输情况,通道适配器还可以填充或提取消息头值。

入站通道适配器端点将源系统连接到MessageChannel

出站通道适配器端点将a连接MessageChannel到目标系统。

总结

到此这篇关于Spring Integration概述与怎么使用的文章就介绍到这了,更多相关Spring Integration使用内容请搜索码农之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持码农之家!


参考资料

相关文章

  • SpringBoot实现优雅停机的正确方法

    发布:2023-04-21

    什么叫优雅停机?就是向应用进程发出停止指令之后,能保证正在执行的业务操作不受影响,直到操作运行完毕之后再停止服务。本文就来和大家聊聊SpringBoot实现优雅停机的正确姿势,希望对大家有所帮助


  • SpringBoot2零基础到精通之自动配置底层分析及小技巧

    SpringBoot2零基础到精通之自动配置底层分析及小技巧

    发布:2022-10-21

    给网友们整理关于SpringBoot的教程,SpringBoot是一种整合Spring技术栈的方式(或者说是框架),同时也是简化Spring的一种快速开发的脚手架,本篇让我们一起学习自动配置的底层分析与一些开发中的小技巧


  • Springboot项目平滑关闭及自动化关闭脚本详解

    发布:2020-02-04

    这篇文章主要为大家详细介绍了Springboot项目平滑关闭及自动化关闭脚本,具有一定的参考价值,感兴趣的小伙伴们可以参考一下


  • SpringBoot使用统一异常处理实例讲解

    发布:2019-08-11

    这篇文章主要为大家详细介绍了SpringBoot使用统一异常处理,具有一定的参考价值,感兴趣的小伙伴们可以参考一下


  • Spring IOC与DI核心深入理解

    发布:2023-03-30

    IOC也是Spring的核心之一了,之前学的时候是采用xml配置文件的方式去实现的,后来其中也多少穿插了几个注解,但是没有说完全采用注解实现。那么这篇文章就和大家分享一下,全部采用注解来实现IOC+DI


  • python3.8.3安装教程及环境配置的详细教程(64-bit)

    python3.8.3安装教程及环境配置的详细教程(64-bit)

    发布:2022-06-17

    给网友朋友们带来一篇关于python3的教程,这篇文章主要介绍了python3.8.3安装教程及环境配置的详细教程(64-bit),本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下


  • Python调试神器之PySnooper的使用教程分享

    发布:2023-04-21

    对于每个程序开发者来说,调试几乎是必备技能。本文小编就来给大家介绍一款非常好用的调试工具,它能在一些场景下,大幅度提高调试的效率, 那就是 PySnooper,希望大家喜欢


  • 解析Spring Boot实例通过接口安全退出

    发布:2020-03-17

    这篇文章主要介绍了Spring Boot 实例代码之通过接口安全退出的相关资料,需要的朋友可以参考下


网友讨论