reactor相关内容

Twisted.internet.reactor 是全球性的吗?

例如，如果一个应用程序执行fromtwisted.internet import reactor，而另一个应用程序执行相同操作，那么这些reactors 是否相同? 我之所以这么问是因为 Deluge 是一个使用 Twisted 的应用程序，看起来它使用反应器来连接他们的UI (gtk) 到由扭曲驱动的应用程序的其余部分(我试图了解源代码).例如，当 UI 关闭时，它只需调用 reactor ..

发布时间：2021-06-07 19:37:26 python networking twisted reactor Python

如果Redis是单线程的，怎么会这么快?

我目前正在尝试了解 Redis 的一些基本实现内容.我知道 redis 是单线程的，我已经偶然发现了以下问题:Redis是单线程的，那么并发I/O是怎么做的? 但我还是觉得我没理解对.Afaik Redis 使用一个单线程的反应器模式.因此，如果我理解正确，那么有一个观察者(处理 FD/传入/传出连接)将要完成的工作委托给它注册的事件处理程序.他们做实际的工作并设置例如.他们的响应作为事件给 ..

发布时间：2021-06-04 20:17:07 multithreading redis reactor single-threaded 其他开发

获取发布者来自输入流

我刚刚升级了我的 mongo-db-java-driver，现在方便的函数 GridFSBucket.uploadFromStream 已经消失了.因此我们现在得到了一个 GridFSUploadPublisheruploadFromPublisher(字符串文件名，Publisher 来源)； 任何想法如何将我的 InputStream 转换为 Publisher?java驱动程序或Reac ..

发布时间：2021-06-03 20:46:42 java mongodb-java bytebuffer reactor publisher Java开发

项目反应堆:collectList()对Flux.create()不起作用

