Reactor 正在参加 2021 年度 OSC 中国开源项目评选,请投票支持!
Reactor 在 2021 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
2021 年度 OSC 中国开源项目评选 正在火热进行中,快来投票支持你喜欢的开源项目!
2021 年度 OSC 中国开源项目评选 >>> 中场回顾
Reactor 获得 2021 年度 OSC 中国开源项目评选「最佳人气项目」 !
授权协议 Apache
开发语言 Java 查看源码 »
操作系统 跨平台
软件类型 开源软件
开源组织
地区 不详
投 递 者 红薯
适用人群 未知
收录时间 2013-05-14

软件简介

Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高,在最新的硬件平台上,使用无堵塞分发器每秒钟可处理 1500 万事件。

开源中国组织翻译的 Reactor 中文文档http://projectreactor.mydoc.io

示例代码:

// This helper method is like jQuery’s.
// It creates a Selector instance so you don’t have
// to construct one using 'new Selector("parse")'
import static reactor.Fn.$;
 
Reactor reactor = R.create();
 
// Register interest in events published to key "parse"
reactor.on($("parse"), new Consumer<Event<String>>() {
  public void call(Event<String> ev) {
    service.handleEvent(ev);
  }
});
 
// Send an event to this Reactor and trigger all actions
// that match the given Selector
reactor.notify("parse", Fn.event("Hello World!"));
展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (6)

加载中
写起来脑壳痛
2019/08/27 14:49
回复
举报
SpringSource出品 Reactor
2013/05/14 09:31
回复
举报
看到名字的第一反应JActor Reactor
2013/05/14 14:16
回复
举报
每秒钟可处理 1500 万事件 #Reactor#
2015/10/26 21:58
回复
举报
2016/01/07 14:58
回复
举报
#Reactor# 工作之余 学个Reactor如何
2016/03/07 16:24
回复
举报
更多评论
发表了资讯
2015/11/27 00:00

众包翻译文档分享 ——《Reactor 指南中文版》

《Reactor 指南中文版》日前在开源中国众包平台翻译完成,现发布在社区与各位 OSCer 共享: http://projectreactor.mydoc.io/ Reactor 官方文档翻译众包悬赏现已结赏,悬赏和结赏详情请看这里,感谢各位 OSCer 的支持。 Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高,在最新的硬件平台上,使用无堵塞分发器每秒钟可处理 1500...

23
116
发表了资讯
2015/02/19 00:00

Reactor 2.0.0.RC1 发布,支持 Reactive Stream

Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高,在最新的硬件平台上,使用无堵塞分发器每秒钟可处理 1500 万事件。 Reactor 2.0.0.RC1 发布,此版本现已提供在 the spring.io Maven repository 和 Maven central。版本 2.0 从 Reactor 版本 1.0 升级只是 #uberupdate,包括一些新组件和完全重写的类,比如 Stream,实现是 Reac...

1
19
发表了资讯
2014/10/22 00:00

Reactor 2.0.0.M1 发布,集成 Reactive Streams

Reactor 2.0.0.M1 发布,此版本完全兼容 Reactive Streams,完全重写了 Stream 和 Promise APIs! 同时还集成了其他 Reactive Streams: Akka Streams, Ratpack, RxJava 等等。Reactor 提供一个固定的函数来构建现代化的 #uberfastdata 应用,要求高通量,低延迟。 更多内容请看发行说明。 Github: https://github.com/reactor/reactor 在线 JavaDoc: http://reactor.github.io/docs/api/2.0.0.M1/index.html Reactor 是一个基...

2
11
发表了资讯
2014/05/07 00:00

Reactor 1.1.0 发布,异步应用基础库

Reactor 1.1.0 发布,该版本修复了很多 bug,重写了一些关键的组件使得框架运行更加快速以及降低内存的使用。Reactor 1.1 包含来自 Goldman Sachs 的 gs-collections 库,提供非常方便的API 来处理 Map 和其他集合类型。详细的介绍请看发行说明。 Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高,在最新的硬件平台上,使用无堵塞...

