如果两者本质上都是异步的，那么在Java语言中使用反应式编程而不是ExecutorService又有什么用呢？与ExecutorService相比，反应式编程在哪些方面更有效？
浏览 12提问于2019-07-10得票数 7
回答已采纳
4回答
请问，谁能给我解释一下使用反应式风格的好处：
Observable<String> greeting = Observable.just("Hello");
Observable<String> yelling = greeting.map(s -> s.toUppercase());
而不是简单的命令式风格：
String greeting = "Hello";
String yelling = greeting.toUppercase();
我理解反应式编程，就像数据库访问、用户界面、计算、网络访问等一样，但是为什么我们需要对简
浏览 3提问于2017-11-12得票数 15
今天，我读到，"...在命令式编程设置中，:= b+c意味着a在表达式求值的瞬间被赋值为b+c的结果，之后，b和c的值可以在不影响a的值的情况下更改。另一方面，在反应式编程中，只要b或c的值发生变化，a的值就会自动更新，而无需程序重新执行语句a := b+c来确定当前赋值的a的值。“在维基百科
这是否意味着反应式编程又回到了通过引用传递的状态？
浏览 14提问于2018-08-27得票数 1
回答已采纳
1回答
我正在使用Spring5和couchbase进行反应式编程。有人能详细解释一下反应式java是如何从couchbase拉入数据的吗？couchbase如何提供响应式支持？提前谢谢。
浏览 34提问于2019-01-18得票数 0
回答已采纳
6回答
反应式编程的优点/缺点
、、、、
我一直在研究和尝试使用Reactor和RxJava的响应式编码方式。我确实理解，与单线程执行相比，反应式编码可以更好地利用CPU。
在基于web的应用程序中，反应式编程和命令式编程之间有什么具体的比较吗？
通过使用反应式编程比使用非反应式编程，我获得了多大的性能增益和吞吐量？
另外，反应式编程的优点和缺点是什么？
有没有统计基准？
浏览 10提问于2017-02-06得票数 36
2回答
我是第一次接触反应式编程的世界。我读到，一旦声明了一个变量，并且它指向一个不断变化的值，它就会自动更新它。所以我想知道asp.net，java等提供的gui控件有什么不同。一旦我们在文本框中输入了一个新值，它就会自动保存这个值。是反应式编程吗？有人能提供一些好的教程来更好地理解这个概念吗？
浏览 2提问于2014-01-23得票数 2
1回答
我真的看不出它们之间的区别。它们都是关于流经指令的数据和输入数据中变化的传播。我读过，它清楚地说它们都是一样的。另一方面，将反应式编程建立为数据流编程的一种形式，也是这样做的。
那么，反应式编程和数据流编程在概念上有什么不同呢？
浏览 47提问于2015-06-07得票数 31
有人能告诉我CompletableFuture和反应式编程有什么关系吗？换句话说，我可以在Java8中使用CompletableFuture实现一些反应性原则吗
浏览 20提问于2016-09-24得票数 0
我刚接触反应式编程，我想知道的一件事是，假设我们有一个api，它在内部调用其他3个api。其中第一api的结果被馈送到第二api，而第二api的输出被馈送到第三api。它是否不会简化为正常的基于单线程的执行。如果是，那么为什么我们要在这种情况下使用反应式编程。
浏览 0提问于2018-11-02得票数 2
1回答
我想使用反应式编程将我的excel文件存储到数据库中。在非反应式中很容易做到，但我不能在反应式中做类似的事情，我应该写什么来将它存储到我的mongo数据库中？
我的控制器
@PostMapping(path = "/file",consumes = MediaType.MULTIPART_FORM_DATA_VALUE,
produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public HttpStatus file(@RequestPart("files") Mono<F
浏览 5提问于2021-11-01得票数 1
1回答
我一直在阅读反应式编程，可以理解编程模型，以及如何使用CQRS等模式来构建微服务和应用程序。这与传统中间件使用的遗留复杂事件处理方法有何不同。
浏览 2提问于2016-10-28得票数 1
1回答
我是反应式编程的新手，我有一段代码，只有在并行任务结束后才能并行运行，后面的代码应该被执行
//step 1 parallel stuff
Flux.fromIterable( sourceOneMap.keySet() )
.parallel()
.runOn( Schedulers.parallel() )
.subscribe( compId -> {
Mono.just( compId )
.then( checkIfSystemTwoContainsSystemOneInfo(compId,sourceOneMap,sourceTwoMap,new Timestamp( n
浏览 2提问于2018-12-07得票数 0
当我们从关系数据库获取数据或调用外部API端点时，使用Spring Reactor进行反应式编程有意义吗？
浏览 27提问于2020-02-02得票数 0
回答已采纳
我有一个Spring boot 1.4.3项目。最近，我提出了一个要求，即我必须将日志从服务器发送到我的web应用程序，并在网页上打印日志。我知道WebSockets，但我正在寻找更好的解决方案，我遇到了响应式编程和gRPC。
Spring在Spring version5中支持反应式编程，但我对gRPC和反应式编程之间的关系感到困惑。gRPC的特点是双向流，它建立在Netty之上，并提供与从服务器向客户端推送数据相同的工具，如反应式编程。所以我应该使用哪一个，如果你能澄清我的困惑，那就太好了。
此外，如果我迁移到支持Spring版本5的Spring Boot 2，则该项目将在Netty上运行。
浏览 1提问于2017-07-31得票数 0
我有一个问题，我刚刚开始进行反应式编程，并且我正在使用quarkus。我用Panache hibernate reactive做了一个演示，用SQL客户端做了一个演示。我希望我的每个rest都运行在不同的非阻塞线程上。使用panache hibernate，每当我执行阻塞操作时，我都会收到一条有关它的消息，日志中显示api正在运行o vertex事件循环线程，所以一切都很好。在反应式客户端中，一切都运行在执行器线程0上，这是否意味着我的apis不是从输入到输出的异步(反应式)，并且当我运行阻塞操作时，没有显示错误。
浏览 34提问于2021-10-10得票数 0
2回答
我刚刚开始研究Haskell中的函数式反应式编程的世界，我想在一个反应式的环境中尝试GUI编程( gtk，因为有实质的绑定)。
现在，我一直在寻找葡萄柚，反应性香蕉和巴斯特，我想要任何证明joy/恐怖使用任何一个或其他软件包。
我所拥有的只是这些初步的观点：
我不介意做一些玻璃钢包装与gtk本人，因为我有一个矛盾的感觉，抽象的后端想法(葡萄柚)。
虽然我觉得类型理论很有趣，但我也很重视实际程序的简单编码，这似乎会使笔录有点偏离.
那就是，除非你们中的一些人说服我不这么想:-)
浏览 3提问于2012-04-03得票数 26
回答已采纳
我正在尝试读取Spring Cloud Gateway中ServerWebExchange的request body数据。有没有人能教我怎么做。 这也是为什么这个简单的任务在反应式编程中是如此困难。
浏览 88提问于2020-10-29得票数 0
4回答
我正在通过网络浏览Rx框架材料，我已经找到了很多。
现在，每当我在谷歌上搜索时，我也会找到维基百科的“反应性编程”链接。
由于反应性编程是关于a := b+ c，(a在b或c更改时更改)。Rx是关于订阅源发布的可观测序列。
有人能解释一下反应式编程和Rx之间到底有什么联系吗？
浏览 9提问于2014-02-16得票数 3
回答已采纳
3回答
我花了些时间考虑了一种基于事件的编程语言。我指的是一种语言，当你改变一个因变量时，每个变量都会被更新。例如，考虑终端应用程序的以下伪代码：
int a = 5
int b = a + 5
// event which is called every 5 seconds
every 5 seconds =>
{
// update a by adding 5
a << a + 5
}
// event which is called when the user presses enter
on enter =>
{
println("
浏览 2提问于2014-09-25得票数 2
2回答
我在做一个闪亮的应用。我使用反应性编程来获得更好的功能性。但我不知道如何引用数据集，即反应式对象。示例如下： buffer_bank <- reactive({mydata <-
merge(buffer_data(), rwa())%>%
mutate(buff = case_when(REGN %in% (szko$REGN) ~ (buffer + buffer_szko), TRUE ~ buffer))%>%
select(REGN, buff)
mydata}) 其中buffer_data()和rwa
浏览 34提问于2020-01-05得票数 0
回答已采纳
6回答
我最近一直在研究Haskell，它似乎是从另一种观点来看待编程问题的一种非常好的方式-至少可以替代我通常的命令式(我有很强的C++背景)视图。
然而，我看到的所有文章似乎都在处理相同类型的编程问题：
的ParsersCompilersNumeric计算问题
我想亲自试一试Haskell，通过编写一些GUI应用程序。因此，我想知道:用Haskell这样的函数式编程语言编写像GUI这样的事件驱动系统有意义吗？或者这是命令式语言擅长的问题领域？不幸的是，我仍然需要相当长的时间才能将我的思想切换到“函数式”模式，所以我很难决定是反对还是支持在事件驱动系统中使用函数式编程语言。
我还对用Haskell实
浏览 96提问于2010-01-18得票数 16
回答已采纳
我将以下formControl作为我的反应式表单的一部分：
<input class="input" formControlName="email" [placeholder]="">
我想知道是否有一种方法可以编程设置占位符？
类似于：this.formGroup.get('email').placeholder = 'Some value';
浏览 26提问于2018-03-06得票数 4
1回答
我在Java反应式编程方面还是个新手，我的项目要求我在Java中使用反应式编程实现分页。
例如，如果我遇到一个API，它返回流中的10000条记录，那么我需要返回一个具有适当分页的flux。
有没有人能给我一个好的建议？
这就是我正在遵循的方法。
存储库
public interface CouchBaseRepository extends ReactiveCouchBaseRepository<Book,Integer> {
@Query("#{#n1ql.selectEntity} where name=$1")
public Flux<
浏览 4提问于2018-09-22得票数 5
1回答
教学包是函数式反应式编程的一个好的(或坏的，还是不好的)示例？
它似乎符合这个概念(每个节拍/输入都建立了一个新的世界状态)，但我从来没有看到与之相关的FRP标签。
浏览 1提问于2013-07-02得票数 8
回答已采纳
这些天我一直在尝试用Rx编程。
现在，每次我开始使用它进行编程时，我都会问到这样一个问题:我真的需要像System.Reactive.*程序集这样的外部SDK库吗？每当我想要使用Rx编程时，我都必须使用observable：IObservable、IObserver等，但这些在mscorlib程序集中已经可用。
那么为什么我要下载这些反应式程序集并添加这些引用呢？
浏览 1提问于2014-02-16得票数 0
1回答
如果反应式编程避免了线程，而是使用对象之间的异步消息传递，那么如何管理可伸缩性？
如何决定何时需要新实例？是否有一些api可以透明地管理这一点？
浏览 0提问于2017-03-08得票数 1
我在一个项目中工作，其中DDD方法将用于开发，由于业务需求，将使用响应式编程方法。
我正在对域进行建模，当我在存储库的定义上工作时，出现了一些疑问。我在通过适配器实现存储库时看到了问题，因为使用反应式编程，所有方法都会返回Uni或Multi (Mutiny！将被使用)。这是一个问题，因为我在域中引入了与框架的依赖关系，这违反了DDD原则。
我在这个论坛上看到了一些帖子(例如：)，但我对提出的解决方案不太有信心。有没有人能够有效地应对这一挑战？
浏览 9提问于2021-06-01得票数 3
回答已采纳
我刚开始使用webflux进行反应式编程，之前我在spring boot上工作，在那里我使用hibernate作为ORM框架。我的疑问是，在反应式堆栈中，hibernate的替代品是什么，我必须使用哪个框架来连接和实现数据库逻辑。我正在使用mongoDB。
提前谢谢。
浏览 2提问于2021-02-24得票数 0
1回答
理解反应
、、
最近，kotlin流得到了广泛的关注。我以前从来没有做过任何反应式的编程，所以我认为现在是学习它的好时机。尽管我可以访问书籍和一些文章，但我无法理解如何集成它，比如在一个没有任何rxjava的现有应用程序上。我试着找一些样品，但他们给我的唯一东西是非常基本的。我真的很困惑于这种反应式的编程。例如，我需要在数据库中获得一个列表。我为什么要用流来获取数据呢？如果我把它形象化为流，那将给我一个数据。如果我得到了这个列表，我就可以得到整个列表，而无需等待每一个流的到来，如果我使用了流。我读了很多关于这个kotlin流的文章，甚至是rx。但是，我仍然想了解为什么流，它有什么不同的其他方式，就像我刚才给出
浏览 2提问于2020-01-12得票数 1
回答已采纳
我开始学习Java的反应式编程。整个反应式范式对我来说都是新的。
在我的学习过程中，我遇到了一些术语/库，比如Spring和RxJava。我希望有人能解释一下区别是什么，你在你的项目中使用了哪一个，以及为什么你做出了这个选择。
我读到Spring实际上在内部使用了WebFlux的Flux/Mono。这将问题简化为Spring Webflux在RxJava上的利弊？
浏览 2提问于2019-06-05得票数 33
回答已采纳
我看过，读过一些关于spring reactor的文章，但我不太理解它。
假设我已经激活了netty和spring reactor，那么让端点返回Flux/Mono实例(jacksonified)而不是直接返回dto对象(jacksonified)有什么好处？我最初假设，在http请求/响应上下文中，反应式流的工作方式更像websockets，其中服务器使用开放的通道将数据推送到接收器，但事实似乎并非如此。
另外，在反应式编程中，netty实际上比tomcat做得更好吗？
如果这些问题看起来很愚蠢，我很抱歉，但我不太理解这个新框架方向的目的。它为什么会出现，它是如何工作的，它解决了什么问题？
浏览 1提问于2016-12-05得票数 16
1回答
反应式/异步编程有一点折衷--为了提高性能，你需要牺牲更简单、更易读、更易维护的代码。 如果您计划在Micronaut REST应用程序中执行阻塞操作，在HTTP请求服务线程上执行这些操作是否被认为是可怕的做法？ 如果您要增加Micronaut中的HTTP请求服务线程池的大小，使其在大小上与常规HTTP框架的线程池的大小相似，例如非反应式Spring MVC / Tomcat，您会期望Micronaut的性能特征与运行在Tomcat上的Spring MVC相似吗？
浏览 50提问于2021-02-27得票数 0
回答已采纳
1回答
所以我知道承诺和函数式反应式编程。
我想要做的是调用一个异步函数，.then(回调)做一些事情，但是我不想马上定义回调。它让我想起了可观察到的RxJS，只是没有所有花哨的特性。
也许有人知道我在找什么。
浏览 4提问于2014-08-13得票数 2
回答已采纳
我正在使用io.lettuce.core库，但在使用RedisPubSubReactiveCommands接口订阅频道时遇到了问题。 我有一个StatefulRedisPubSubConnection和一个活动的redis集群，我正在尝试订阅它。 和connection.async().subscribe("channel")一样，connection.sync().subscribe("channel")运行得也很好。但是，当我使用由lettuce提供的反应式“热可观察”界面时，如下所示： connection.reactive().subscribe(ch
浏览 85提问于2019-10-03得票数 1
回答已采纳
当resteasy-reactive项目时，我得到了这个消息。
(build-70) Quarkus空: io.quarkus.resteasy.common.deployment.ResteasyCommonProcessor检测到需要Mutiny反应式编程支持，但是quarkus-resteasy-mutiny扩展不存在。我使用了以下依赖项的quarkus-resteasy-reactive-jackson。
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-
浏览 58提问于2021-03-01得票数 2
在wiki中：
在计算中，反应性编程是一种与数据流和变化传播有关的声明式编程范式。使用此范式，可以轻松地表示静态(例如数组)或动态(例如事件发射器)数据流，还可以传递关联执行模型中存在推断的依赖关系，这有助于更改数据流的自动传播。
因此，反应性编程只是一个与数据流有关的声明性编程范例。但是，为什么在许多情况下，反应性编程都是异步编程？
浏览 4提问于2021-08-17得票数 2
我正在努力完成EDx platform的EFPL -编程反应式系统课程的最后一个作业(名为反应式追随者)。
我能够完成除outgoingFlow之外的所有功能。
在我看来，我应该以某种方式从现有的流程创建一个新的源代码，在阅读了一些内容后，我仍然没有意识到如何执行流程来为新的源代码生成元素。
我尝试过使用mapConcat，但没有成功。
我认为现有的流程是：
eventParserFlow
.via(followersFlow)
.filter(p => isNotified(userId)(p))
现有Flow的类型和我试探性的do实现outgoingFlow可以在这里看到：
val
浏览 0提问于2019-07-03得票数 0
2回答
在反应式编程中，这是找到方法执行时间(getFavouriteDetails())的理想方法吗？
public List<Favourites> getFavouriteDetails(String userId){
userService.getFavorites(userId)
.flatMap(favoriteService::getDetails)
.switchIfEmpty(suggestionService.getSuggestions())
.take(5)
浏览 0提问于2018-07-06得票数 7
我刚刚读了，觉得它绝对很吸引人。
文档中描述的Scala.React包的状态如何？我找到了一个Scala.React快照的tarball，但似乎没有太多的文档或活动维护。我还发现了ScalaFX，它看起来可能与反应式编程有关，但同样没有维护。
有没有基于本文中的想法来创建基于reactives的GUI框架的项目？
浏览 0提问于2011-02-24得票数 57
在非反应式应用程序中，我们可以使用SecurityContextHolder.getContext().setAuthentication(authentication);以编程方式对请求进行身份验证。 Webflux的等价物是什么？ public class ReactiveServiceAuthenticationFilter implements WebFilter {
private final ReactiveAuthenticationManager authenticationManager;
public ReactiveServiceAuthentica
浏览 108提问于2020-04-24得票数 0
回答已采纳
我知道，并非函数式反应式编程(FRP)的每个组件都可以在大多数命令式语言中实现，这纯粹是因为语言是如何设计的。
但是，有没有可能使用C#中的事件来达到类似的效果，即某些输入值的更改会级联以更新各种对象？或者我已经回答了我的问题，除了“观察者”模式的变体之外，真的没有什么可以做的了？除了C#之外的其他命令式语言(我只是出于熟悉才在这里提到它)呢？
浏览 4提问于2014-05-01得票数 1
我目前正在R中创建一个闪亮的应用程序，我已经达到了将更高级的响应式编程放入我的代码中的地步。在这一点上，我正在尝试理解如何在反应式上下文中使用观察函数。但是，我还遇到了另一个响应式函数调用observeEvent。在R Shiny中，observe和obsereEvent的区别是什么？
浏览 0提问于2018-06-19得票数 0
我希望能够为特定请求从外部Api中获取数据，但当返回该数据时，还可以在缓存中使用该数据来表示应用程序的当前状态。
这一解决方案似乎有效：
var Rx = require('rx');
var cached_todos = new Rx.ReplaySubject(1);
var api = {
refresh_and_get_todos: function() {
var fetch_todos = Rx.Observable.fromCallback($.get('example.com/todos'));
return fetch_
浏览 3提问于2015-07-16得票数 4
有一种叫做反应式扩展的东西，也叫做ReactiveX。
引言中有这一部分，它说：
它有时被称为“函数式反应式编程”，但这是一个用词不当。ReactiveX可能是函数式的，也可能是反应式的，但“函数式反应式编程”是另一回事。主要的不同之处在于，函数式反应式编程对随时间不断变化的值进行操作，而ReactiveX则对随时间发出的离散值进行操作。(有关函数式反应式编程的更精确信息，请参阅Conal Elliott的工作。)
现在，如果我想了解/编写关于反应式扩展的内容？这是否意味着FRP <：反应式扩展所以反应式扩展也应该涵盖FRP。还是说这两个FRP和ReactiveX或者连续时间和离散时间是
浏览 16提问于2018-01-08得票数 0
这是我在笔记本电脑上尝试过的“用python进行反应式编程”一书中的代码。 import sys
from rx import Observable
argv = Observable.from_(sys.argv[1:])
argv.subscribe(
on_next=lambda i: print("on_next: {}".format(i)),
on_error=lambda e: print("on_error: {}".format(e)),
on_completed=lambda: print("on_comp
浏览 22提问于2019-09-25得票数 0
1回答
Rx映射函数并行
、、、
新的RxJava和反应式编程可以这么说。
我试图并行地映射两个函数，作为单个可观察管道的一部分，但似乎不是这样工作的。这是我的密码。
Observable.fromCallable(thatReturnsNumberOne())
.observeOn(newThread())
.map(doubleIt())
.observeOn(newThread())
.map(doubleIt())
.subscribe(testSubscrib
浏览 3提问于2017-08-17得票数 0
回答已采纳
1回答
Spring-Core5.2具有带有诸如StringDecoder解码器的编解码器包，该解码器支持反应式编程。获取Publisher<DataBuffer>并返回解码后的Flux<String>。 我希望找到gzip的Publisher<DataBuffer>或Publisher<ByteArray>的GzipDecoder，并返回未压缩的Flux<ByteArray>，但我没有找到它。 我发现唯一符合我需求库是https://github.com/kptfh/gzip-reactive，但它非常不成熟 熟悉成熟的代码吗？
浏览 12提问于2020-01-20得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
