程序员经验分享-hwhale

在 Spring Cloud Data Flow 中使用一个源、两个并行处理器和一个接收器创建流

2024-06-26

我正在尝试在 Spring Cloud Data Flow 中创建一个流

  1. 单一来源，即订单来源 订单消息将发布到 RabbitMQ 主题/队列。

  2. 两个并行处理器，即产品处理器和运输处理器 这两个处理器都将成为 RabbitMQ 主题/队列的订阅者并获取订单消息，并且每个处理器将单独处理这些订单消息并更新订单，并将订单消息发布到 RabbitMQ 主题/队列。

  3. 一个接收器即支付接收器 接收器将是 RabbitMQ 主题/队列的订阅者，并将获取订单消息，并根据订单消息完成支付过程。

我尝试了以下命令并部署

流创建 --name order-to- payment --definition 'order-source |产品处理机|出货处理机|支付接收器'

但在 Spring Cloud Data Flow 中以图形方式表示，如下所示：

但我看起来像下面的东西

有可能实现这一目标吗？由于 Spring Cloud Data Flow 不允许它从一个源连接两个处理器，也无法以图形方式从两个处理器连接到一个接收器？

谢谢， 大卫。


您可以使用命名目的地来拥有带有数据流的 DAG，请在此处查看：http://docs.spring.io/spring-cloud-dataflow/docs/1.2.2.RELEASE/reference/htmlsingle/#spring-cloud-dataflow-stream-advanced http://docs.spring.io/spring-cloud-dataflow/docs/1.2.2.RELEASE/reference/htmlsingle/#spring-cloud-dataflow-stream-advanced

您需要通过指定的目的地发送消息并从中编写流程。如果您在阅读文档时遇到困难，请告诉我，我可以在此处发布一个示例。

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

springcloudstream

springclouddataflow

在 Spring Cloud Data Flow 中使用一个源、两个并行处理器和一个接收器创建流 的相关文章

