Skip to content

Spring 中文文档社区
Spring 中文文档社区

tianxingzijian / Spring 中文文档社区
与 Fork 源项目一致

Fork自 开发云 / Spring 中文文档社区

通知 1
Star 1
Fork 0
Spring 中文文档社区
Spring 中文文档社区

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

切换分支/标签
查找文件 普通视图历史永久链接Permalink
500.10c0ee69.js 68.0 KB
Newer Older
茶陵後's avatar
#1 添加本地编译文件  
茶陵後 已提交
1 
(window.webpackJsonp=window.webpackJsonp||[]).push([[500],{935:function(e,t,a){"use strict";a.r(t);var n=a(56),r=Object(n.a)({},(function(){var e=this,t=e.$createElement,a=e._self._c||t;return a("ContentSlotsDistributor",{attrs:{"slot-key":e.$parent.slotKey}},[a("h1",{attrs:{id:"系统管理"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#系统管理"}},[e._v("#")]),e._v(" 系统管理")]),e._v(" "),a("h2",{attrs:{id:"系统管理-2"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#系统管理-2"}},[e._v("#")]),e._v(" 系统管理")]),e._v(" "),a("h3",{attrs:{id:"指标和管理"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#指标和管理"}},[e._v("#")]),e._v(" 指标和管理")]),e._v(" "),a("p",[e._v("本节描述如何捕获 Spring 集成的指标。在最近的版本中，我们更多地依赖于 Micrometer（参见"),a("a",{attrs:{href:"https://micrometer.io",target:"_blank",rel:"noopener noreferrer"}},[e._v("https://micrometer.io"),a("OutboundLink")],1),e._v("），并且我们计划在未来的版本中更多地使用 Micrometer。")]),e._v(" "),a("h4",{attrs:{id:"遗留指标"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#遗留指标"}},[e._v("#")]),e._v(" 遗留指标")]),e._v(" "),a("p",[e._v("旧的度量标准在版本 5.4 中被删除；请参见下面的 Micrometer 集成。")]),e._v(" "),a("h4",{attrs:{id:"在大容量环境中禁用日志记录"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#在大容量环境中禁用日志记录"}},[e._v("#")]),e._v(" 在大容量环境中禁用日志记录")]),e._v(" "),a("p",[e._v("你可以在主消息流中控制调试日志记录。在非常大容量的应用程序中，对"),a("code",[e._v("isDebugEnabled()")]),e._v("的调用在一些日志记录子系统中可能非常昂贵。你可以禁用所有这样的日志记录，以避免这种开销。异常日志记录（调试或其他方式）不受此设置的影响。")]),e._v(" "),a("p",[e._v("下面的清单显示了用于控制日志记录的可用选项：")]),e._v(" "),a("p",[e._v("爪哇")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('@Configuration\n@EnableIntegration\n@EnableIntegrationManagement(\n    defaultLoggingEnabled = "true" <1>)\n\npublic static class ContextConfiguration {\n...\n}\n')])])]),a("p",[e._v("XML")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:management default-logging-enabled="true"/> (1)\n')])])]),a("table",[a("thead",[a("tr",[a("th",[a("strong",[e._v("1")])]),e._v(" "),a("th",[e._v("设置为"),a("code",[e._v("false")]),e._v("以禁用主消息流中的所有日志记录，无论日志系统的类别设置如何。"),a("br"),e._v("设置为“true”，以启用调试日志记录（如果还启用了日志记录子系统）。"),a("br"),e._v("仅当你没有在 Bean 定义中显式配置该设置时才应用。"),a("br"),e._v("默认值为"),a("code",[e._v("true")]),e._v("。")])])]),e._v(" "),a("tbody")]),e._v(" "),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[a("code",[e._v("defaultLoggingEnabled")]),e._v("仅在未在 Bean 定义中显式配置相应设置的情况下才应用。")])])]),e._v(" "),a("tbody")]),e._v(" "),a("h4",{attrs:{id:"千分尺积分"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#千分尺积分"}},[e._v("#")]),e._v(" 千分尺积分")]),e._v(" "),a("h5",{attrs:{id:"概述"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#概述"}},[e._v("#")]),e._v(" 概述")]),e._v(" "),a("p",[e._v("从版本 5.0.3 开始，在应用程序上下文中出现"),a("a",{attrs:{href:"https://micrometer.io/",target:"_blank",rel:"noopener noreferrer"}},[e._v("Micrometer"),a("OutboundLink")],1),a("code",[e._v("MeterRegistry")]),e._v("会触发对千分尺指标的支持。")]),e._v(" "),a("p",[e._v("要使用 Micrometer，将"),a("code",[e._v("MeterRegistry")]),e._v("bean 中的一个添加到应用程序上下文中。")]),e._v(" "),a("p",[e._v("对于每个"),a("code",[e._v("MessageH和ler")]),e._v("和"),a("code",[e._v("MessageChannel")]),e._v("，计时器被注册。对于每个"),a("code",[e._v("MessageSource")]),e._v("，注册一个计数器。")]),e._v(" "),a("p",[e._v("这仅适用于扩展"),a("code",[e._v("AbstractMessageHandler")]),e._v("、"),a("code",[e._v("AbstractMessageChannel")]),e._v("和"),a("code",[e._v("AbstractMessageSource")]),e._v("的对象（大多数框架组件都是这种情况）。")]),e._v(" "),a("p",[e._v("用于在消息通道上进行发送操作的"),a("code",[e._v("Timer")]),e._v("计具有以下名称或标记：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("name")]),e._v(": "),a("code",[e._v("spring.integration.send")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("type:channel")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("name:<componentName>")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("result:(success|failure)")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("exception:(none|exception simple class name)")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("description")]),e._v(": "),a("code",[e._v("Send processing time")])])])]),e._v(" "),a("p",[e._v("（带有"),a("code",[e._v("none")]),e._v("异常的"),a("code",[e._v("failure")]),e._v("结果表示通道的"),a("code",[e._v("send()")]),e._v("操作返回"),a("code",[e._v("false")]),e._v("。")]),e._v(" "),a("p",[e._v("用于在可匹配消息通道上进行接收操作的"),a("code",[e._v("Counter")]),e._v("计具有以下名称或标记：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("name")]),e._v(": "),a("code",[e._v("spring.integration.receive")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("type:channel")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("name:<componentName>")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("result:(success|failure)")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("exception:(none|exception simple class name)")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("description")]),e._v(": "),a("code",[e._v("Messages received")])])])]),e._v(" "),a("p",[e._v("用于消息处理程序上的操作的"),a("code",[e._v("Timer")]),e._v("表具有以下名称或标记：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("name")]),e._v(": "),a("code",[e._v("spring.integration.send")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("type:handler")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("name:<componentName>")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("result:(success|failure)")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("exception:(none|exception simple class name)")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("description")]),e._v(": "),a("code",[e._v("Send processing time")])])])]),e._v(" "),a("p",[e._v("消息源的"),a("code",[e._v("Counter")]),e._v("表具有以下名称/标记：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("name")]),e._v(": "),a("code",[e._v("spring.integration.receive")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("type:source")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("name:<componentName>")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("result:success")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("exception:none")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("description")]),e._v(": "),a("code",[e._v("Messages received")])])])]),e._v(" "),a("p",[e._v("此外，还有三个"),a("code",[e._v("Gauge")]),e._v("米：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("spring.integration.channels")]),e._v(":应用程序中"),a("code",[e._v("MessageChannels")]),e._v("的数量。")])]),e._v(" "),a("li",[a("p",[a("code",[e._v("spring.integration.handlers")]),e._v(":应用程序中"),a("code",[e._v("MessageHandlers")]),e._v("的数量。")])]),e._v(" "),a("li",[a("p",[a("code",[e._v("spring.integration.sources")]),e._v(":应用程序中"),a("code",[e._v("MessageSources")]),e._v("的数量。")])])]),e._v(" "),a("p",[e._v("通过提供"),a("code",[e._v("MicrometerMetricsCaptor")]),e._v("的子类，可以定制由集成组件创建的"),a("code",[e._v("Meters")]),e._v("的名称和标记。"),a("a",{attrs:{href:"https://github.com/spring-projects/spring-integration/blob/main/spring-integration-core/src/test/java/org/springframework/integration/support/management/micrometer/MicrometerCustomMetricsTests.java",target:"_blank",rel:"noopener noreferrer"}},[e._v("MicroMeterCustomMetricstests"),a("OutboundLink")],1),e._v("测试用例展示了如何实现这一点的一个简单示例。你还可以通过在 Builder 子类上重载"),a("code",[e._v("build()")]),e._v("方法来进一步自定义仪表。")]),e._v(" "),a("p",[e._v("从版本 5.1.13 开始，"),a("code",[e._v("QueueChannel")]),e._v("公开了用于队列大小和剩余容量的千分尺：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("name")]),e._v(": "),a("code",[e._v("spring.integration.channel.queue.size")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("type:channel")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("name:<componentName>")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("description")]),e._v(": "),a("code",[e._v("The size of the queue channel")])])])]),e._v(" "),a("p",[e._v("and")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("name")]),e._v(": "),a("code",[e._v("spring.integration.channel.queue.remaining.capacity")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("type:channel")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("tag")]),e._v(": "),a("code",[e._v("name:<componentName>")])])]),e._v(" "),a("li",[a("p",[a("code",[e._v("description")]),e._v(": "),a("code",[e._v("The remaining capacity of the queue channel")])])])]),e._v(" "),a("h5",{attrs:{id:"禁用仪表"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#禁用仪表"}},[e._v("#")]),e._v(" 禁用仪表")]),e._v(" "),a("p",[e._v("使用"),a("a",{attrs:{href:"#legacy-metrics"}},[e._v("遗留指标")]),e._v("（现已删除），你可以指定哪些集成组件将收集度量。默认情况下，所有仪表都是在首次使用时注册的。现在，使用 Micrometer，可以将"),a("code",[e._v("MeterFilter")]),e._v("s 添加到"),a("code",[e._v("MeterRegistry")]),e._v("中，以防止部分或全部被注册。你可以通过提供的任何属性（"),a("code",[e._v("name")]),e._v("、"),a("code",[e._v("tag")]),e._v("等）过滤掉（拒绝）表。有关更多信息，请参见千分尺文档中的"),a("a",{attrs:{href:"https://micrometer.io/docs/concepts#_meter_filters",target:"_blank",rel:"noopener noreferrer"}},[e._v("仪表过滤器"),a("OutboundLink")],1),e._v("。")]),e._v(" "),a("p",[e._v("例如，给出：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("@Bean\npublic QueueChannel noMeters() {\n    return new QueueChannel(10);\n}\n")])])]),a("p",[e._v("你可以通过以下方式抑制仅此频道的仪表注册：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('registry.config().meterFilter(MeterFilter.deny(id ->\n        "channel".equals(id.getTag("type")) &&\n        "noMeters".equals(id.getTag("name"))));\n')])])]),a("h4",{attrs:{id:"spring-集成-jmx-支持"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#spring-集成-jmx-支持"}},[e._v("#")]),e._v(" Spring 集成 JMX 支持")]),e._v(" "),a("p",[e._v("另见"),a("RouterLink",{attrs:{to:"/spring-integration/jmx.html#jmx"}},[e._v("JMX 支持")]),e._v("。")],1),e._v(" "),a("h3",{attrs:{id:"消息历史记录"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#消息历史记录"}},[e._v("#")]),e._v(" 消息历史记录")]),e._v(" "),a("p",[e._v("消息传递体系结构的主要好处是松耦合，这样参与的组件就不会对彼此保持任何意识。仅这一点就使应用程序变得非常灵活，允许你在不影响流的其余部分的情况下更改组件、更改消息传递路径、更改消息消费风格（轮询与事件驱动），等等。然而，当情况出现问题时，这种低调的建筑风格可能会变得很困难。在调试时，你可能需要尽可能多的有关消息的信息（消息的来源、经过的通道和其他详细信息）。")]),e._v(" "),a("p",[e._v("消息历史是一种模式，它可以帮助你选择保持对消息路径的某种级别的了解，用于调试目的或维护审计跟踪。 Spring 集成提供了一种简单的方式来配置消息流，以维护消息历史记录，方法是在消息中添加一个头，并在每次消息通过被跟踪的组件时更新该头。")]),e._v(" "),a("h4",{attrs:{id:"消息历史配置"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#消息历史配置"}},[e._v("#")]),e._v(" 消息历史配置")]),e._v(" "),a("p",[e._v("要启用消息历史记录，只需要在配置中定义"),a("code",[e._v("message-history")]),e._v("元素（或"),a("code",[e._v("@EnableMessageHistory")]),e._v("），如以下示例所示：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("@Configuration\n@EnableIntegration\n@EnableMessageHistory\n")])])]),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("<int:message-history/>\n")])])]),a("p",[e._v("现在，每个已命名的组件（定义了“ID”的组件）都会被跟踪。该框架在你的消息中设置“历史”头。其值 a"),a("code",[e._v("List<Properties>")]),e._v("。")]),e._v(" "),a("p",[e._v("考虑以下配置示例：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('@MessagingGateway(defaultRequestChannel = "bridgeInChannel")\npublic interface SampleGateway {\n   ...\n}\n\n@Bean\n@Transformer(inputChannel = "enricherChannel", outputChannel="filterChannel")\nHeaderEnricher sampleEnricher() {\n    HeaderEnricher enricher =\n           new HeaderEnricher(Collections.singletonMap("baz", new StaticHeaderValueMessageProcessor("baz")));\n    return enricher;\n}\n')])])]),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:gateway id="sampleGateway"\n    service-interface="org.springframework.integration.history.sample.SampleGateway"\n    default-request-channel="bridgeInChannel"/>\n\n<int:header-enricher id="sampleEnricher" input-channel="enricherChannel" output-channel="filterChannel">\n    <int:header name="baz" value="baz"/>\n</int:header-enricher>\n')])])]),a("p",[e._v("前面的配置生成一个简单的消息历史结构，其输出类似于以下内容：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("[{name=sampleGateway, type=gateway, timestamp=1283281668091},\n {name=sampleEnricher, type=header-enricher, timestamp=1283281668094}]\n")])])]),a("p",[e._v("要访问消息历史记录，只需访问"),a("code",[e._v("MessageHistory")]),e._v("头。下面的示例展示了如何做到这一点：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('Iterator<Properties> historyIterator =\n    message.getHeaders().get(MessageHistory.HEADER_NAME, MessageHistory.class).iterator();\nassertTrue(historyIterator.hasNext());\nProperties gatewayHistory = historyIterator.next();\nassertEquals("sampleGateway", gatewayHistory.get("name"));\nassertTrue(historyIterator.hasNext());\nProperties chainHistory = historyIterator.next();\nassertEquals("sampleChain", chainHistory.get("name"));\n')])])]),a("p",[e._v("你可能不想跟踪所有的组件。要根据组件的名称将历史限制为某些组件，可以提供"),a("code",[e._v("tracked-components")]),e._v("属性，并指定一个以逗号分隔的组件名称和模式列表，该列表与要跟踪的组件相匹配。下面的示例展示了如何做到这一点：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('@Configuration\n@EnableIntegration\n@EnableMessageHistory("*Gateway", "sample*", "aName")\n')])])]),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:message-history tracked-components="*Gateway, sample*, aName"/>\n')])])]),a("p",[e._v("在前面的示例中，仅对以“gateway”结尾、以“sample”开头或与名称“aname”完全匹配的组件维护消息历史记录。")]),e._v(" "),a("p",[e._v("此外，"),a("code",[e._v("MessageHistoryConfigurer")]),e._v(" Bean 现在被"),a("code",[e._v("IntegrationMBeanExporter")]),e._v("公开为 JMX MBean（参见"),a("RouterLink",{attrs:{to:"/spring-integration/jmx.html#jmx-mbean-exporter"}},[e._v("MBean 出口商")]),e._v("），允许你在运行时更改模式。但是，请注意，为了更改模式，必须停止 Bean（关闭消息历史记录）。这个特性对于临时打开历史记录来分析系统可能是有用的。MBean 的对象名是"),a("code",[e._v("<domain>:name=messageHistoryConfigurer,type=MessageHistoryConfigurer")]),e._v("。")],1),e._v(" "),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[e._v("只有一个"),a("code",[e._v("@EnableMessageHistory")]),e._v("（或"),a("code",[e._v("<message-history/>")]),e._v("）必须在应用程序上下文中声明为组件跟踪配置的单个源。"),a("br"),e._v("不要为"),a("code",[e._v("MessageHistoryConfigurer")]),e._v("使用通用的 Bean 定义。")])])]),e._v(" "),a("tbody")]),e._v(" "),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[e._v("根据定义，消息历史记录头是不可变的（不能重写历史记录），因此，在编写消息历史记录值时，组件要么创建新消息（当组件是源消息时），要么从请求消息中复制历史记录，修改它并在回复消息上设置新的列表。"),a("br"),e._v("在这两种情况下，即使消息本身跨越了线程边界，也可以追加这些值。"),a("br"),e._v("这意味着历史值可以大大简化异步消息流中的调试。")])])]),e._v(" "),a("tbody")]),e._v(" "),a("h3",{attrs:{id:"消息存储"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#消息存储"}},[e._v("#")]),e._v(" 消息存储")]),e._v(" "),a("p",[a("a",{attrs:{href:"https://www.enterpriseintegrationpatterns.com/",target:"_blank",rel:"noopener noreferrer"}},[e._v("*Enterprise 整合模式 *"),a("OutboundLink")],1),e._v("书标识了几种具有缓冲消息能力的模式。例如，聚合器缓冲消息直到可以释放消息，而"),a("code",[e._v("QueueChannel")]),e._v("缓冲消息直到消费者明确地从该通道接收这些消息。由于消息流中的任何一点都可能发生故障，缓冲消息的 EIP 组件还引入了消息可能丢失的点。")]),e._v(" "),a("p",[e._v("为了减少丢失消息的风险，EIP 定义了"),a("a",{attrs:{href:"https://www.enterpriseintegrationpatterns.com/MessageStore.html",target:"_blank",rel:"noopener noreferrer"}},[e._v("消息存储"),a("OutboundLink")],1),e._v("模式，该模式允许 EIP 组件存储消息，通常是在某种类型的持久性存储（例如 RDBMS）中。")]),e._v(" "),a("p",[e._v("Spring 集成通过以下方式提供对消息存储模式的支持：")]),e._v(" "),a("ul",[a("li",[a("p",[e._v("定义"),a("code",[e._v("org.springframework.integration.store.MessageStore")]),e._v("策略接口")])]),e._v(" "),a("li",[a("p",[e._v("提供此接口的几种实现方式")])]),e._v(" "),a("li",[a("p",[e._v("在所有具有缓冲消息功能的组件上公开"),a("code",[e._v("message-store")]),e._v("属性，以便你可以插入实现"),a("code",[e._v("MessageStore")]),e._v("接口的任何实例。")])])]),e._v(" "),a("p",[e._v("有关如何配置特定消息存储实现以及如何将"),a("code",[e._v("MessageStore")]),e._v("实现注入特定缓冲组件的详细信息在整个手册中进行了描述（请参阅特定组件，例如"),a("RouterLink",{attrs:{to:"/spring-integration/channel.html#channel-configuration-queuechannel"}},[e._v("Queuechannel")]),e._v("，"),a("RouterLink",{attrs:{to:"/spring-integration/aggregator.html#aggregator"}},[e._v("Aggregator")]),e._v("，"),a("RouterLink",{attrs:{to:"/spring-integration/delayer.html#delayer"}},[e._v("Delayer")]),e._v("等）。以下两个示例展示了如何为"),a("code",[e._v("QueueChannel")]),e._v("和聚合器向消息存储区添加引用：")],1),e._v(" "),a("p",[e._v("例1.Queuechannel")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:channel id="myQueueChannel">\n    <int:queue message-store="refToMessageStore"/>\n<int:channel>\n')])])]),a("p",[e._v("例2.聚合器")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:aggregator … message-store="refToMessageStore"/>\n')])])]),a("p",[e._v("默认情况下，消息通过使用"),a("code",[e._v("o.s.i.store.SimpleMessageStore")]),e._v("存储在内存中，这是"),a("code",[e._v("MessageStore")]),e._v("的一种实现。对于开发环境或简单的低容量环境来说，这可能是很好的，在这些环境中，潜在的非持久性消息丢失不是一个问题。然而，典型的生产应用程序需要一个更健壮的选项，不仅要减轻消息丢失的风险，还要避免潜在的内存不足错误。因此，我们还为各种数据存储提供"),a("code",[e._v("MessageStore")]),e._v("实现。以下是受支持的实现的完整列表：")]),e._v(" "),a("ul",[a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/jdbc.html#jdbc-message-store"}},[e._v("JDBC 消息存储")]),e._v(":使用 RDBMS 存储消息")],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/redis.html#redis-message-store"}},[e._v("Redis 消息存储")]),e._v(":使用 Redis 键/值数据存储来存储消息")],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/mongodb.html#mongodb-message-store"}},[e._v("MongoDB 消息存储")]),e._v(":使用 MongoDB 文档存储来存储消息")],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/gemfire.html#gemfire-message-store"}},[e._v("Gemfire 消息存储")]),e._v(":使用 Gemfire 分布式缓存存储消息")],1)])]),e._v(" "),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[e._v("但是，在使用"),a("code",[e._v("MessageStore")]),e._v("的持久实现时要注意一些限制。"),a("br"),a("br"),e._v("消息数据（有效载荷和报头）通过使用不同的序列化策略进行序列化和反序列化，这取决于"),a("code",[e._v("MessageStore")]),e._v("的实现方式。"),a("br"),e._v("例如，当使用"),a("code",[e._v("JdbcMessageStore")]),e._v("时，默认情况下，只有"),a("code",[e._v("Serializable")]),e._v("数据是持久的。"),a("br"),e._v("在这种情况下，在进行序列化之前，要删除不可序列化的标头。"),a("br"),e._v("此外，要注意传输适配器（例如 FTP、HTTP、JMS 和其他）注入的特定于协议的标头。"),a("br"),e._v("例如，"),a("code",[e._v("<http:inbound-channel-adapter/>")]),e._v("将 HTTP 标头映射到消息标头，其中之一是一个"),a("code",[e._v("ArrayList")]),e._v("的不可序列化"),a("code",[e._v("org.springframework.http.MediaType")]),e._v("实例。你可以将你自己的"),a("code",[e._v("Serializer")]),e._v("和"),a("code",[e._v("Deserializer")]),e._v("策略接口的实现注入到一些"),a("code",[e._v("MessageStore")]),e._v("实现中（例如"),a("code",[e._v("JdbcMessageStore")]),e._v("），以改变序列化和反序列化的行为。"),a("br"),a("br"),e._v("特别注意表示某些类型数据的头。"),a("br"),e._v("例如，如果其中一个头包含某个 Spring  Bean 的实例，那么在反序列化时，你可能会得到另一个 Bean 的实例，这将直接影响框架创建的一些隐式头（例如"),a("code",[e._v("REPLY_CHANNEL")]),e._v("或"),a("code",[e._v("ERROR_CHANNEL")]),e._v("）。，"),a("br"),e._v("目前，它们不能序列化，但是，即使它们是，反序列化的通道也不会表示预期的实例。"),a("br"),a("br"),e._v("从 Spring Integration3.0 开始，你可以使用配置为在用"),a("code",[e._v("HeaderChannelRegistry")]),e._v("注册通道后用名称替换这些头的 header 来解决此问题，"),a("br"),a("br"),e._v("同样，考虑一下，当你按照以下方式配置消息流时会发生什么：网关队列通道（由持久性消息存储支持）服务激活器，"),a("br"),e._v("该网关创建了一个临时回复通道，当服务激活器的 poller 从队列中读取消息时，该通道会丢失。，再次，<gtr=“217”/，你可以使用 header enricher 用"),a("code",[e._v("String")]),e._v("表示替换 header。"),a("br"),a("br"),e._v("有关更多信息，请参见"),a("RouterLink",{attrs:{to:"/spring-integration/content-enrichment.html#header-enricher"}},[e._v("页眉 Enricher")]),e._v("。")],1)])]),e._v(" "),a("tbody")]),e._v(" "),a("p",[e._v("Spring Integration4.0 引入了两个新的接口：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("ChannelMessageStore")]),e._v(":实现针对"),a("code",[e._v("QueueChannel")]),e._v("实例的特定操作")])]),e._v(" "),a("li",[a("p",[a("code",[e._v("PriorityCapableChannelMessageStore")]),e._v(":标记用于"),a("code",[e._v("MessageStore")]),e._v("实例的"),a("code",[e._v("PriorityChannel")]),e._v("实现，并为持久消息提供优先顺序。")])])]),e._v(" "),a("p",[e._v("真正的行为取决于执行情况。该框架提供了以下实现方式，它们可以用作"),a("code",[e._v("MessageStore")]),e._v("和"),a("code",[e._v("PriorityChannel")]),e._v("的持久性"),a("code",[e._v("MessageStore")]),e._v(":")]),e._v(" "),a("ul",[a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/redis.html#redis-cms"}},[e._v("Redis Channel 消息存储")])],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/mongodb.html#mongodb-priority-channel-message-store"}},[e._v("MongoDB 通道消息存储")])],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/jdbc.html#jdbc-message-store-channels"}},[e._v("支持消息通道")])],1)])]),e._v(" "),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[e._v("注意"),a("code",[e._v("SimpleMessageStore")]),a("br"),a("br"),e._v("从版本 4.1 开始，在调用"),a("code",[e._v("SimpleMessageStore")]),e._v("时，"),a("code",[e._v("SimpleMessageStore")]),e._v("不再复制消息组。对于大型消息组，"),a("br"),e._v("，这是一个重要的性能问题。"),a("br"),e._v("4.0.1 引入了一个布尔"),a("code",[e._v("copyOnGet")]),e._v("属性，该属性允许你控制此行为，"),a("br"),e._v("当聚合器内部使用时，将此属性设置为"),a("code",[e._v("false")]),e._v("以提高性能。"),a("br"),e._v("默认情况下，它现在是"),a("code",[e._v("false")]),e._v("。"),a("br"),a("br"),e._v("在组件之外访问组存储的用户因为聚合器现在获得了对聚合器正在使用的组的直接引用，而不是一个副本。"),a("br"),e._v("聚合器之外的组的操作可能会导致不可预测的结果。"),a("br"),a("br"),e._v("由于这个原因，你不应该执行这样的操作，或者将"),a("code",[e._v("copyOnGet")]),e._v("属性设置为"),a("code",[e._v("true")]),e._v("。")])])]),e._v(" "),a("tbody")]),e._v(" "),a("h4",{attrs:{id:"使用messagegroupfactory"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#使用messagegroupfactory"}},[e._v("#")]),e._v(" 使用"),a("code",[e._v("MessageGroupFactory")])]),e._v(" "),a("p",[e._v("从版本 4.3 开始，一些"),a("code",[e._v("MessageGroupStore")]),e._v("实现可以被注入一个自定义"),a("code",[e._v("MessageGroupFactory")]),e._v("策略来创建和定制"),a("code",[e._v("MessageGroup")]),e._v("实例，该实例由"),a("code",[e._v("MessageGroupStore")]),e._v("使用。这默认为"),a("code",[e._v("SimpleMessageGroupFactory")]),e._v("，它基于"),a("code",[e._v("GroupType.HASH_SET")]),e._v("（"),a("code",[e._v("LinkedHashSet")]),e._v("）内部集合生成"),a("code",[e._v("SimpleMessageGroup")]),e._v("实例。其他可能的选项是"),a("code",[e._v("SYNCHRONISED_SET")]),e._v("和"),a("code",[e._v("BLOCKING_QUEUE")]),e._v("，其中最后一个选项可以用来恢复先前的"),a("code",[e._v("SimpleMessageGroup")]),e._v("行为。而且"),a("code",[e._v("PERSISTENT")]),e._v("选项也是可用的。有关更多信息，请参见下一节。从版本 5.0.1 开始，当组中消息的顺序和唯一性无关紧要时，"),a("code",[e._v("LIST")]),e._v("选项也可用。")]),e._v(" "),a("h4",{attrs:{id:"持久messagegroupstore和-lazy-load"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#持久messagegroupstore和-lazy-load"}},[e._v("#")]),e._v(" 持久"),a("code",[e._v("MessageGroupStore")]),e._v("和 lazy-load")]),e._v(" "),a("p",[e._v("从版本 4.3 开始，所有持久的"),a("code",[e._v("MessageGroupStore")]),e._v("实例都以延迟加载的方式从存储中检索"),a("code",[e._v("MessageGroup")]),e._v("实例及其"),a("code",[e._v("messages")]),e._v("实例。在大多数情况下，对于相关"),a("code",[e._v("MessageHandler")]),e._v("实例是有用的（参见"),a("RouterLink",{attrs:{to:"/spring-integration/aggregator.html#aggregator"}},[e._v("Aggregator")]),e._v("和"),a("RouterLink",{attrs:{to:"/spring-integration/resequencer.html#resequencer"}},[e._v("重测序器")]),e._v("），当它将增加开销以从存储中加载整个"),a("code",[e._v("MessageGroup")]),e._v("上的每个相关操作时。")],1),e._v(" "),a("p",[e._v("你可以使用"),a("code",[e._v("AbstractMessageGroupStore.setLazyLoadMessageGroups(false)")]),e._v("选项从配置中关闭惰性负载行为。")]),e._v(" "),a("p",[e._v("我们对 MongoDB"),a("code",[e._v("MessageStore")]),e._v("（"),a("RouterLink",{attrs:{to:"/spring-integration/mongodb.html#mongodb-message-store"}},[e._v("MongoDB 消息存储")]),e._v("）和"),a("code",[e._v("<aggregator>")]),e._v("（"),a("RouterLink",{attrs:{to:"/spring-integration/aggregator.html#aggregator"}},[e._v("Aggregator")]),e._v("）上的 lazy-load 进行的性能测试使用了一个自定义"),a("code",[e._v("release-strategy")]),e._v("，类似于以下内容：")],1),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:aggregator input-channel="inputChannel"\n                output-channel="outputChannel"\n                message-store="mongoStore"\n                release-strategy-expression="size() == 1000"/>\n')])])]),a("p",[e._v("它为 1000 条简单消息生成类似于以下结果的结果：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("...\nStopWatch 'Lazy-Load Performance': running time (millis) = 38918\n-----------------------------------------\nms     %     Task name\n-----------------------------------------\n02652  007%  Lazy-Load\n36266  093%  Eager\n...\n")])])]),a("p",[e._v("然而，从版本 5.5 开始，所有持久的"),a("code",[e._v("MessageGroupStore")]),e._v("实现都提供了基于目标数据库流 API 的"),a("code",[e._v("streamMessagesForGroup(Object groupId)")]),e._v("契约。当存储中的组非常大时，这将提高资源利用率。在框架内部，这个新的 API 在"),a("RouterLink",{attrs:{to:"/spring-integration/delayer.html#delayer"}},[e._v("Delayer")]),e._v("中使用（例如），当它重新安排启动时的持久化消息时。返回的"),a("code",[e._v("Stream<Message<?>>")]),e._v("必须在处理结束时关闭，例如通过"),a("code",[e._v("try-with-resources")]),e._v("自动关闭。每当使用"),a("code",[e._v("PersistentMessageGroup")]),e._v("时，将其"),a("code",[e._v("streamMessages()")]),e._v("委托给"),a("code",[e._v("MessageGroupStore.streamMessagesForGroup()")]),e._v("。")],1),e._v(" "),a("h4",{attrs:{id:"消息组条件"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#消息组条件"}},[e._v("#")]),e._v(" 消息组条件")]),e._v(" "),a("p",[e._v("从版本 5.5 开始，"),a("code",[e._v("MessageGroup")]),e._v("抽象提供了"),a("code",[e._v("condition")]),e._v("字符串选项。此选项的值可以是任何可以在稍后进行解析的内容，以便为组做出决定。例如，来自"),a("RouterLink",{attrs:{to:"/spring-integration/aggregator.html#aggregator-api"}},[e._v("相关消息处理程序")]),e._v("的"),a("code",[e._v("ReleaseStrategy")]),e._v("可能会从组中查询此属性，而不是迭代组中的所有消息。"),a("code",[e._v("MessageGroupStore")]),e._v("公开了"),a("code",[e._v("setGroupCondition(Object groupId, String condition)")]),e._v("API。为此，在"),a("code",[e._v("AbstractCorrelatingMessageHandler")]),e._v("中添加了"),a("code",[e._v("setGroupConditionSupplier(BiFunction<Message<?>, String, String>)")]),e._v("选项。此函数是在将每个消息添加到该组以及该组的现有条件之后，针对每个消息进行求值的。该实现可以决定返回一个新的值、现有的值，或者将目标条件重置为"),a("code",[e._v("null")]),e._v("。"),a("code",[e._v("condition")]),e._v("的值可以是 JSON、SPEL 表达式、数字或任何可以序列化为字符串并在之后进行解析的内容。例如，来自"),a("RouterLink",{attrs:{to:"/spring-integration/file.html#file-aggregator"}},[e._v("文件聚合器")]),e._v("组件的"),a("code",[e._v("FileMarkerReleaseStrategy")]),e._v("将一个条件从"),a("code",[e._v("FileHeaders.LINE_COUNT")]),e._v("消息的"),a("code",[e._v("FileSplitter.FileMarker.Mark.END")]),e._v("头中填充到一个组中，并从其"),a("code",[e._v("canRelease()")]),e._v("中与该组中的值进行比较，并与之进行协商。这样，它就不会迭代组中的所有消息来查找带有"),a("code",[e._v("FileHeaders.LINE_COUNT")]),e._v("头的"),a("code",[e._v("FileSplitter.FileMarker.Mark.END")]),e._v("消息。它还允许结束标记在所有其他记录之前到达聚合器；例如，在多线程环境中处理文件时。")],1),e._v(" "),a("p",[e._v("此外，为了方便配置，引入了"),a("code",[e._v("GroupConditionProvider")]),e._v("契约。"),a("code",[e._v("AbstractCorrelatingMessageHandler")]),e._v("检查所提供的"),a("code",[e._v("ReleaseStrategy")]),e._v("是否实现了该接口，并提取了用于组条件评估逻辑的"),a("code",[e._v("conditionSupplier")]),e._v("。")]),e._v(" "),a("h3",{attrs:{id:"元数据存储"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#元数据存储"}},[e._v("#")]),e._v(" 元数据存储")]),e._v(" "),a("p",[e._v("许多外部系统、服务或资源不是事务性的（Twitter、RSS、文件系统等），并且没有任何能力将数据标记为已读。此外，有时，你可能需要在一些集成解决方案中实现 Enterprise 集成模式"),a("a",{attrs:{href:"https://www.enterpriseintegrationpatterns.com/IdempotentReceiver.html",target:"_blank",rel:"noopener noreferrer"}},[e._v("幂等接收机"),a("OutboundLink")],1),e._v("。为了实现这一目标并在下一次与外部系统交互之前存储端点的一些先前状态或处理下一次消息， Spring 集成提供了元数据存储组件作为"),a("code",[e._v("org.springframework.integration.metadata.MetadataStore")]),e._v("接口的一种实现方式，具有一般的键值契约。")]),e._v(" "),a("p",[e._v("元数据存储旨在存储各种类型的通用元数据（例如，已处理的最后一个提要条目的发布日期），以帮助提要适配器等组件处理重复数据。如果组件没有直接提供对"),a("code",[e._v("MetadataStore")]),e._v("的引用，则用于定位元数据存储的算法如下：首先，在应用程序上下文中查找具有"),a("code",[e._v("metadataStore")]),e._v("ID 的 Bean。如果找到了，就使用它。否则，创建一个"),a("code",[e._v("SimpleMetadataStore")]),e._v("的新实例，这是一个内存中的实现，它只在当前运行的应用程序上下文的生命周期内持久化元数据。这意味着，在重新启动时，你可能会以重复的条目结束。")]),e._v(" "),a("p",[e._v("如果需要在应用程序上下文重新启动之间持久化元数据，则框架提供以下持久化"),a("code",[e._v("MetadataStores")]),e._v(":")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("PropertiesPersistingMetadataStore")])])]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/gemfire.html#gemfire-metadata-store"}},[e._v("Gemfire 元数据存储")])],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/jdbc.html#jdbc-metadata-store"}},[e._v("JDBC 元数据存储")])],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/mongodb.html#mongodb-metadata-store"}},[e._v("MongoDB 元数据存储")])],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/redis.html#redis-metadata-store"}},[e._v("Redis 元数据存储")])],1)]),e._v(" "),a("li",[a("p",[a("RouterLink",{attrs:{to:"/spring-integration/zookeeper.html#zk-metadata-store"}},[e._v("ZooKeeper 元数据存储")])],1)])]),e._v(" "),a("p",[a("code",[e._v("PropertiesPersistingMetadataStore")]),e._v("由一个属性文件和一个["),a("code",[e._v("PropertiesPersister")]),e._v("]（https://DOCS. Spring.io/ Spring/DOCS/current/javadoc-api/org/springframework/util/propertiespersister.html）支持。")]),e._v(" "),a("p",[e._v("默认情况下，它仅在应用程序上下文正常关闭时保持状态。它实现了"),a("code",[e._v("Flushable")]),e._v("，这样你就可以通过调用"),a("code",[e._v("flush()")]),e._v("随意地持久化状态。下面的示例展示了如何使用 XML 配置“PropertiesPersistingMetaDataStore”：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<bean id="metadataStore"\n    class="org.springframework.integration.metadata.PropertiesPersistingMetadataStore"/>\n')])])]),a("p",[e._v("或者，你可以提供你自己的"),a("code",[e._v("MetadataStore")]),e._v("接口的实现（例如，"),a("code",[e._v("JdbcMetadataStore")]),e._v("），并将其配置为应用程序上下文中的 Bean。")]),e._v(" "),a("p",[e._v("从版本 4.0 开始，"),a("code",[e._v("SimpleMetadataStore")]),e._v("，"),a("code",[e._v("PropertiesPersistingMetadataStore")]),e._v("，和"),a("code",[e._v("RedisMetadataStore")]),e._v("实现"),a("code",[e._v("ConcurrentMetadataStore")]),e._v("。它们提供了原子更新，并且可以跨多个组件或应用程序实例使用。")]),e._v(" "),a("h4",{attrs:{id:"幂等接收器和元数据存储"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#幂等接收器和元数据存储"}},[e._v("#")]),e._v(" 幂等接收器和元数据存储")]),e._v(" "),a("p",[e._v("当需要过滤已处理的传入消息时，元数据存储对于实现 EIP"),a("a",{attrs:{href:"https://www.enterpriseintegrationpatterns.com/IdempotentReceiver.html",target:"_blank",rel:"noopener noreferrer"}},[e._v("幂等接收机"),a("OutboundLink")],1),e._v("模式非常有用，并且可以丢弃它或在丢弃时执行其他逻辑。下面的配置展示了如何这样做的示例：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:filter input-channel="serviceChannel"\n\t\t\toutput-channel="idempotentServiceChannel"\n\t\t\tdiscard-channel="discardChannel"\n\t\t\texpression="@metadataStore.get(headers.businessKey) == null"/>\n\n<int:publish-subscribe-channel id="idempotentServiceChannel"/>\n\n<int:outbound-channel-adapter channel="idempotentServiceChannel"\n                              expression="@metadataStore.put(headers.businessKey, \'\')"/>\n\n<int:service-activator input-channel="idempotentServiceChannel" ref="service"/>\n')])])]),a("p",[e._v("幂等条目的"),a("code",[e._v("value")]),e._v("可能是一个到期日期，在此日期之后，某个预定的收割者应该将该条目从元数据存储中删除。")]),e._v(" "),a("p",[e._v("另见"),a("RouterLink",{attrs:{to:"/spring-integration/handler-advice.html#idempotent-receiver"}},[e._v("幂等接收机 Enterprise 集成模式")]),e._v("。")],1),e._v(" "),a("h4",{attrs:{id:"metadatastorelistener"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#metadatastorelistener"}},[e._v("#")]),e._v(" "),a("code",[e._v("MetadataStoreListener")])]),e._v(" "),a("p",[e._v("一些元数据存储（目前只有 ZooKeeper）支持注册侦听器，以便在项目更改时接收事件，如下例所示：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("public interface MetadataStoreListener {\n\n\tvoid onAdd(String key, String value);\n\n\tvoid onRemove(String key, String oldValue);\n\n\tvoid onUpdate(String key, String newValue);\n}\n")])])]),a("p",[e._v("有关更多信息，请参见"),a("a",{attrs:{href:"https://docs.spring.io/spring-integration/api/org/springframework/integration/metadata/MetadataStoreListenerAdapter.html",target:"_blank",rel:"noopener noreferrer"}},[e._v("Javadoc"),a("OutboundLink")],1),e._v("。如果你只对事件的一个子集感兴趣，那么"),a("code",[e._v("MetadataStoreListenerAdapter")]),e._v("可以被子类。")]),e._v(" "),a("h3",{attrs:{id:"控制总线"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#控制总线"}},[e._v("#")]),e._v(" 控制总线")]),e._v(" "),a("p",[e._v("正如"),a("a",{attrs:{href:"https://www.enterpriseintegrationpatterns.com/",target:"_blank",rel:"noopener noreferrer"}},[e._v("*Enterprise 整合模式 *"),a("OutboundLink")],1),e._v("一书中所描述的，控制总线背后的思想是，可以使用与“应用程序级”消息传递相同的消息传递系统来监视和管理框架内的组件。在 Spring 集成中，我们构建在上面描述的适配器的基础上，以便你可以发送消息作为调用公开操作的一种方式。")]),e._v(" "),a("p",[e._v("下面的示例展示了如何使用 XML 配置控制总线：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<int:control-bus input-channel="operationChannel"/>\n')])])]),a("p",[e._v("控制总线有一个输入通道，可以访问该通道来调用应用程序上下文中的 bean 上的操作。它还具有服务激活端点的所有公共属性。例如，如果操作的结果具有要发送到下游通道的返回值，则可以指定输出通道。")]),e._v(" "),a("p",[e._v("控制总线以 Spring 表达式语言表达式的形式在输入通道上运行消息。它接收一条消息，将正文编译为表达式，添加一些上下文，然后运行它。默认上下文支持用"),a("code",[e._v("@ManagedAttribute")]),e._v("或"),a("code",[e._v("@ManagedOperation")]),e._v("注释的任何方法。它还支持 Spring 的"),a("code",[e._v("Lifecycle")]),e._v("接口上的方法（以及自版本 5.2 以来的"),a("code",[e._v("Pausable")]),e._v("扩展），并且支持用于配置 Spring 的"),a("code",[e._v("TaskExecutor")]),e._v("和"),a("code",[e._v("TaskScheduler")]),e._v("实现的几种方法。确保你自己的方法对控制总线可用的最简单的方法是使用"),a("code",[e._v("@ManagedAttribute")]),e._v("或"),a("code",[e._v("@ManagedOperation")]),e._v("注释。由于这些注释也用于向 JMX MBean 注册中心公开方法，因此它们提供了一个方便的副产品：通常，你希望向控制总线公开的相同类型的操作在通过 JMX 公开时是合理的。应用程序上下文中任何特定实例的解析都是用典型的 SPEL 语法实现的。要做到这一点，请为 Bean 名称提供带有 bean 的 SPEL 前缀（"),a("code",[e._v("@")]),e._v("）。例如，要在 Spring  Bean 上执行方法，客户端可以向操作通道发送如下消息：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('Message operation = MessageBuilder.withPayload("@myServiceBean.shutdown()").build();\noperationChannel.send(operation)\n')])])]),a("p",[e._v("表达式的上下文的根是"),a("code",[e._v("Message")]),e._v("本身，因此你还可以访问"),a("code",[e._v("payload")]),e._v("和"),a("code",[e._v("headers")]),e._v("作为表达式中的变量。这与 Spring 集成端点中的所有其他表达式支持一致。")]),e._v(" "),a("p",[e._v("使用 Java 注释，你可以将控制总线配置如下：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('@Bean\n@ServiceActivator(inputChannel = "operationChannel")\npublic ExpressionControlBusFactoryBean controlBus() {\n    return new ExpressionControlBusFactoryBean();\n}\n')])])]),a("p",[e._v("类似地，你可以按以下方式配置 Java DSL 流定义：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('@Bean\npublic IntegrationFlow controlBusFlow() {\n    return IntegrationFlows.from("controlBus")\n              .controlBus()\n              .get();\n}\n')])])]),a("p",[e._v("如果你更喜欢使用带有自动"),a("code",[e._v("DirectChannel")]),e._v("创建的 lambdas，则可以按以下方式创建控制总线：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("@Bean\npublic IntegrationFlow controlBus() {\n    return IntegrationFlowDefinition::controlBus;\n}\n")])])]),a("p",[e._v("在这种情况下，信道被命名为"),a("code",[e._v("controlBus.input")]),e._v("。")]),e._v(" "),a("h3",{attrs:{id:"有序关机"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#有序关机"}},[e._v("#")]),e._v(" 有序关机")]),e._v(" "),a("p",[e._v("如“"),a("RouterLink",{attrs:{to:"/spring-integration/jmx.html#jmx-mbean-exporter"}},[e._v("MBean 出口商")]),e._v("”中所述，MBean Exporter 提供了一个名为"),a("code",[e._v("stopActiveComponents")]),e._v("的 JMX 操作，该操作用于以有序的方式停止应用程序。该操作有一个"),a("code",[e._v("Long")]),e._v("参数。该参数指示操作等待多长时间（以毫秒为单位）以允许飞行中的消息完成。该行动的工作方式如下：")],1),e._v(" "),a("ol",[a("li",[a("p",[e._v("在所有实现"),a("code",[e._v("OrderlyShutdownCapable")]),e._v("的 bean 上调用"),a("code",[e._v("beforeShutdown()")]),e._v("。")]),e._v(" "),a("p",[e._v("这样做可以让这些组件为关闭做好准备。实现这个接口的组件的例子，以及它们对这个调用所做的工作，包括 JMS 和 AMQP 消息驱动的适配器，这些适配器停止它们的侦听器容器，TCP 服务器连接工厂停止接受新连接（同时保持现有连接打开），TCP 入站端点丢弃（记录）接收到的任何新消息，和 HTTP 入站端点，对于任何新请求返回"),a("code",[e._v("503 - Service Unavailable")]),e._v("。")])]),e._v(" "),a("li",[a("p",[e._v("停止任何活动通道，如 JMS 或 AMQP 支持的通道。")])]),e._v(" "),a("li",[a("p",[e._v("停止所有"),a("code",[e._v("MessageSource")]),e._v("实例。")])]),e._v(" "),a("li",[a("p",[e._v("停止所有入站"),a("code",[e._v("MessageProducer")]),e._v("s（不是"),a("code",[e._v("OrderlyShutdownCapable")]),e._v("）。")])]),e._v(" "),a("li",[a("p",[e._v("等待剩余的任何时间，如传递给操作的"),a("code",[e._v("Long")]),e._v("参数的值所定义的。")]),e._v(" "),a("p",[e._v("这样做可以让任何飞行中的信息完成它们的旅程。因此，在调用此操作时选择一个适当的超时是很重要的。")])]),e._v(" "),a("li",[a("p",[e._v("在所有"),a("code",[e._v("OrderlyShutdownCapable")]),e._v("组件上调用"),a("code",[e._v("afterShutdown()")]),e._v("。")]),e._v(" "),a("p",[e._v("这样做可以让这些组件执行最后的关闭任务（例如，关闭所有打开的套接字）。")])])]),e._v(" "),a("p",[e._v("正如"),a("RouterLink",{attrs:{to:"/spring-integration/jmx.html#jmx-mbean-shutdown"}},[e._v("有序停机管理运行")]),e._v("中所讨论的，可以通过使用 JMX 调用此操作。如果希望以编程方式调用该方法，则需要注入或以其他方式获得对"),a("code",[e._v("IntegrationMBeanExporter")]),e._v("的引用。如果在"),a("code",[e._v("<int-jmx:mbean-export/>")]),e._v("定义中没有提供"),a("code",[e._v("id")]),e._v("属性，则 Bean 具有生成的名称。如果同一 JVM（"),a("code",[e._v("MBeanServer")]),e._v("）中存在多个 Spring 集成上下文，则该名称包含一个随机组件，以避免"),a("code",[e._v("ObjectName")]),e._v("冲突。")],1),e._v(" "),a("p",[e._v("出于这个原因，如果你希望以编程方式调用该方法，我们建议你为 exporter 提供一个"),a("code",[e._v("id")]),e._v("属性，以便你可以在应用程序上下文中轻松地访问它。")]),e._v(" "),a("p",[e._v("最后，可以使用"),a("code",[e._v("<control-bus>")]),e._v("元素调用该操作。有关详细信息，请参见"),a("a",{attrs:{href:"https://github.com/spring-projects/spring-integration-samples/tree/main/intermediate/monitoring",target:"_blank",rel:"noopener noreferrer"}},[e._v("monitoring Spring Integration sample application"),a("OutboundLink")],1),e._v("。")]),e._v(" "),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[e._v("前面描述的算法在版本 4.1 中得到了改进。"),a("br"),e._v("以前，所有的任务执行器和调度程序都被停止。"),a("br"),e._v("这可能导致"),a("code",[e._v("QueueChannel")]),e._v("实例中的中间流消息保持不变。"),a("br"),e._v("现在关闭将使 pollers 继续运行，以使这些消息被耗尽并得到处理。")])])]),e._v(" "),a("tbody")]),e._v(" "),a("h3",{attrs:{id:"积分图"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#积分图"}},[e._v("#")]),e._v(" 积分图")]),e._v(" "),a("p",[e._v("从版本 4.3 开始， Spring 集成提供了对应用程序运行时对象模型的访问，其中可以选择包括组件指标。它以图形的形式公开，可用于可视化集成应用程序的当前状态。"),a("code",[e._v("o.s.i.support.management.graph")]),e._v("包包含收集、构建和呈现 Spring 集成组件的运行时状态作为单个树状"),a("code",[e._v("Graph")]),e._v("对象所需的所有类。应该将"),a("code",[e._v("IntegrationGraphServer")]),e._v("声明为用于构建、检索和刷新"),a("code",[e._v("Graph")]),e._v("对象的 Bean。结果"),a("code",[e._v("Graph")]),e._v("对象可以序列化为任何格式，尽管 JSON 在客户端解析和表示时非常灵活和方便。 Spring 只包含缺省组件的集成应用程序将公开如下图：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('{\n  "contentDescriptor" : {\n    "providerVersion" : "5.5.9",\n    "providerFormatVersion" : 1.2,\n    "provider" : "spring-integration",\n    "name" : "myAppName:1.0"\n  },\n  "nodes" : [ {\n    "nodeId" : 1,\n    "componentType" : "null-channel",\n    "integrationPatternType" : "null_channel",\n    "integrationPatternCategory" : "messaging_channel",\n    "properties" : { },\n    "sendTimers" : {\n      "successes" : {\n        "count" : 1,\n        "mean" : 0.0,\n        "max" : 0.0\n      },\n      "failures" : {\n        "count" : 0,\n        "mean" : 0.0,\n        "max" : 0.0\n      }\n    },\n    "receiveCounters" : {\n      "successes" : 0,\n      "failures" : 0\n    },\n    "name" : "nullChannel"\n  }, {\n    "nodeId" : 2,\n    "componentType" : "publish-subscribe-channel",\n    "integrationPatternType" : "publish_subscribe_channel",\n    "integrationPatternCategory" : "messaging_channel",\n    "properties" : { },\n    "sendTimers" : {\n      "successes" : {\n        "count" : 1,\n        "mean" : 7.807002,\n        "max" : 7.807002\n      },\n      "failures" : {\n        "count" : 0,\n        "mean" : 0.0,\n        "max" : 0.0\n      }\n    },\n    "name" : "errorChannel"\n  }, {\n    "nodeId" : 3,\n    "componentType" : "logging-channel-adapter",\n    "integrationPatternType" : "outbound_channel_adapter",\n    "integrationPatternCategory" : "messaging_endpoint",\n    "properties" : { },\n    "output" : null,\n    "input" : "errorChannel",\n    "sendTimers" : {\n      "successes" : {\n        "count" : 1,\n        "mean" : 6.742722,\n        "max" : 6.742722\n      },\n      "failures" : {\n        "count" : 0,\n        "mean" : 0.0,\n        "max" : 0.0\n      }\n    },\n    "name" : "errorLogger"\n  } ],\n  "links" : [ {\n    "from" : 2,\n    "to" : 3,\n    "type" : "input"\n  } ]\n}\n')])])]),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[e._v("版本 5.2 不赞成使用旧版度量标准，而使用"),a("RouterLink",{attrs:{to:"/spring-integration/metrics.html#metrics-management"}},[e._v("度量管理")]),e._v("."),a("br"),e._v("所讨论的千分尺。")],1)])]),e._v(" "),a("tbody")]),e._v(" "),a("p",[e._v("在前面的示例中，图由三个顶级元素组成。")]),e._v(" "),a("p",[a("code",[e._v("contentDescriptor")]),e._v("图元素包含有关提供数据的应用程序的一般信息。可以在"),a("code",[e._v("IntegrationGraphServer")]),e._v(" Bean 或"),a("code",[e._v("spring.application.name")]),e._v("应用程序上下文环境属性中定制"),a("code",[e._v("name")]),e._v("。框架提供了其他属性，让你将类似的模型与其他来源区分开来。")]),e._v(" "),a("p",[a("code",[e._v("links")]),e._v("图元素表示来自"),a("code",[e._v("nodes")]),e._v("图元素的节点之间的连接，因此表示源 Spring 集成应用程序中的集成组件之间的连接。例如，从一个"),a("code",[e._v("MessageChannel")]),e._v("到一个"),a("code",[e._v("EventDrivenConsumer")]),e._v("，加上一些"),a("code",[e._v("MessageHandler")]),e._v("，或者从一个"),a("code",[e._v("AbstractReplyProducingMessageHandler")]),e._v("到一个"),a("code",[e._v("MessageChannel")]),e._v("。为了方便起见并让你确定链接的目的，该模型包含"),a("code",[e._v("type")]),e._v("属性。可能的类型有：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v("input")]),e._v(":标识从"),a("code",[e._v("MessageChannel")]),e._v("到端点的方向，"),a("code",[e._v("inputChannel")]),e._v("，或"),a("code",[e._v("requestChannel")]),e._v("属性")])]),e._v(" "),a("li",[a("p",[a("code",[e._v("output")]),e._v(":从"),a("code",[e._v("MessageHandler")]),e._v("，"),a("code",[e._v("MessageProducer")]),e._v("，或"),a("code",[e._v("SourcePollingChannelAdapter")]),e._v("到"),a("code",[e._v("MessageChannel")]),e._v("的方向，通过"),a("code",[e._v("outputChannel")]),e._v("或"),a("code",[e._v("replyChannel")]),e._v("属性")])]),e._v(" "),a("li",[a("p",[a("code",[e._v("error")]),e._v(":从"),a("code",[e._v("MessageHandler")]),e._v("on"),a("code",[e._v("PollingConsumer")]),e._v("或"),a("code",[e._v("MessageProducer")]),e._v("or"),a("code",[e._v("SourcePollingChannelAdapter")]),e._v("到"),a("code",[e._v("MessageChannel")]),e._v("通过"),a("code",[e._v("errorChannel")]),e._v("属性；")])]),e._v(" "),a("li",[a("p",[a("code",[e._v("discard")]),e._v(":通过"),a("code",[e._v("errorChannel")]),e._v("属性从"),a("code",[e._v("DiscardingMessageHandler")]),e._v("（如"),a("code",[e._v("MessageFilter")]),e._v("）到"),a("code",[e._v("MessageChannel")]),e._v("。")])]),e._v(" "),a("li",[a("p",[a("code",[e._v("route")]),e._v(":从"),a("code",[e._v("AbstractMappingMessageRouter")]),e._v("（如"),a("code",[e._v("HeaderValueRouter")]),e._v("）到"),a("code",[e._v("MessageChannel")]),e._v("。类似于"),a("code",[e._v("output")]),e._v("，但在运行时确定。可以是已配置的通道映射或动态解析的通道.为此，路由器通常只保留多达 100 个动态路由，但是你可以通过设置"),a("code",[e._v("dynamicChannelLimit")]),e._v("属性来修改该值。")])])]),e._v(" "),a("p",[e._v("来自此元素的信息可以由可视化工具用于呈现来自"),a("code",[e._v("nodes")]),e._v("图元素的节点之间的连接，其中"),a("code",[e._v("from")]),e._v("和"),a("code",[e._v("to")]),e._v("数字表示来自链接节点的"),a("code",[e._v("nodeId")]),e._v("属性的值。例如，"),a("code",[e._v("link")]),e._v("元素可用于确定目标节点上的适当"),a("code",[e._v("port")]),e._v("。")]),e._v(" "),a("p",[e._v("下面的“文本图像”显示了类型之间的关系：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v("              +---(discard)\n              |\n         +----o----+\n         |         |\n         |         |\n         |         |\n(input)--o         o---(output)\n         |         |\n         |         |\n         |         |\n         +----o----+\n              |\n              +---(error)\n")])])]),a("p",[a("code",[e._v("nodes")]),e._v("图元素可能是最有趣的，因为它的元素不仅包含运行时组件及其"),a("code",[e._v("componentType")]),e._v("实例和"),a("code",[e._v("name")]),e._v("值，而且还可以选择性地包含组件公开的度量。节点元素包含各种属性，这些属性通常是不言自明的。例如，基于表达式的组件包括"),a("code",[e._v("expression")]),e._v("属性，该属性包含组件的主表达式字符串。要启用度量，可以将"),a("code",[e._v("@EnableIntegrationManagement")]),e._v("添加到"),a("code",[e._v("@Configuration")]),e._v("类中，或者将"),a("code",[e._v("<int:management/>")]),e._v("元素添加到 XML 配置中。有关完整信息，请参见"),a("RouterLink",{attrs:{to:"/spring-integration/metrics.html#metrics-management"}},[e._v("度量和管理")]),e._v("。")],1),e._v(" "),a("p",[a("code",[e._v("nodeId")]),e._v("表示一个唯一的增量标识符，可以让你区分一个组件和另一个组件。在"),a("code",[e._v("links")]),e._v("元素中，它也用于表示此组件与其他组件（如果有的话）的关系（连接）。"),a("code",[e._v("input")]),e._v("和"),a("code",[e._v("output")]),e._v("属性用于"),a("code",[e._v("inputChannel")]),e._v("和"),a("code",[e._v("outputChannel")]),e._v("属性的"),a("code",[e._v("AbstractEndpoint")]),e._v("，"),a("code",[e._v("MessageHandler")]),e._v("，"),a("code",[e._v("SourcePollingChannelAdapter")]),e._v("，或"),a("code",[e._v("MessageProducerSupport")]),e._v("。有关更多信息，请参见下一节。")]),e._v(" "),a("p",[e._v("从版本 5.1 开始，"),a("code",[e._v("IntegrationGraphServer")]),e._v("对于特定的"),a("code",[e._v("NamedComponent")]),e._v("，在"),a("code",[e._v("IntegrationNode")]),e._v("上的附加属性的总体接受"),a("code",[e._v("Function<NamedComponent, Map<String, Object>> additionalPropertiesCallback")]),e._v("。例如，你可以将"),a("code",[e._v("SmartLifecycle``autoStartup")]),e._v("和"),a("code",[e._v("running")]),e._v("属性公开到目标图形中：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('server.setAdditionalPropertiesCallback(namedComponent -> {\n            Map<String, Object> properties = null;\n            if (namedComponent instanceof SmartLifecycle) {\n                SmartLifecycle smartLifecycle = (SmartLifecycle) namedComponent;\n                properties = new HashMap<>();\n                properties.put("auto-startup", smartLifecycle.isAutoStartup());\n                properties.put("running", smartLifecycle.isRunning());\n            }\n            return properties;\n        });\n')])])]),a("h4",{attrs:{id:"图运行时模型"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#图运行时模型"}},[e._v("#")]),e._v(" 图运行时模型")]),e._v(" "),a("p",[e._v("Spring 集成组件具有不同级别的复杂性。例如，任何被调查者"),a("code",[e._v("MessageSource")]),e._v("还具有一个"),a("code",[e._v("SourcePollingChannelAdapter")]),e._v("和一个"),a("code",[e._v("MessageChannel")]),e._v("，从源数据定期向其发送消息。其他组件可能是中间件请求-回复组件（例如"),a("code",[e._v("JmsOutboundGateway")]),e._v("），其使用"),a("code",[e._v("AbstractEndpoint")]),e._v("来订阅（或轮询）用于消息的"),a("code",[e._v("requestChannel")]),e._v("（"),a("code",[e._v("input")]),e._v("），以及用于生成向下游发送的回复消息的"),a("code",[e._v("replyChannel")]),e._v("（"),a("code",[e._v("output")]),e._v("）。同时，任何"),a("code",[e._v("MessageProducerSupport")]),e._v("实现（例如"),a("code",[e._v("ApplicationEventListeningMessageProducer")]),e._v("）都会封装一些源协议侦听逻辑并将消息发送到"),a("code",[e._v("outputChannel")]),e._v("。")]),e._v(" "),a("p",[e._v("在图中， Spring 积分组件通过使用"),a("code",[e._v("IntegrationNode")]),e._v("类层次结构来表示，你可以在"),a("code",[e._v("o.s.i.support.management.graph")]),e._v("包中找到它。例如，对于"),a("code",[e._v("AggregatingMessageHandler")]),e._v("可以使用"),a("code",[e._v("ErrorCapableDiscardingMessageHandlerNode")]),e._v("（因为它有一个"),a("code",[e._v("discardChannel")]),e._v("选项），并且在使用"),a("code",[e._v("PollableChannel")]),e._v("时可以产生错误。另一个例子是"),a("code",[e._v("CompositeMessageHandlerNode")]),e._v("—当通过使用"),a("code",[e._v("EventDrivenConsumer")]),e._v("订阅"),a("code",[e._v("SubscribableChannel")]),e._v("时，用于"),a("code",[e._v("MessageHandlerChain")]),e._v("。")]),e._v(" "),a("table",[a("thead",[a("tr",[a("th"),e._v(" "),a("th",[a("code",[e._v("@MessagingGateway")]),e._v("（参见"),a("RouterLink",{attrs:{to:"/spring-integration/gateway.html#gateway"}},[e._v("消息传递网关")]),e._v("）为其每个方法提供节点，其中"),a("code",[e._v("name")]),e._v("属性基于网关的 Bean 名称和简短的方法签名。"),a("br"),e._v("考虑以下网关示例：")],1)])]),e._v(" "),a("tbody")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('@MessagingGateway(defaultRequestChannel = "four")\npublic interface Gate {\n\n\tvoid foo(String foo);\n\n\tvoid foo(Integer foo);\n\n\tvoid bar(String bar);\n\n}\n')])])]),a("p",[e._v("前面的网关产生的节点类似于以下内容：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('{\n  "nodeId" : 10,\n  "name" : "gate.bar(class java.lang.String)",\n  "stats" : null,\n  "componentType" : "gateway",\n  "integrationPatternType" : "gateway",\n  "integrationPatternCategory" : "messaging_endpoint",\n  "output" : "four",\n  "errors" : null\n},\n{\n  "nodeId" : 11,\n  "name" : "gate.foo(class java.lang.String)",\n  "stats" : null,\n  "componentType" : "gateway",\n  "integrationPatternType" : "gateway",\n  "integrationPatternCategory" : "messaging_endpoint",\n  "output" : "four",\n  "errors" : null\n},\n{\n  "nodeId" : 12,\n  "name" : "gate.foo(class java.lang.Integer)",\n  "stats" : null,\n  "componentType" : "gateway",\n  "integrationPatternType" : "gateway",\n  "integrationPatternCategory" : "messaging_endpoint",\n  "output" : "four",\n  "errors" : null\n}\n')])])]),a("p",[e._v("你可以使用这个"),a("code",[e._v("IntegrationNode")]),e._v("层次结构在客户端解析图形模型，以及理解一般的 Spring 集成运行时行为。有关更多信息，请参见"),a("RouterLink",{attrs:{to:"/spring-integration/overview.html#programming-tips"}},[e._v("编程技巧和技巧")]),e._v("。")],1),e._v(" "),a("p",[e._v("版本 5.3 引入了一个"),a("code",[e._v("IntegrationPattern")]),e._v("抽象和所有开箱即用的组件，它们代表一个 Enterprise 集成模式，实现了这个抽象，并提供了一个"),a("code",[e._v("IntegrationPatternType")]),e._v("enum 值。对于目标应用程序中的某些分类逻辑来说，这些信息可能是有用的，或者，当暴露在图形节点中时，UI 可以使用这些信息来确定如何绘制组件。")]),e._v(" "),a("h3",{attrs:{id:"积分图控制器"}},[a("a",{staticClass:"header-anchor",attrs:{href:"#积分图控制器"}},[e._v("#")]),e._v(" 积分图控制器")]),e._v(" "),a("p",[e._v("如果你的应用程序是基于 Web 的（或构建在带有嵌入式 Web 容器的 Spring 启动之上），并且 Spring 集成 HTTP 或 WebFlux 模块（分别参见和）存在于 Classpath 上，你可以使用"),a("code",[e._v("IntegrationGraphController")]),e._v("将"),a("code",[e._v("IntegrationGraphServer")]),e._v("功能公开为 REST 服务。为此，"),a("code",[e._v("@EnableIntegrationGraphController")]),e._v("和"),a("code",[e._v("@Configuration")]),e._v("类注释和"),a("code",[e._v("<int-http:graph-controller/>")]),e._v("XML 元素在 HTTP 模块中可用。与"),a("code",[e._v("@EnableWebMvc")]),e._v("注释（或用于 XML 定义的"),a("code",[e._v("<mvc:annotation-driven/>")]),e._v("）一起，此配置注册了"),a("code",[e._v("IntegrationGraphController``@RestController")]),e._v("，其中其"),a("code",[e._v("@RequestMapping.path")]),e._v("可以在"),a("code",[e._v("@EnableIntegrationGraphController")]),e._v("注释或"),a("code",[e._v("<int-http:graph-controller/>")]),e._v("元素上进行配置。默认路径是"),a("code",[e._v("/integration")]),e._v("。")]),e._v(" "),a("p",[a("code",[e._v("IntegrationGraphController``@RestController")]),e._v("提供以下服务：")]),e._v(" "),a("ul",[a("li",[a("p",[a("code",[e._v('@GetMapping(name = "getGraph")')]),e._v(":检索自上次"),a("code",[e._v("IntegrationGraphServer")]),e._v("刷新后 Spring 集成组件的状态。将"),a("code",[e._v("o.s.i.support.management.graph.Graph")]),e._v("作为 REST 服务的"),a("code",[e._v("@ResponseBody")]),e._v("返回。")])]),e._v(" "),a("li",[a("p",[a("code",[e._v('@GetMapping(path = "/refresh", name = "refreshGraph")')]),e._v(":为实际运行时状态刷新当前"),a("code",[e._v("Graph")]),e._v("，并将其作为 REST 响应返回。没有必要刷新图表以获取度量。当图形被检索时，它们是实时提供的。如果自上次检索图表以来应用程序上下文已被修改，则可以调用刷新。在这种情况下，这个图是完全重建的。")])])]),e._v(" "),a("p",[e._v("你可以使用 Spring Security 和 Spring MVC 项目提供的标准配置选项和组件，为"),a("code",[e._v("IntegrationGraphController")]),e._v("设置安全性和跨源限制。下面的示例实现了这些目标：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('<mvc:annotation-driven />\n\n<mvc:cors>\n\t<mvc:mapping path="/myIntegration/**"\n\t\t\t\t allowed-origins="http://localhost:9090"\n\t\t\t\t allowed-methods="GET" />\n</mvc:cors>\n\n<security:http>\n    <security:intercept-url pattern="/myIntegration/**" access="ROLE_ADMIN" />\n</security:http>\n\n<int-http:graph-controller path="/myIntegration" />\n')])])]),a("p",[e._v("下面的示例展示了如何对 Java 配置执行相同的操作：")]),e._v(" "),a("div",{staticClass:"language- extra-class"},[a("pre",{pre:!0,attrs:{class:"language-text"}},[a("code",[e._v('@Configuration\n@EnableWebMvc // or @EnableWebFlux\n@EnableWebSecurity // or @EnableWebFluxSecurity\n@EnableIntegration\n@EnableIntegrationGraphController(path = "/testIntegration", allowedOrigins="http://localhost:9090")\npublic class IntegrationConfiguration extends WebSecurityConfigurerAdapter {\n\n    @Override\n    protected void configure(HttpSecurity http) throws Exception {\n\t    http\n            .authorizeRequests()\n               .antMatchers("/testIntegration/**").hasRole("ADMIN")\n            // ...\n            .formLogin();\n    }\n\n    //...\n\n}\n')])])]),a("p",[e._v("注意，为了方便起见，"),a("code",[e._v("@EnableIntegrationGraphController")]),e._v("注释提供了一个"),a("code",[e._v("allowedOrigins")]),e._v("属性。这提供了"),a("code",[e._v("GET")]),e._v("对"),a("code",[e._v("path")]),e._v("的访问。为了更复杂，你可以使用标准的 Spring MVC 机制来配置 CORS 映射。")])])}),[],!1,null,null,null);t.default=r.exports}}]);