程序员经验分享-hwhale

Spring集成流程的优雅关闭

2024-04-11

我从 spring 集成监控示例中了解到https://github.com/spring-projects/spring-integration-samples/tree/master/intermediate/monitoring https://github.com/spring-projects/spring-integration-samples/tree/master/intermediate/monitoring如何使用控制总线来关闭集成流程。我想知道怎么样

@integrationMBeanExporter.stopActiveComponents(false, 20000)

与仅关闭应用程序上下文不同

applicationContext.stop()

流被加载到其中。那岂不是达到同样的结果。


其实你是对的。从高处看，他们对组件做同样的事情：调用Lifecycle.stop().

您的应用程序在第一种情况下继续工作并且您可以调用的区别Lifecycle.start()再次。和IntegrationMBeanExporter仅适用于集成组件。

The applicationContext.stop() fully shutdownSpring 应用程序上下文 - 在大多数情况下只是停止整个应用程序。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

springintegration

Spring集成流程的优雅关闭 的相关文章

  • 如何增加消息头

    Spring Integration Java DSL 有没有办法修改现有的消息头 我正在使用 SI Java DSL 重新实现下载重试机制 并且希望在发生失败时增加保存下载尝试的消息标头 然后根据与限制相比的尝试次数路由消息 我的路由基于

  • 自定义 Spring 作用域不适用于消息通道

    在 Spring 集成中 我尝试创建一个具有自定义范围的直接消息通道 如下所示

  • 通过 Spring Batch 集成为 AWS S3 中的每个新文件启动 JobLaunchRequest

    我正在关注文档 Spring批量集成 https docs spring io spring batch docs current reference html spring batch integration html springBat

  • Spring Integration 中下游流完成后，如何从队列中一次轮询 1 条消息

    我目前正在努力提高集成流程的性能 尝试并行化消息处理 我已经使用 Java DSL 实现了所有内容 当前的集成流程从具有固定轮询器的队列通道获取消息 并通过多个处理程序依次处理该消息 直到到达最终处理程序 该处理程序会考虑前一个处理程序的每

  • 由于接收超时和任务执行器不协调而导致内存泄漏

    我正在浏览 spring 集成参考文档和第 10 1 8 节异步轮询 https docs spring io spring integration reference html async polling据记载 不协调的conf会导致内存

  • Spring Batch - Web 服务到 Web 服务分块

    我有一个托管的网络服务 允许批量提取记录 此 Web 服务以起始记录号 ROWID 和页面大小 最大 800 作为参数 可以从此服务中提取 50 60k 条记录 并调用另一个 Web 服务以块的形式再次发布所有这些数据 而无需在其间保留数据

  • Spring 集成 TCP。获取已连接客户端的连接ID

    我在这里遇到动态 TCP 连接方法的问题 Spring IP 动态 FTP 示例 https github com spring projects spring integration samples tree master advance

  • Spring集成：如何顺序处理文件

    我使用 int file inbound channel adapter 来加载目录中存在的文件 我喜欢按顺序处理文件 这意味着当第一个文件的处理完成时 我加载第二个文件 等等 I see a sample https github com

  • spring amqp-outbound gateway 生成来自不同 thead 的回复（如 jms-outbound gateway）

    问题陈述 Spring amqp outbound gateway 从不同线程生成回复 像 jms outbound gateway 一样 具有不同的队列 使用相关键关联请求 响应 无法将该消息与此示例关联起来 弹簧集成

  • 具有多租户的 Spring Batch

    我们如何定义针对多个租户运行的 Spring 批处理作业 我已经设置为每晚针对一个数据库模式按顺序运行一系列作业 当前所有作业都从某个位置读取文件并插入到数据库 批处理配置非常基本 我在其中定义了数据源 事务管理器并将作业存储库映射到它 我

  • Spring 集成超时客户端

    我的 Spring 集成场景是 使用自定义协议发送数据的数十个生产者 大小和内容 我必须解码这个自定义协议 然后处理结果 所以我尝试了很多配置 目前最好的配置如下

  • Spring Integration TCP - 在发送数据之前启动消息握手

    我正在使用 MessagingGateway 将数据发送到服务器 我为出站网关配置了 AbstractClientConnectionFactory 和 ServiceActivator 为了将数据发送到我的服务器 我需要在启动连接时发送握

  • Spring集成中运行时可配置的动态路由

    我想构建一个具有多个出站网关的方案 可以在运行时添加这些网关 假设它以 2 个网关开始 但能够在运行时添加第 3 4 个网关 我想要 http outbound gateways 来实现它们的功能 但想在运行时构建它们的实例 问题在于在 s

  • spring-integration并行分割路由聚合流由于单向MessageHandler而失败

    我想通过拆分项目 将每个项目路由到适当的网关并聚合结果来并行处理项目列表 但是 我的应用程序无法启动 出现以下错误 BeanCreationException The currentComponent is a one way Messag

  • 如何创建检测连接丢失和自动重新连接的 tcp-inbound-gateway？

    我正在尝试配置一组 spring 集成组件来使用来自 TCP 套接字的数据 基本协议是 打开连接后 系统会提示我输入用户名 然后输入密码 然后如果身份验证成功 数据就会在可用时流式传输给我 每 30 秒就会向我发送一条 ping 消息 以便

  • Spring Integration DSL - 可访问标头的出站网关

    我在 Spring 集成方面遇到了问题 我正在使用 Spring Boot 1 4 0 RELEASE Spring Integration 4 3 1 RELEASE Spring Integration DSL 1 2 0 M1 我正在

  • Spring集成MQTT发布订阅多个主题

    我正在尝试构建一个订阅多个 mqtt 主题的应用程序 获取信息 处理它并形成 xml 并在处理时触发一个事件 以便这些可以发送到某个云服务器 并将成功的响应从那里发送回MQTT 通道

  • 使用java工具的类似Sidekiq的队列？

    我想要一个工作队列 其行为几乎与 ruby 的 sidekiq 完全相同 它不need使用 Redis 但它可以 我只是不能使用 ruby 甚至不能使用 Jruby 基本上 我希望能够创建使用某些参数运行的作业 并且工作池执行作业 工作人员

  • Spring Batch - 读取多行日志消息

    我面临一个问题 在配置了 Spring 集成的 Spring Batch 应用程序中将多行日志消息读取为单个消息 该应用程序必须将多行日志消息 示例异常堆栈跟踪 读取为单个消息 稍后它必须处理并对消息进行分类以进一步建立索引 每行都由其时间

  • Spring Integration：SecurityContext 传播

    我对 Spring Integration 中的 SecurityContext 传播有一些困惑 这是文档的要点 http docs spring io spring integration reference htmlsingle sec

