我的编程空间,编程开发者的网络收藏夹
学习永远不晚

Spring Integration概述与怎么使用详解

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

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使用内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

Spring Integration概述与怎么使用详解

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

Spring Integration概述与怎么使用详解

公司项目需要用到springintegration,而网上关于springintegration的有价值的参考资料比较少,下面这篇文章主要给大家介绍了关于Spring Integration概述与怎么使用的相关资料,需要的朋友可以参考下
2023-02-24

如何使用Spring integration在Springboot中集成Mqtt详解

MQTT是多个客户端通过一个中央服务器传递信息的多对多协议,能高效地将信息分发给一个或多个订阅者,下面这篇文章主要给大家介绍了关于如何使用Spring integration在Springboot中集成Mqtt的相关资料,需要的朋友可以参考下
2023-02-24

怎么使用Spring integration在Springboot中集成Mqtt

今天小编给大家分享一下怎么使用Spring integration在Springboot中集成Mqtt的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考一下,希望大家阅读完这篇文章后有所收获,下
2023-07-05

spring kafka @KafkaListener详解与使用过程

这篇文章主要介绍了spring-kafka @KafkaListener详解与使用,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2023-02-20

详解C#中委托的概念与使用

委托这个名字取的神乎其神的,但实质是函数式编程,把函数作为参数传递给另一个参数。这篇文章主要为大家介绍一下C#中委托的概念与使用,需要的可以参考一下
2023-02-27

详解Spring的@Value作用与使用场景

这篇文章主要介绍了详解Spring的@Value作用与使用场景,Spring为大家提供许多开箱即用的功能,@Value就是一个极其常用的功能,它能将配置信息注入到bean中去,需要的朋友可以参考下
2023-05-19

一文详解Spring AOP的配置与使用

面向切面编程(俗称AOP)提供了一种面向对象编程(俗称OOP)的补充,面向对象编程最核心的单元是类(class),然而面向切面编程最核心的单元是切面(Aspects)。本文就来和大家聊聊AOP的配置与使用,感兴趣的可以了解一下
2022-11-13

详解redis与spring的整合(使用缓存)

1、实现目标通过redis缓存数据。(目的不是加快查询的速度,而是减少数据库的负担)  2、所需jar包注意:jdies和commons-pool两个jar的版本是有对应关系的,注意引入jar包是要配对使用,否则将会报错。因为commons
2023-05-31

spring的异步执行使用与源码详解

这篇文章主要介绍了spring的异步执行使用与源码详解,Spring中通过在方法上设置@Async注解,可使得方法被异步调用,需要的朋友可以参考下
2023-05-20

Java锁擦除与锁粗化概念和使用详解

这篇文章主要介绍了Java锁擦除与锁粗化概念和使用,锁擦除的主要判定依据来源于逃逸分析的数据支持,如果判断在一段代码中,堆上的所有数据都不会逃逸出去从而被其他线程访问到,那就可以把它们当做栈上数据对待,认为它们是线程私有的,同步加锁自然就无须进行
2023-02-13

Redis怎么与Spring结合使用

这期内容当中小编将会给大家带来有关Redis怎么与Spring结合使用,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。Spring-data-redis是spring大家族的一部分,提供了在srping应用
2023-05-31

spring怎么与struts结合使用

这期内容当中小编将会给大家带来有关spring怎么与struts结合使用,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。Struts调用流程如下图所示。 看到这幅图一下子就能了解了strut
2023-05-31

Mybatis怎么与Spring结合使用

Mybatis怎么与Spring结合使用?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。所需要用到的其他工具或技术:项目管理工具 : Maven前台WEB展示:JSP其他框架:S
2023-05-31

Spring底层架构核心概念Environment怎么使用

这篇“Spring底层架构核心概念Environment怎么使用”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看看这篇“Spring底
2023-07-04

编程热搜

  • Python 学习之路 - Python
    一、安装Python34Windows在Python官网(https://www.python.org/downloads/)下载安装包并安装。Python的默认安装路径是:C:\Python34配置环境变量:【右键计算机】--》【属性】-
    Python 学习之路 - Python
  • chatgpt的中文全称是什么
    chatgpt的中文全称是生成型预训练变换模型。ChatGPT是什么ChatGPT是美国人工智能研究实验室OpenAI开发的一种全新聊天机器人模型,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,并协助人类完成一系列
    chatgpt的中文全称是什么
  • C/C++中extern函数使用详解
  • C/C++可变参数的使用
    可变参数的使用方法远远不止以下几种,不过在C,C++中使用可变参数时要小心,在使用printf()等函数时传入的参数个数一定不能比前面的格式化字符串中的’%’符号个数少,否则会产生访问越界,运气不好的话还会导致程序崩溃
    C/C++可变参数的使用
  • css样式文件该放在哪里
  • php中数组下标必须是连续的吗
  • Python 3 教程
    Python 3 教程 Python 的 3.0 版本,常被称为 Python 3000,或简称 Py3k。相对于 Python 的早期版本,这是一个较大的升级。为了不带入过多的累赘,Python 3.0 在设计的时候没有考虑向下兼容。 Python
    Python 3 教程
  • Python pip包管理
    一、前言    在Python中, 安装第三方模块是通过 setuptools 这个工具完成的。 Python有两个封装了 setuptools的包管理工具: easy_install  和  pip , 目前官方推荐使用 pip。    
    Python pip包管理
  • ubuntu如何重新编译内核
  • 改善Java代码之慎用java动态编译

目录