当前位置: 首页 > 知识库问答 >
问题:

Spring Cloud Stream输出通道的并发性(线程执行器)

洪鸿博
2023-03-14

有没有办法为Spring云流中的输出通道配置并发?

例如,我正在考虑如何为输出MessageChannel或通过配置属性设置线程执行器,如果这是一个好主意的话,在Spring-Cloud-Stream服务的情况下。

我还没有找到一种方法,那么这是否意味着spring stream cloud可以很好地为我们管理并发性(线程数量、放大/缩小策略),我们最好不要触及这一部分?

谢谢你,西蒙

共有1个答案

匡晟
2023-03-14

生产者端没有内置并发,因为不需要它,因为对于标准绑定器,发送是异步的,并且在任何情况下,并发都在输入端进行管理。

如果要进行实验,请在应用程序中使用任务执行器;如果您发现将其添加到框架中有令人信服的理由,请打开一个github问题,要求提供新功能

 类似资料:
  • 消费者是一个spring集成项目,它从消息队列中消费并执行大量处理。我使用Executor通道并行处理消息,然后流通过一些公共处理程序类。 请在下面的代码片段中找到- -我们从EMS队列接收消息并将其发送到路由器 -基于以下消息的id:“特定ExecutorChannel实例配置了一个单线程执行器。每个ExecutorChannel都将是它的专用执行器,只有一个线程。 -所有ExecutorCha

  • 欢迎阅读我的Java8并发教程的第一部分。这份指南将会以简单易懂的代码示例来教给你如何在Java8中进行并发编程。这是一系列教程中的第一部分。在接下来的15分钟,你将会学会如何通过线程,任务(tasks)和 exector services来并行执行代码。 并发在Java5中首次被引入并在后续的版本中不断得到增强。在这篇文章中介绍的大部分概念同样适用于以前的Java版本。不过我的代码示例聚焦于Ja

  • 消费者是一个spring集成项目,它从消息队列中消费并执行大量处理。目前,它是单线程的,不能与生产者发送消息的速度匹配。因此队列深度不断增加 是否可以使用executor通道在多线程环境中处理此问题并加快使用者进程 如果是,请建议如何实现--为了确保消息的顺序,我需要将相同类型的消息(基于消息的id)分配给executor通道的相同线程。 因此executor通道上的BridgeTo将转发消息

  • 并发是什么?引用Rob Pike的经典描述: 并发是同一时间应对多件事情的能力 其实在我们身边就有很多并发的事情,比如一边上课,一边发短信;一边给小孩喂奶,一边看电视,只要你细心留意,就会发现许多类似的事。相应地,在软件的世界里,我们也会发现这样的事,比如一边写博客,一边听音乐;一边看网页,一边下载软件等等。显而易见这样会节约不少时间,干更多的事。然而一开始计算机系统并不能同时处理两件事,这明显满

  • 除了接口比普通线程(例如管理)有一些优势之外,执行以下操作之间是否存在真正的内部差异(性能差异大、资源消耗……): 以及: 我只问这里的一个线索。

  • 并行 理论上并行和语言并没有什么关系,所以在理论上的并行方式,都可以尝试用Rust来实现。本小节不会详细全面地介绍具体的并行理论知识,只介绍用Rust如何来实现相关的并行模式。 Rust的一大特点是,可以保证“线程安全”。而且,没有性能损失。更有意思的是,Rust编译器实际上只有Send Sync等基本抽象,而对“线程” “锁” “同步” 等基本的并行相关的概念一无所知,这些概念都是由库实现的。这