项目反应堆稳定性的Spring云流
（Reactor）是一种基于云计算和云原生技术的响应式编程框架，它能够提供高度可靠的反应式应用程序开发解决方案。以下是关于Spring云流的详细介绍：
概念： Spring云流是Spring生态系统中的一个项目，它建立在Spring Boot和Spring Cloud基础上，提供了一种反应式的编程模型，旨在简化构建可靠性高的微服务架构。它利用反应式流和消息传递机制来处理异步任务和事件驱动的工作流程。
分类： Spring云流可以分为两个主要组件：Spring云流核心和Spring云流任务。Spring云流核心主要负责定义和实现反应式流的相关功能，包括事件驱动、流处理、消息传递等。Spring云流任务则是用于构建和管理异步任务的模块，可以与核心模块配合使用，实现更复杂的工作流程。
优势：
- 可靠性：Spring云流提供了可靠性高的消息传递和事件处理机制，能够确保任务的顺序性和一致性。
- 弹性扩展：基于云计算和云原生技术，Spring云流可以轻松实现水平扩展，应对高并发和大流量的需求。
- 高性能：采用反应式编程模型，Spring云流能够充分利用计算资源，提供高吞吐量和低延迟的服务。
- 简化开发：Spring云流提供了丰富的开发工具和组件，帮助开发人员快速构建可靠的反应式应用程序。
应用场景： Spring云流适用于各种需要实现异步任务和事件驱动工作流程的应用场景，特别是在需要处理大量并发请求和高吞吐量的系统中。例如电商平台的订单处理、实时数据分析和监控系统等。
推荐的腾讯云产品： 腾讯云提供了一系列与Spring云流兼容的云计算产品，包括云服务器、云数据库、云原生应用平台等。其中，推荐以下产品：
- 云服务器（https://cloud.tencent.com/product/cvm）：腾讯云的弹性云服务器提供了可靠的计算能力，可以用于部署Spring云流的应用程序。
- 云数据库MySQL版（https://cloud.tencent.com/product/cdb_mysql）：腾讯云的云数据库MySQL版提供了高可用性和可扩展性的数据库服务，适用于存储和管理Spring云流的数据。
- 腾讯云原生应用平台TKE（https://cloud.tencent.com/product/tke）：TKE是腾讯云提供的一款云原生应用平台，支持容器化部署和管理，可以方便地部署和扩展Spring云流应用程序。
综上所述，Spring云流是一种可靠的反应式编程框架，适用于处理异步任务和事件驱动工作流程的应用场景。腾讯云提供了一系列与Spring云流兼容的云计算产品，帮助用户快速构建可靠的云原生应用。
相关·内容
当我使用spring云网关集成spring云侦探时，我发现其性能比单独使用spring云网关要慢得多。有什么优化方案吗？
机器配置:6芯，16克
弹簧云网关:5331.9 tps弹簧云网关+弹簧云探测仪:4119.47 tps
“弹簧云网关”比“弹簧云网关+弹簧云休眠”慢1000-2000 than，“弹簧云网关+弹簧云侦察”性能下降22%。
浏览 1提问于2021-01-28得票数 0
回答已采纳
我目前正在从事一个Spring引导项目。最近，我将Spring引导的版本从2.3.3升级到2.6.6。在Spring 2.3.3中，我使用的是SpringCloudSleuth2.x.x，由于Spring云依赖关系管理BOM，它现在已经升级到3.x.x。POM如下
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
浏览 1提问于2022-05-04得票数 0
1回答
我注意到Spring框架在Spring5.0发行版中引入了反应性堆栈，该版本构建在和上。我很想知道，如果有人有这方面的信息，为什么他们选择项目反应堆，而似乎是一个更好的选择(广泛使用，良好的社区，更长的历史，通常意味着更少的bug，实现反应流规范，等等)。
浏览 1提问于2019-07-11得票数 2
回答已采纳
1回答
在写这个问题的时候，我正在使用SpringFramework5.0.0.M5和Akka 2.4.17。在项目中，我目前正在使用来自Akka的参与者消息和流。我明白了，v5也有流。
根据
作为一个反应性引擎/SPI，反应堆核心和IO模块都为集中的用例公开反应流结构，最终与Spring、RxJava、Akka流、Ratpack相结合.作为一个反应性API，反应堆框架模块将提供丰富的易耗特性，如组合和发布子事件。“
它看起来像Spring在引擎盖下使用Akka流(加上其他东西)。
问题是:从Akka流切换到Spring流可能有哪些优点和缺点？
编辑:这里有更广泛的问题(Reactov对Akka一般)
浏览 2提问于2017-02-25得票数 0
回答已采纳
1回答
我在一个使用spring流量的微服务项目上工作，下面是一些服务：
baseInfoService
notificationService
accountService
orderService
performService
我正在OrderService中实现一个服务，它将具有以下流程：
@PostMapping("/create")
//@PostMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Mono<OrderDto> createOrder(@Request
浏览 1提问于2021-05-23得票数 0
回答已采纳
我正在尝试构建一个Spring应用程序，它使用来自一个Kafka主题的事件，对其进行一些处理(可能涉及对反应性db查找的操作)，并将它们发送到另一个kafka主题。目前，该应用程序为kafka使用了webflux和spring云数据流。
请有人建议使用好吗，还是应该使用其他方法来实现端到端的反应行为。
尝试用Spring引导WebFlux，春季云数据流卡夫卡流。
这里的处理器示例
浏览 7提问于2022-12-02得票数 0
2回答
我在我的春季启动微服务中为其他微服务提供了一个api，我想在这个微服务前面放置一个spring云网关。
我已经回顾了众所周知的spring文档()，但据我所知，它要求我在一个单独的项目中启动云网关。但是我想在我的微服务中运行RouteLocator bean。不是在单独的项目中，而是在同一个项目中。
当我在同一个项目中使用它时，我会收到如下警告
Spring在类路径上找到，这与目前是不兼容的。请删除spring-boot-starter web依赖项。
稍后，正如他在警告中所说的那样，我移除了spring starter依赖项，甚至在其他项目中也是如此，像这样将它们从其中排除在外。
浏览 1提问于2021-03-19得票数 2
回答已采纳
2回答
祖尔2号春季计划
、、
我听说Zuul 2被释放了。有更新Spring的计划吗？我都等不及了。
我用Spring云构建了一个微服务系统，并认为它们很棒。所以，Zuul 2让我感到兴奋。
浏览 1提问于2016-10-05得票数 3
我正在从事一个项目，在这个项目中，我们将我们的一些微服务从Spring转移到Spring，以测试反应性范例。在hystrix的github存储库中寻找一些帮助，我们注意到该项目从一年前开始就没有提交，而且它是基于RxJava的，因此与项目反应堆有一些不兼容之处。
我们在使用Hystrix时遇到了一些问题，特别是来自"Javanica“的注释不起作用，我们的开发人员需要使用Spring的HystrixCommands。很明显，除了反应堆的线程之外，Hystrix还创造了他自己的线程池。
到了这一点，我的问题不是如何在SpringBoot2.0中使用Hystrix，而是如果必须将来自微服务
浏览 0提问于2018-11-13得票数 4
回答已采纳
1回答
我很清楚使用使用EventBus的项目反应堆进行Spring事件驱动的编程。
如果我让所有组件(消费者和生产者)都驻留在同一个JVM中，那么它们可以交换事件，并且这个模型工作得很好。
如果组件位于不同的JVM中，那么我可以使用Spring事件驱动的方法在它们之间进行通信吗？
浏览 0提问于2016-11-29得票数 2
回答已采纳
1回答
我有下面的逻辑流程。
public Mono<Response> process(Request request) {
var existingData = repository.find(request.getId());
if (existingData != null) {
if (existingData.getState() != pending) {
throw new RuntimeException("test");
}
} else {
existingData = repository
浏览 3提问于2022-11-01得票数 1
回答已采纳
我有两个对象，每个对象中都包含列表，我的整个spring引导项目都使用项目反应堆结构。我是否应该使用通量内的java流或单映射操作来遍历和操作数据？
Flux.fromIterable(page.getPageFieldData()).subscribeOn(Schedulers.elastic()).map(pageField - > {
clientDataMono.subscribeOn(Schedulers.elastic()).map(clientData - > {
Flux.fromIterable(clientData.get
浏览 0提问于2019-07-25得票数 3
回答已采纳
1回答
我在spring应用程序中使用spring发送数据主题。我需要从oracle表中获取数据并发送。
我从甲骨文桌上取名单。如何将它们发送到主题？
即
有什么办法把它们作为单子寄出去吗？如果是，怎么做？如果是，那么如何在消费者端反序列化呢？
使用spring和spring可以像流媒体一样发送数据吗？如果是的话，请提供更多的信息或样本/片段。
如果我一次发送列表，如何处理partitionKey？
目前，我正在发送个人公司obj，因此将密钥定义如下
companyKafkaTemplate.send(COMPANY_TOPIC,this.getKey(company), compan
浏览 0提问于2019-06-20得票数 2
1回答
我想知道反应流(由反应宣言定义)和反应堆模式()之间的关系。我读到了Project反应堆，我认为它是反应堆模式的一个实现，实现了反应性流API。但是，项目反应堆如何将反应堆模式的概念转化为流概念。这两个领域的抽象是如何联系起来的？
浏览 3提问于2021-10-07得票数 1
回答已采纳
我读到了Spring的FluxMessageChannel 和，但我仍然不明白在使用项目反应堆时使用DirectChannel和FluxMessageChannel有什么不同。由于DirectChannel是无状态的，并且由它的计票器控制，所以我认为不需要FluxMessageChannel。我正试图理解，在使用Spring实现的反应性流应用程序上，何时应该使用每个应用程序，以及为什么使用这些应用程序。
我目前有一个使用DirectChannel的反应性项目，它似乎工作得很好，甚至文档都说：
流程行为由命令式推送模型转变为反应拉力模型。
我想了解什么时候使用每个通道，以及在使用反应性流
浏览 6提问于2022-02-04得票数 0
回答已采纳
1回答
项目反应堆具有超时、重试、回退功能、wrt异常和背压功能。在使用Spring Cloud的微服务世界中，当我在项目反应器中使用Spring WebFlux时，我还需要resilience4j吗？resilience4j提供了哪些在Project Reactor中不可用的功能？
浏览 24提问于2019-02-02得票数 3
回答已采纳
我们正在评估反应堆库在我们的项目中的使用情况。我们的项目得到了春季背景的支持。因此，我们需要一个工具来构建具有spring支持的事件驱动应用程序。
此外，我们主要关注的领域是组成异步事件序列的能力(Streams & Promises)。在某些其他用例中，我们可能需要发布服务器/订阅服务器模型或异步运行长时间运行的进程。
在我评估的时候，我注意到了下面一些最新发布的反应堆--弹簧版本是v1.1.3，依赖于反应堆-v1.1.3，这是我们可以使用的。
但我也注意到了反应堆-v.2.0.0(正在开发中)，它有相当大的变化，特别是在流和承诺领域。
请建议我，如果这是一个好主意，与反应堆-v1.
浏览 3提问于2014-08-28得票数 3
回答已采纳
我们的应用程序是使用Spring + Gradle构建的。我们对实现春季批处理作业提出了新的要求，它将使用autosys(作业调度工具)触发，它有3个步骤执行3种不同的操作(文件准备、ftp和审计操作)。我已经附加了@EnableBatchProcessing配置文件供您参考。以下是与Spring数据流相关的问题。
Spring云数据流项目可以使用Gradle构建吗？我看到了使用Maven和官方Spring页面构建的所有示例项目，Maven是Spring数据流必须的。Gradle是我们公司唯一获得批准的建设项目。
我们正在寻找Spring批管理UI类特性或在Spring数据流中的操作。
浏览 0提问于2019-05-31得票数 1
2回答
使用Kafka作为微服务体系结构中的消息传递系统，使用spring相对于spring云流+spring-云-初学者流-kafka有什么好处？
spring云流框架支持更多的消息传递系统，因此具有更模块化的设计。但是功能呢？泉-卡夫卡的功能和弹簧云流+弹簧云-启动-流-卡夫卡的功能之间有差距吗？哪个API设计得更好？
期待阅读你的观点
浏览 5提问于2017-11-15得票数 56
我只是通过示例PoC项目在简单的普通场景中测试一些阻塞/非阻塞解决方案。
设想情况：
有rest阻塞端点，它非常慢-每个请求都有200 ms。
还有其他客户端应用程序，它们调用这个缓慢的端点。
我已经测试过当前(阻塞) Spring (tomcat)、SpringBoot2.0 (netty)和WebFlux - WebClient、Ratpack和Lagom。在每种情况下，我都通过gatling测试简单场景(100-1000个用户/秒)来强调客户端应用程序。
我已经测试了ratpack和lagom作为参考的非阻塞io服务器，以比较与spring引导(阻塞和非阻塞)的结果。
在
浏览 0提问于2017-03-30得票数 17
我的理解是，创建是为了与Kafka客户端API交互，后来创建项目是为了“构建与共享消息传递系统相连接的高度可伸缩的事件驱动的微服务”，该项目包括两个绑定程序，其中一个是允许与Kafka交互的绑定器。
spring-cloud-stream-binder-kafka-streams
因此，我很清楚，如果我想与Kafka交互，我将使用spring云流方法和适当的绑定器。
但是，我发现您可以与交互，也可以使用spring方法。
需要以下两个依赖项。就是一个例子。
'org.springframework.kafka:spring-kafka'
'org.apache.kafk
浏览 3提问于2021-11-10得票数 0
回答已采纳
我在Spring项目中发现了一些使用依赖项的漏洞：
reactor-netty-core
reactor-netty-http
我在pom.xml文件中拥有的唯一相关导入是：
<dependency>
<groupId>org.projectreactor</groupId>
<artifactId>reactor-spring</artifactId>
<version>1.0.1.RELEASE</version>
</dependency>
经过一些研究后，我发现这个依
浏览 4提问于2022-02-27得票数 0
2回答
我想用Spring创建一个新项目，但我不想要所有的反应性功能。对我来说，如果其他微服务阻塞I/O而不是反应性的话，那就没问题了。
我怎么能这么做？
假设我将云网关实现为反应性，而所有其他MS作为阻塞，这是一个好方法吗？那有什么坏处？
浏览 6提问于2021-01-21得票数 0
回答已采纳
最近发现了CVE-2022-22963弹簧云函数漏洞，这里的团队提供了一个简单的修补程序：。
我们通过以下依赖关系从spring-cloud-function-context:3.0.6获得spring-cloud-stream:3.0.4 ( spring.boot.version为2.2.6)：
spring-cloud-services-starter-circuit-breaker:2.2.6
弹簧云总线:2.2.6(包括amqp/kafka)
弹簧-云-启动-流-卡夫卡:3.0.4
春-云-启动-流-兔:3.0.4
我们没有直接使用RoutingFunctio
浏览 20提问于2022-04-12得票数 1
回答已采纳
1回答
我将Spring Cloud Stream 3.1.2用于KafkaStreams。程序设计模型如下：
ProgrammingImperative函数式编程
后者使用注释作为Spring提供要使用的所有其他注释。但是，有人提到
从3.1.0版本的绑定器开始，我们建议对基于Kafka流绑定器的应用程序使用上面描述的函数编程模型。从Stream的3.1.0开始，不再支持StreamListener。
因为我认为旧的模型更易读(至少对我来说是这样)。有谁能解释一下为什么决定放弃它来支持函数式编程，它会被删除吗？
浏览 2提问于2021-04-02得票数 5
回答已采纳
1回答
我正在使用Project反应堆进行非阻塞IO数据管道，并且我正在考虑使用作为抽象层来管理管道中的所有流和组件。我目前正在用项目反应堆实现Kafka用户，我开始怀疑Spring包装是否会在阻塞和背压方面破坏我的管道。
我想知道在一个完整的非阻塞应用程序中使用及其类是否安全，以及是否存在任何陷阱。
浏览 5提问于2022-01-18得票数 2
回答已采纳
使用SpringBootv1.5.x，可以将单个服务双作为和。在Spring 2.x中，似乎使用了Spring reactive (webflux、Netty等)，而仍然使用Tomcat。我想知道是否可以将Netty用于Eureka Server，或者在一个服务中同时使用Netty和Tomcat。下面的示例代码
import de.codecentric.boot.admin.server.config.EnableAdminServer;
import org.springframework.boot.SpringApplication;
import org.springframework
浏览 0提问于2018-12-04得票数 1
我正在尝试持久化一个singleton类，并且我希望确保它仍然是单例的。在Spring WebFlux中同步方法调用的合适方法是什么？
我有以下服务方法：
public Mono<SingletonClass> saveOrUpdate(SingletonClass singletonClass) {
return this.getTheSingletonClass()
.map(someLogicAndSave)
.switchIfEmpty(singletonClassRepository.save(singl
浏览 4提问于2019-01-14得票数 2
回答已采纳
1回答
有反应流的春云流
、、、、
我的目标是使用Spring云流和Kafka开发一个应用程序，并发现“反应性”世界。我有个有用的东西。这是我的一部分消费者。在我的演讲中，我宣布：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>
这是我使用的1.0。
我已经宣布我的频道
浏览 0提问于2016-07-10得票数 4
回答已采纳
虽然弹簧堆芯3.1.0.RC1 et.al。我找不到IO.放映机:反应堆-bom:Bimuth-RC1。我想用最新的Spring WebFlux来测试它。任何暗示都是感激的。
浏览 2提问于2017-09-06得票数 0
回答已采纳
1回答
我正在开发一个spring引导项目，它有几个模块。我有一个入口点模块，它有主类，另一个模块依赖于我在入口点模块pom.xml中添加的内容。当我命令mvn干净安装时，它会抛出一个错误，上面写着
未能执行项目api:无法解决项目com.nikesh:api:jar:1.0.0的依赖关系: com.nikesh:lib:jar:1.0.0，com.nikesh:repo:jar:1.0.0，com.nikesh:entity:jar:1.0.0，com.nikesh:dto:jar:1.0.0，com.nikesh:service:jar:1.0.0，Com.nikesh: forced :jar
浏览 2提问于2017-12-04得票数 0
回答已采纳
1回答
我在理解反应性流原理以及使用简单的解决方案时遇到了困难，这个简单的解决方案很容易由java 8流解决。我想这样做：
class service{
public void add(List<Car> cars){
cars.parallelStream.forEach(car -> repo.add(car));
}
使用Spring反应堆实现。我在互联网上看到了很多例子，但通常是与对象映射或类似的东西。
浏览 0提问于2018-06-14得票数 0
1回答
：不通过流获取数据库更新
、、、
我面临的问题：
无论我尝试如何使用(WebFlux) REST的各种教程，我都无法让它发挥作用。当我最初调用端点时，我能够从MongoDB集合中获得结果。但是，每当我对文档条目进行更新，或者添加一个新文档时，都不会通过文本事件流更新它。每次我必须再次调用端点才能获得新的结果。
设置：
目前，我有以下设置：
(我在后面运行各种)
包含RestControllers的Service (称它为主服务)
我正在使用Spring、Spring和。
这些依赖项包括Spring服务的pom.xml：
<dependency>
<gro
浏览 2提问于2021-01-21得票数 2
回答已采纳
我正在考虑使用spring云流来构建消息驱动的微服务应用程序，使用RabbitMQ作为代理。
我看到spring云流构建在( SI )之上，SI提供spring集成脚本来执行python脚本。但我不知道如何在春云流中把它连接起来。
因此，我想知道的是，当消息到达队列时，如何依次执行python脚本并获得脚本的输出？
任何代码和配置示例都会有帮助。
希望有人能帮忙。
谢谢GM
浏览 4提问于2016-06-13得票数 2
回答已采纳
我刚刚开始使用SpringReaser3 (WebFlux).When，尝试使用WebClient来使用REST端点来返回Flux，我得到了以下错误。
申请课程：
@Bean
public WebClient client(){
return WebClient.create("http://localhost:8080");
}
@Bean
CommandLineRunner demo(WebClient client){
return args-> {
client.get().uri("/reactive/zip-code
浏览 11提问于2017-05-02得票数 2
回答已采纳
1回答
弹簧集成堆
、、
这个问题是我之前发布的一个的延续。我想创建一个github项目来确认这种行为，并可能想出某种解决方案。这是
反应堆2.x版本中似乎包含了对反应堆的Spring支持，spring集成sftp使用了1.1.4版本的反应堆，并引用了一个StringUtils类，该类已移到反应堆2+版本中的不同包中。
这个版本的冲突似乎是不可避免的，直到它在SI 4.2中得到解决，所以我希望能得到一些关于如何使用反应堆1.1.4和重新创建与弹簧反应堆支持的相同/类似的反应堆配置的建议(在这个项目中)。这样SI sftp也能工作。
浏览 4提问于2015-04-29得票数 1
回答已采纳
我正在尝试将春云流与春云功能webflux集成在一起。
由于它们在将来的版本中不推荐spring云反应性流，所以我尝试使用spring云函数。
Spring云web函数可以公开其函数的端点，路径类似于doc。
从云流中，我可以看到源需要定义为供应商
但是我的用例是从反应性http端点获取POST数据，并将其摄取到kafka中，有没有办法从spring云功能web和spring云流中实现呢？
从文档中获取包含弹簧云流的spring云函数。
@SpringBootApplication
@EnableBinding(Source.class)
public static class Source
浏览 2提问于2019-03-27得票数 2
回答已采纳
1回答
我正在我的Spring项目中实现Cosmos DB，并在连接到Azure Cosmos DB时出错。
POM.xml
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-cosmosdb-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<dependency>
<groupId>com.micr
浏览 7提问于2020-02-16得票数 0
1回答
求助！之前用2G内存的云服务器个人使用，用VSCode远程写C++，看一些开源项目什么的，但是C++插件占的内存比较大，稍微开多一点文件连接就断开了，如果要编译的话有时候完全连不上。一般看的项目文件数量都在1000个以内，选云服务器的话至少需要多大内存合适呢？
浏览 455提问于2022-07-30
据我理解，Mono和Flux在反应性编程中是“不可变的”。
这是否意味着，如果我有两个相同的操作要运行(例如，相同的Mono定义)，是否应该只重用相同的定义。
在某种程度上，将这两个对象(Mono和Flux)作为一组指令来处理，而不是使用当前状态的指令。
例如：
Mono<String> someMono = // Some Custom Mono
//Perform 2 concurrent someMono calls , and block on result
Mono.zip(someMono, someMono, (a,b) -> a + b).block(
浏览 0提问于2018-06-21得票数 3
回答已采纳
我在我的项目中使用spring网络流量。我的控制器类调用返回Mono或Flux的服务类方法。
我正在尝试为我的服务类编写单元测试。我不知道如何为返回Mono/Flux的方法编写单元测试。我查看的大多数文章都建议我使用WebclientTest。但重点是，我在这里测试我的服务类。当我通过模拟服务类方法测试我的web层(控制器类)时，我使用了WebclientTest。
现在我想为我的服务类方法编写单元测试(通过模拟数据库类)。
对于如何实现这一点，有什么想法吗？我应该使用调用测试中的服务类方法并调用block()，还是有更好的方法？
浏览 1提问于2019-11-24得票数 3
我是spring，mongo和noSQL的菜鸟。
我已经连接到本地的mongoDB。
然而，我拯救实体的努力一直失败。
val a0 = myEntity(name = "my Entity")
repository.save(a0)
我的存储库扩展了ReactiveMongoRepository<MyEntity, Long>。
但是，当我将它更改为扩展MongoRepository<MyEntity, Long>时，它就能工作了。
有什么问题吗？
我的数据库实例正在运行并正常工作。我猜它必须做一些反应的事情。
浏览 1提问于2019-07-17得票数 8
回答已采纳
我们正在开发SCDF上的项目，kafka版本2.4.1用于数据流，2.3.1用于skipper。我有一个云流应用程序，它在我的IDE中进行单元测试时工作得很好。但当我注册为处理器时，我在我的Stream中看不到此特定应用程序的日志中的任何活动。 当前使用Boot2.2.5和Hoxton.SR3。 但当我使用spring boot版本2.1.4时，这款应用运行得很好。我使用spring boot 2.1.4的原因是这个URL上的示例应用程序使用2.1.4 因此，如果有文档可以让您知道SCDF发行版使用哪些spring boot版本，这会很有帮助。
浏览 13提问于2020-03-25得票数 0
1回答
我正在从事一个Spring项目，并且遇到了一个问题，试图在计划的任务中发布和使用Flux。
@Scheduled(fixedRate = 20*1000)
fun updateNews() {
try {
logger.info("Automatic Update at: ${LocalDateTime.now()}")
articleRepository.saveAll(
sourceRepository.findAll().publishOn(Schedulers.parallel())
浏览 3提问于2017-10-16得票数 4
回答已采纳
2回答
我正在使用任务云模块的spring数据流，但是我在午餐上遇到了一些麻烦，这是一个容器中的简单例子。编写代码时，我已经部署了它，但是当我试图执行它时，我会抛出一个
org.springframework.util.Assert.notNull(Assert.java:134)：无效的TaskExecution，在org.springframework.cloud.task.listener.TaskLifecycleListener.doTaskStart(TaskLifecycleListener.java:200)的java.lang.IllegalArgumentException上找不
浏览 3提问于2017-08-29得票数 2
这里是我的文件，在这里我已经升级到SpringBoot2.5.12。是否需要更新或添加任何其他依赖项？
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
浏览 21提问于2022-04-22得票数 -6
1回答
Spring数据流支持批处理吗？
、、、、
我们正在探索各种编程/库选项(在Java方面)，以便更快地进行批处理，并能够部署在云上。我们遇到了Spring /XD/cloud数据流。从对文档的快速回顾来看，我们无法评估Spring是否也具有spring将提供的所有批处理功能。例如，这里是SPring批处理文档()所说的："Spring提供了处理大量记录所必需的可重用函数，包括日志/跟踪、事务管理、作业处理统计、作业重新启动、跳过和资源管理。“
如果有人对春云数据流中的批处理功能有任何了解，请在这里发帖。非常感谢！
浏览 4提问于2016-05-18得票数 4
回答已采纳
1回答
基于的数据总线
、、
我在研究Java时，从一些教程中注意到，您只能订阅一个发布者。然而，我看到了一个用例，在这个用例中，多个发布者对单个订阅是有用的:某种类型的数据/消息总线。
我找到的唯一解决方案是在总线中封装一个订阅者数组和一个发布服务器。
我的问题是，从反应的角度来看，对这个问题，哪种方法是正确的？
我有兴趣通过实现我自己的Publisher/订户等等来解决这个问题(使用Java9API)，这个项目是为了学习java.util.concurrent.Flow，而不是为了生产。
浏览 0提问于2018-09-06得票数 0
1回答
使用spring云数据流运行我的spring云流应用程序的最简单方法是什么？我的想法是创建自定义的源代码，使用kafka绑定器和接收器作为预构建的启动程序，文件。我正在创建applciation，它非常基本，类似于。我尝试创建可执行的jar，并使用dataflow shell将其注册为源代码，但这根本不起作用。我已经在跟踪这个了。
浏览 2提问于2016-07-27得票数 0
回答已采纳
我试图创建一个使用spring引导和axon框架来实现CQRS和事件源的微服务。当我运行应用程序时，我正在获取FileNotFoundException。我在网上找不到任何解决办法。有人能帮我找到决议吗？如果我需要补充任何细节，请告诉我。
错误：
java.lang.IllegalStateException: Unable to read meta-data for class io.axoniq.axonserver.config.MetricsConfiguration
at org.springframework.boot.autoconfigure.AutoConfiguration
浏览 12提问于2022-05-01得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