随机推荐

  • 如何在 Eclipse 中使用 JavaFX 2 SDK？

    我已经安装了 JavaFX 2 0 SDK 现在我想使用 Eclipse 制作一个 JavaFX 应用程序 但我该如何使用javafx Eclipse 中的类 The 官方 JavaFX Eclipse 插件 http docs oracl

  • C# 7.0 独立丢弃混淆

    我想更好地理解几个涉及 C 7 0 丢弃功能的使用的示例 他们都利用所谓的单独丢弃 https learn microsoft com en us dotnet csharp discards a standalone discard 这是

  • CQRS 对于我的域是否正确？

    我正在对一个档案进行建模 它是视频点播系统的一部分 将存档想象成 Windows 资源管理器 其中多个用户可以创建文件夹 上传视频 重组文件夹等 有业务规则 权限 确定是否允许用户执行任务 即重命名文件夹 移动文件夹 查看文件夹等 我已将每

  • 如何减少 Hybris 服务器的启动时间？

    我正在研究一个Hybris项目这是非常耗时的等待 350 550 秒对于单个Hybris服务器启动 即使只是代码中的一点修改 错误输入 是否有可能reduce this time仅运行我修改过的扩展或任何其他方式 那将是一件很棒的事情 在

  • DirectX Release 构建可以通过 VS2010 运行，但不能运行 exe

    我已经通过 Google 访问 Stack Overflow 几年了 但到目前为止还没有询问 回答任何问题 所以就到这里吧 基本上 我有一个在 DirectX 11 中设置绘图模型和地形的 3D 渲染框架 一切正常 通过 Visual St

  • 当前上下文中不存在名称“isPost”（带有 Razor 的 ASP.NET）

    我正在尝试遵循有关 Razor 入门的 Microsoft 文档 https learn microsoft com en us aspnet web pages overview getting started introducing r

  • 如何使用VBA在Excel中保持第一个单元格始终处于活动状态

    如何在打开 Excel 工作表时保持第一个单元格始终处于活动状态 任何人都可以指导我如何做到这一点 这是我的 代码 Private Sub Send Click Dim strURL As String strURL http xxxxxx

  • UIFont - 如何获取系统细字体

    UIFont有方法获取常规字体 systemFontOfSize 或粗体 boldSystemFontOfSize 但是如何通过情节提要获得可用的 瘦系统字体 将 系统精简 传递给UIFont构造函数不起作用 该构造函数仅适用于非系统字体

  • Django 开发将 HttpResponses 记录到开发服务器

    我正在使用 Django 创建一个 API 每个视图都以 JSON 形式响应 我想将每个 HttpResponse JSON 记录到开发服务器输出 到目前为止我已经添加了一个处理程序 console level DEBUG class lo

  • 在 Python 中列出所有 Google Drive 文件和文件夹并保存 ID

    我正在尝试编写一个程序来将文件夹和所有内容 包括子文件夹等 复制到另一个文件夹 我可能过于复杂化了 但我觉得第一步是获取与它们关联的所有文件名和 ID 并将它们保存到两个列表中 一个用于文件 一个用于文件夹 我无法让我的程序递归地遍历所有子

  • 无法验证 AzureAD 本机客户端应用程序

    我已经注册了一个 AzureAD 应用程序 它是公共客户端 本机客户端 我在门户中使用 Azure 生成的标准代码 重要的是 static App clientApp PublicClientApplicationBuilder Creat

  • 在Java中，我们可以将一个类分成多个文件吗

    是否有可能使用Java将一个类划分为多个物理文件 不 整个类必须位于 Java 的单个文件中 如果您正在考虑 C 的 部分类型 功能 那么 Java 中没有类似的功能 如果您没有想到 C 请忽略此

  • 带有 rpi 主站和从站的 Profibus [关闭]

    Closed 这个问题是与编程或软件开发无关 help closed questions 目前不接受答案 我的任务是使用 Rpi 和 Rs 485 转换器构建 profibus 主站和从站网络 一个 Rpi 将成为主设备 另一个将成为从设备

  • 无法加载 RSA 公钥

    我正在尝试读取如下所示的 RSA 公钥 但在第 6 行出现异常 java security spec InvalidKeySpecException java security InvalidKeyException IOException

  • 将浮点数转换为整数

    我试图定义 square Integer gt Integer square round 2 我得到

  • XDebug：Windows + Docker + PHPStorm

    我的操作系统是 Windows 10 我通过 boot2docker 映像运行 Docker 我使用的IDE是PHPStorm 我想做的是使用 XDebug 进行调试 但我没有让它运行 我搜索了网络并尝试了我找到的示例 但没有任何帮助 有相

  • 我收到来自 Retrofit Expected BEGIN_ARRAY but was STRING at line 1 column 1 path $ 的响应错误

    我看了几个答案 我遗漏了一些东西 还有没有办法在 Retrofit 处理之前查看数据 这是代码 extends Activity implements Callback

  • Celery 任务状态取决于 CELERY_TASK_RESULT_EXPIRES

    据我所知 任务状态完全取决于 CELERY TASK RESULT EXPIRES 设置的值 如果我在任务完成执行后检查此间隔内的任务状态 则返回的状态为 AsyncResult task id state 是正确的 如果没有 状态将不会更

  • 在 C - linux 中强制使用原始串行模式

    不知道如何表述标题 但我想做的是用我的 Linux PC 测试我的微控制器 以确保数据正确 经过几个小时的搜索 我发现 stty 命令可以更改通过串行端口管理数据的方式 并且事实证明 默认情况下 如果从端口接收到 xon 或 xoff 字符

  • Spring集成流程的优雅关闭

    我从 spring 集成监控示例中了解到https github com spring projects spring integration samples tree master intermediate monitoring http

热门标签