随机推荐

  • Azure Functions 如何横向扩展？

    The Azure Functions 的扩展文档 https azure microsoft com en us documentation articles functions scale 详细介绍了 Azure Functions 如

  • 如何使用 C# 将标签/关键字添加到 Windows 文件属性详细信息选项卡

    理想情况下 我想使用 shell 类将标签添加到我的 Office 文档中 但我认为这样 tag 属性是只读项目 有人还有其他办法吗 关于这个主题的内容很少 感谢您的帮助 我进一步研究了 shellfile 类 答案就在我眼前 string

  • 在 django 中运行普通 sql 查询时如何获取字段名称

    在我的 django 视图之一中 我使用纯 sql 不是 orm 查询数据库并返回结果 sql select from foo bar cursor connection cursor cursor execute sql rows cur

  • 当错误较多时，Laravel 不会显示错误。这是 Bug？

    重复的https github com laravel framework issues 31123 https github com laravel framework issues 31123 Laravel 版本 6 8 0 6 10

  • 如何在 JTextArea 中设置部分文本颜色？

    我想为文本区域中的特定行设置颜色 到目前为止我发现的是以下内容 Declarations private final DefaultStyledDocument document private final MutableAttribute

  • Typescript 合并来自多个文件的接口

    我有一个名为service ts它公开了以下代码 export interface SomeInterface keyOne string export class TestService

  • 如何获取viewPager选中的Tab？

    我使用 lib viewpagerindicator 创建了一个 viewpager 该活动扩展了 FragmentActivity 因此我在获取选择哪个选项卡时遇到问题 我的适配器由下面的代码给出 class GoogleMusicAda

  • 使用 Python for Linux 模拟按键事件

    我正在编写一个脚本来自动运行特定模型 当模型失败时 它会等待用户输入 Enter 键 我可以检测到模型何时失败 但我无法使用 python 在 Linux 上 来模拟按键事件 Windows 有 SendKeys 库来执行此操作 但我想知道

  • 保存用户的身高和体重

    我应该如何将用户的身高和体重存储在MySQL数据库中 以便我可以使用这些信息来查找特定身高或体重内的用户 另外 我需要能够以英制或公制显示此信息 我的想法是存储以厘米为单位的身高和以公斤为单位的体重信息 我更喜欢公制而不是英制 我什至可以让

  • 对等未经过身份验证：在 Android Studio 中构建应用程序时出错

    我一直在尝试构建使用 Fabric io 的 crashlytics 的应用程序 但构建失败并出现以下错误 Executing tasks clean app generateDebugSources app generateDebugAn

  • object_setClass()而不是分配isa指针的性能

    我注意到在 XCode 4 6 的最新更新中 我收到了关于以下几行的警告JSONKit m 具体来说 设置对象类的行 dictionary gt isa JKDictionaryClass 这些被标记为已弃用 并注明首选方法是使用objec

  • intellij idea 中的项目组

    目前 至少从 IntelliJ Idea 14 开始 ide 会记住最后一组打开的项目 我们能否轻松地控制它并拥有可切换的项目集 组 这是打开项目的另一种方式 与模块不同 我希望某个插件已经具备该功能 但是是哪一个呢 截至2017年8月 I

  • 在 Bootstrap 按钮下拉列表标题/占位符文本中显示所选项目

    这个问题已经在 Stackoverflow 上被问过几次了 但是我仍然无法弄清楚它的真相 而且我的查询正在抛出更多的下拉菜单 所以我有两个下拉菜单和一个搜索 我想从下拉列表和 选定 中进行选择以替换下拉占位符文本 但我还需要记住 点击搜索后

  • Jenkins 可以向我显示每月损坏构建的总数/百分比吗？

    我有一个 Jenkins 服务器 可以构建 测试大约 50 个项目 不幸的是 其中一些构建失败了 但是我没有一个好的方法来衡量构建失败的频率是否随着时间的推移而增加或减少 我想要的是这样的东西 一份报告向我展示了在一个月内有多少工作不稳定

  • WCF CommunicationException 没有异常消息详细信息

    我从来不理解 WCF 的一件事是 当服务器遇到未处理的异常时 为什么没有异常消息详细信息传播回调用客户端 例如 如果我有以下服务器代码 ServiceBehavior IncludeExceptionDetailInFaults true

  • 将 JVM 参数放入要在运行时获取的文件中

    我正在构建当前应用程序的 jar 它需要设置几个 JVM 参数 有没有办法在文件中而不是在命令行上设置这些 JVM 参数 我已经做了一些搜索 看起来我可以使用 java properties 文件做一些事情 可能通过设置 java args

  • NESTJS AWS Lambda 和 Sequelize 连接池

    由于我已经给出了下面代码片段中提到的池参数 因此是否有必要在每次 lambda 调用后关闭连接 这个 aws lambda 函数应该每分钟触发一次 池参数仅足以关闭连接吗 export const databaseProviders pro

  • SVG 以 % 为单位旋转文本

    我尝试旋转 svg 文本 我通过从 xslt 调用 php 函数来获取文本的位置 即 15 问题是我无法使用 旋转 svg 对象 如果我使用数字来代替 它就可以了 下面我将问题简化

  • 通过 XMLHttpRequest 将数据从 JavaScript 发送到 PHP

    再会 我正在尝试将一段简单的数据从一个 php 文件 manage php 发送到另一个 view php 我无法通过表单发送数据 我想通过 JS 脚本发送数据 这是我的尝试 var read function id xmlhttp new

  • 在 Spring Cloud Data Flow 中使用一个源、两个并行处理器和一个接收器创建流

    我正在尝试在 Spring Cloud Data Flow 中创建一个流 单一来源 即订单来源 订单消息将发布到 RabbitMQ 主题 队列 两个并行处理器 即产品处理器和运输处理器 这两个处理器都将成为 RabbitMQ 主题 队列的订

热门标签