0
16
发表了资讯
2013/11/22 00:00

Reactor 1.0 GA 发布,异步应用基础库

Reactor 1.0 GA 发布,Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高,在最新的硬件平台上,使用无堵塞分发器每秒钟可处理 1500 万事件。 官方发行说明: https://spring.io/blog/2013/11/12/it-can-t-just-be-big-data-it-has-to-be-fast-data-reactor-1-0-goes-ga 示例代码: // This helper method is like jQuery’s. // I...

1
12
发表了资讯
2013/08/28 00:00

Reactor 1.0.0 M2 发布,异步应用基础库

Reactor 1.0.0 M2 包含 bug 修复和一些相当令人兴奋的新特性,包括一个 Processor 抽象,这是一个高度优化的任务处理器,基于 LMAX Disruptor RingBuffer。1.0.0 M2 的 API 中同时包含一个小的但是相当棒的新特性,它优化了事件发布的性能,提升了 30-50% 的吞吐量。详细的介绍请看发行说明。 Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。React...

2
12
发表了资讯
2013/07/19 00:00

Reactor 1.0.0 M1 发布,异步应用基础库

Reactor 1.0.0 M1 发布,该版本引入 TCP 支持,支持 Groovy 和 Spring,详细描述请看发行说明。 Reactor 是一个基于 JVM 之上的异步应用基础库。为 Java 、Groovy 和其他 JVM 语言提供了构建基于事件和数据驱动应用的抽象库。Reactor 性能相当高,在最新的硬件平台上,使用无堵塞分发器每秒钟可处理 1500 万事件。 示例代码: // This helper method is like jQuery’s. // It creates a Selector instance so you don’t have ...

4
19
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表于开发技能专区
2020/11/09 20:00

Reactor:深入理解reactor core