下面的示例显示从1到10的整数以及(7，8，9，10)的列表 public void streamCollect(){ConnectableFlux连接= Flux.range(1，10).发布();connect.subscribe(v-> System.out.println("1:" + v));连接.filter(数字->数字> 6).collectList().s ..

发布时间：2021-05-18 21:13:37 java reactor Java开发

如何转换List< Mono<>>到Mono< List< T>> ;?

我有一个返回 Mono 的方法: 接口处理器{单声道处理(输入输入)；} 我想为集合执行此 processor 方法: List输入=//获取输入处理器处理器=//获取处理器List输出= inputs.stream().map(supplier :: supply).collect(toList()); 但我想获取的 ..

发布时间：2021-05-18 20:49:24 java project-reactor reactor Java开发

将所有消息发送到Kafka之前，反应式程序退出得较早

这是先前反应式kafka问题(将数据流量发送到反应式kafka 时发出的问题)的后续问题. 我正在尝试使用反应式方法将一些日志记录发送到kafka.这是使用响应式kafka发送消息的响应式代码. 公共类LogProducer {私有最终KafkaSender发件人公共LogProducer(String bootstrapServers){Map ..

发布时间：2021-05-08 20:43:51 apache-kafka project-reactor flux reactor reactive-kafka 其他开发

Spring Reactor合并vs Concat

我在玩Spring Reactor，我看不到 concat 和 merge 运算符 之间的任何区别 这是我的例子 @Test公共无效merge(){助焊剂flux1 = Flux.just("hello").doOnNext(value-> {尝试 {Thread.sleep(1000);} catch(InterruptedException e){e.printSta ..

发布时间：2021-05-08 20:43:28 java spring flux reactor Java开发

.NET Reactor的.NET程序集保护

我正在测试Eziriz .NET Reactor ，以保护使用Visual Studio 2010 C#WPF开发的软件. 当.NET Reactor询问要保护哪个程序集时，我感到困惑.我虽然应该保护用户要安装的.msi文件.但是它要求我上传一个程序集文件，它是一个.exe文件.因此，我将.exe上传到我的bin/Debug文件夹中，该文件夹是通过在Visual Studio中构建解决方案而 ..

发布时间：2021-04-01 19:49:13 .net protection reactor C#/.NET

如何使用Reactor框架2.x在多线程映射/归约中捕获/检测异常？

我正在使用此答案，它可以正常运行。 但是，如果引发异常，则调用者代码不会捕获该异常。 如何在反应堆2.0流中捕获异常？ 我想做的是：如果抛出异常，则流处理必须停止。我需要在调用者线程（首先创建蒸汽的线程）中抛出异常。 List>数据= readData（）; Streams.from（数据） .flatMap（m-> S ..

发布时间：2020-10-07 21:28:03 java multithreading concurrency mapreduce reactor Java开发

Python扭曲了停止具有多个客户端的Reactor

如果我通过这样做创建了多个客户： def main（）： 客户= [无] *范围（0，10）中i的* 10 ： 客户端[i] = ClientFactory（） react.connectTCP（'192.168.0.1'，8000，客户端[ i]） Reactor.run（） 如何-优雅地-停止反应堆？如果我这样做： self.transport. ..

发布时间：2020-10-02 18:53:51 python client-server twisted reactor Python

nodejs是否代表Reactor或Proactor设计模式?

许多在线文章都将nodejs演示为反应堆模式的示例.它不是前摄者吗? 据我了解，两者之间的区别是: 反应器在单个线程中(同步)处理事件， proactor处理事件的原因是多个线程(异步)与完成回调. 例如，在本文中: Reactor Pattern是Node.js中的非阻塞I/O操作的想法.该模式提供了与每个I/O操作相关联的处理程序(对于Node.js，是一个回调函数) ..

发布时间：2020-09-06 19:48:02 node.js design-patterns architecture reactor 其他开发

默认情况下，Spring Reactor中的订阅者是否不受限制?

我一直在Spring Reactor中工作，并且之前进行过一些测试，这些使我感到奇怪，默认情况下，助焊剂如何处理背压.我知道onBackpressureBuffer等存在，并且我还阅读了所以，任何人都可以为我澄清一下:Reactor 3中的助焊剂默认的背压行为是什么? 我尝试搜索答案，但是找不到任何明确的答案，仅找到Backpressure的定义或上面针对RxJava链接的答案 解决方 ..

发布时间：2020-07-09 03:58:08 spring rx-java rx-java2 project-reactor reactor 其他开发

带有非流应用程序/json的Spring WebFlux Flux行为

我正在使用Spring Webflux进行评估，但我们必须支持希望使用application/json而不是application/stream + json的客户端.我不清楚在需要application/json的客户端中，Spring WebFlux如何处理序列化Flux. 如果将Flux序列化为application/json而不是application/stream + json，这 ..

发布时间：2020-07-09 01:00:29 java spring spring-webflux reactor Java开发

如何在Spring 5 WebFlux WebClient中设置超时

我正在尝试在WebClient上设置超时，这是当前代码: SslContext sslContext = SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build(); ClientHttpConnector httpConnector = new ReactorClient ..

发布时间：2020-07-05 06:53:08 spring reactor spring-webflux reactor-netty 其他开发

Reactor 3.x:是否有节流阀最新操作符(合并)?

在rx-java 2.x中，有一个名为 throttleLatest 的运算符，它可以根据给定的时间压缩传入的事件: https://github.com/ReactiveX/RxJava/pull/5979 Reactor 3中是否有类似的运算符? 还是可以通过组合其他运算符来获得相同的行为? 解决方案 否，目前截至反应堆核心3.2.0/3.1.9，尚无此类运算符. ..

发布时间：2020-07-05 06:31:49 reactive-programming rx-java2 project-reactor reactor reactive-streams 其他开发

扭曲-通过KeyboardInterrupt中断回调

我目前正在使用Twisted在回调内的for循环中重复执行任务，但是如果用户通过Ctrl-C发出KeyboardInterrupt，我希望反应堆中断回调中的循环(一个).根据我的测试，反应堆仅在回调结束时停止或处理中断. 在回调运行的中间，有什么方法可以发送KeyboardInterrupt到回调或错误处理程序吗? 干杯 克里斯 #!/usr/bin/env python ..

发布时间：2020-06-29 19:03:52 twisted reactor keyboardinterrupt 其他开发

用Reactor抛出异常的正确方法

我是项目反应器和反应性编程的新手. 我目前正在编写类似于以下代码: Mono.just(userId) .map(repo::findById) .map(user-> { if(user == null){ throw new UserNotFoundException(); } return u ..

发布时间：2020-06-26 23:38:24 java reactive-programming project-reactor reactor Java开发

如何限制活动的Spring WebClient调用的数量

我有一个要求，我使用Spring Batch从SQL DB中读取一堆行（数千），并在写入Kafka主题之前调用REST服务来丰富内容。 使用Spring Reactive webClient时，如何限制活动非阻塞服务调用的数量？在使用Spring Batch读取数据后，我是否应该以某种方式在循环中引入Flux？ （我理解delayElements的用法，它用于不同的目的，就像单个获取服 ..

发布时间：2019-01-10 13:34:41 java webclient project-reactor reactor Java开发

Akka或Reactor

我正在开始一个新项目（基于java）。我需要将其构建为模块化，分布式和弹性架构。 因此，我希望业务流程能够相互通信，可互操作，还可以独立。 我现在正在寻找两个框架，除了它们的年龄差异外，还表达了两种不同的观点： Akka（ http://akka.io ） Reactor（ https://github.com/reactor/reactor ） 选择上述框架之一时我应该 ..

发布时间：2018-12-25 20:03:40 java spring akka reactor project-reactor Java开发

如何使用Reactor框架2.x执行多线程map / reduce？

我以前曾询问此问题 for Reactor 1.x： 假设我有一个 Collection 。我想： 将每个映射实例转换为 Foo 并发（每个实例完全独立于另一个实例 - 不需要连续/迭代地转换每个实例）。 当所有实例都转换时，想要aa方法， onReduce（Collection foos），被调用 - 参数包含所有的结果 Foo 实例。 但是我们似 ..

发布时间：2016-12-26 19:07:56 java multithreading concurrency mapreduce reactor Java开发