简介 上篇文章我们简单的介绍了Reactor的发展史和基本的Flux和Mono的使用,本文将会进一步挖掘Reactor的高级用法,一起来看看吧。 自定义Subscriber 之前的文章我们提到了4个Flux的subscribe的方法: Disposable subscribe(); Disposable subscribe(Consumer<? super T> consumer); Disposable subscribe(Consumer<? super T> consumer, Consumer<? super Throwable> errorConsumer); Disposable subscribe(Consumer...

0
0
发表于软件架构专区
2020/11/09 09:24

Reactor:深入理解reactor core

# 简介 上篇文章我们简单的介绍了Reactor的发展史和基本的Flux和Mono的使用,本文将会进一步挖掘Reactor的高级用法,一起来看看吧。 # 自定义Subscriber 之前的文章我们提到了4个Flux的subscribe的方法: ~~~java Disposable subscribe(); Disposable subscribe(Consumer consumer); Disposable subscribe(Consumer consumer, Consumer errorConsumer); Disposable subscribe(Consumer consumer, Consumer errorConsumer, Runn...

0
1
发表了博客
2018/02/23 15:48

Reactor

Flux和Mono   Flux和Mono是Reactor中的两个基本概念。Flux表示的是包含0到N个元素的异步序列。在该序列中可以包含三种不同类型的消息通知:正常的包含元素的消息,序列结束的消息和序列出错的消息。当消息通知产生时,订阅者中对应的方法onNext(),onComplete()和onError()会被调用。Mono表示的是包含0或1个元素的异步序列。该序列中同样可以包含与Flux相同的三种类型的消息通知。Flux和Mono之间可以进行转换。对一个Flux序列...

0
0
发表了博客
2018/03/27 14:58

reactor模式:单线程的reactor模式

reactor模式称之为响应器模式,常用于nio的网络通信框架,其服务架构图如下 不同于传统IO的串行调度方式,NIO把整个服务请求分为五个阶段 read:接收到请求,读取数据 decode:解码数据 compute:业务逻辑处理 encode:返回数据编码 send:发送数据 其中,以read和send阶段IO最为频繁 代码实现 1 // Reactor線程 2 package server; 3 4 import java.io.IOException; 5 import java.net.Ine...

0
0
发表于软件架构专区
2014/05/06 14:40

.NET Reactor 4.8

.NET Reactor是一款功能强大的代码保护以及许可授权管理系统软件,主要用于开发人员保护其.NET软件程序,.NET Reactor支持所有支持.NET编译的程序开发语言。控件中国网是.NET Reactor在中国正式的授权销售商,提供.NET Reactor购买服务、.NET Reactor销售、.NET Reactor技术支持等服务,详情请致电控件中国网:023-67870900。 .NET Reactor 是一款强大的 .NET 代码保护和许可管理系统,安全可靠、简单易用,主要用来帮助开发人员...

0
0
发表了博客
2013/12/26 11:39

reactor学习

from twisted.internet import reactor这里reactor默认为 selectreactor 若要选择其他类型的reactor则 from twisted.internet import pollreactor pollreactor.install() 我们得用Twisted来做什么吧。下面这段代码在reactor循环开始后向终端打印一条消息: def hello(): print 'Hello from the reactor loop!' print 'Lately I feel like I\'m stuck in a rut.' from twisted.internet import reactor reactor.callWhenRunning...

0
1
发表于软件架构专区
2018/05/08 00:25

Reactor模式

Reactor模式是什么? 反应器设计模式(Reactor pattern),是一种基于事件驱动的设计模式。Reactor框架是ACE各个框架中最基础的一个框架,其他框架都或多或少地用到了Reactor框架。 在事件驱动的应用中,将一个或多个客户的服务请求分离(demultiplex)和调度(dispatch)给应用程序。在事件驱动的应用中,同步地、有序地处理同时接收的多个服务请求。 reactor模式与外观模式有点像。不过,观察者模式与单个事件源关联,而反应器模...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表于大前端专区
2019/10/29 15:35

Spring boot 种reactor 里面publisher的map和flatMap操作符最终的区别是什么?执行流程是怎样的?

// map操作符 Flux flux = Flux.just(1,2,3,4) .log() .map(i->{ System.out.println("first:"+i); return i+1; }); System.out.println(flux.subscribe( System.out::println )); //flapMap操作符 Flux flux1 = Flux.just(1,2,3,4) .log() .flatMap(i->{ Flux flux2 = Flux.just(i); System.out.println("first:"+i); return flux2; }); flux.subscribe( System.out::println ); 测试输出完全一样。除了参数不一样外,本质的区...

3
0
2020/05/23 20:29

spring gateway 网关报错

访问量小的时候不会 现在访问起来了 网关一直报这个错 ERROR 116528 --- [server-epoll-38] reactor.core.publisher.Operators : Operator called default onErrorDropped reactor.ipc.netty.channel.AbortedException: Connection has been closed at reactor.ipc.netty.channel.ChannelOperationsHandler.discard(ChannelOperationsHandler.java:365) [reactor-netty-0.7.8.RELEASE.jar!/:0.7.8.RELEASE] at reactor.ipc.nett...

1
0
发表于软件架构专区
2019/11/22 15:59

springboot jdk11 spring-boot-starter-webflux 启动报错

2019-11-22 15:14:28.112 DEBUG 11988 --- [ main] .c.l.ClasspathLoggingApplicationListener : Application started with classpath: unknown . ____ _ __ _ _ /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \ ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \ \\/ ___)| |_)| | | | | || (_| | ) ) ) ) ' |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v2.2.1.RELEASE) 2019-11-22 ...

8
0
发表了问答
2017/10/13 13:21

如何理解Java8 Stream API是拉,Reactor是推

在Java8 Stream API里面,如果只有中间操作,没有终止操作。数据是不会进行处理的。 比如说,下面代码不会输出的 Stream.of("aa", "bb").map(x -> {   System.out.println("Stream input : " + x);   return x; }); 但是,在Reactor中,为什么如下代码也没有执行 Flux.just("aa", "bb").map(x -> {   System.out.println("Reactor input : " + x);   return x; }); Java8 Stream是只有碰到终止操作,才会真正执行。可以理解为拉 但是...

1
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
6 评论
286 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部