- 综合排序
- 最热优先
- 最新优先
- 来自专栏johnhuster
反应式编程之flux concatmap
publisher，下面看个例子 @Test public void concatmap(){ Student st1 = new Student("张三",90); Student st2 = new Student("宋江",85); List<Student> list1 = new ArrayList<>(); list1.add(st1); list1.add(st2) ; list1.add(st5); List<Student> list2 = new ArrayList<>(); list2.add(st3); list2.add(st4); Teacher t1 = new Teacher(); t1.setStudents(list1); Teacher t2 = new Teacher(); t2.setStudents(list2 (teachers).concatMap(t->Flux.fromIterable(t.getStudents())) .sort((s1,s2)->s1.getScore()-s2.getScore
73210编辑于 2022-03-28 - 来自专栏响应式编程
关于“反应式宣言”
Reactive Manifesto 的中文版都已经是“反应式宣言”了。看来公众号也要择机改名了。 反应式宣言英文版：https://www.reactivemanifesto.org/ 反应式宣言中文版：https://www.reactivemanifesto.org/zh-CN 前几年开始看到这些没有一行代码的宣言感觉好飘渺 反应式宣言最关键的四个单词：Responsive、Resilient、Elastic、Message Driven。 反应式系统依赖异步的消息传递机制在组件间建立边界，这就保证了组件之间的松耦合、隔离、以及位置透明。【感觉官方中文版翻译的有问题 组件之间的松耦合、隔离、位置透明是实现回弹性、回弹的条件。 Cloud 的服务就是通过服务注册[使能 Eureka 服务、在服务的 bootstrap 文件中把服务注册到 Eureka]、服务发现[1, 原始的 EnableDiscoveryClient 到 2，
85020编辑于 2022-05-30 - 来自专栏johnhuster
反应式编程之Mono.defer
public void defer(){ //声明阶段创建DeferClass对象 Mono<Date> m1 = Mono.just(new Date()); Mono<Date> m2 = Mono.defer(()->Mono.just(new Date())); m1.subscribe(System.out::println); m2.subscribe(System.out catch (InterruptedException e) { e.printStackTrace(); } m1.subscribe(System.out::println); m2.
1.2K10编辑于 2022-03-28 - 来自专栏TopCoder
从Redis异步到反应式架构
下面就这2种实现思路分别讨论下 :) 单连接+序列号通信方式 单连接+序列号通信方式理论上是可以的，不过由于RESP协议中并没有一个"序列号"的字段，所以直接靠原生的通信方法来实现是不现实的。 反应式架构 反应式架构中的反应式就是 Reactive，分析反应式架构之前，先了解下常见的异步化处理机制：线程池、事件驱动、消息驱动等。 线程池：业务中将耗时操作交给线程池来处理，不影响当前线程。 RxJava 已经广泛在大小公司中应用；最后，包括 Java 9（引入 Reactive Sreams 规范 API）、Spring 5（引入 Reactor/WebFlux）、Spring Boot 2 都开始拥抱 Reactive，说明反应式编程的确是趋势。 更多的反应式架构可参考：https://www.infoq.cn/article/2upHTmd0pOEUNmhY5-Ay
1.2K20发布于 2019-11-06 - 来自专栏码农小胖哥的码农生涯
反应式数据库连接规范R2DBC正式发布1.0，利好Webflux
R2DBC致力于为反应式编程 API操作关系型数据库带来规范支持，R2DBC不同于我们熟知的JDBC规范，它是异步的、响应式的，更多的介绍请参考我以前对R2DBC的介绍。 R2DBC规范的维护迭代上。 1.0 版本定义了可预见的未来的稳定状态，预计数据库驱动程序供应商将在今年全部升级到 R2DBC 1.0。这对喜欢反应式编程的同学是一个重大的利好消息，Spring Webflux狂喜。 r2dbc官网：r2dbc.io r2dbc介绍：Java 响应式关系数据库连接了解一下 r2dbc入门：只会JDBC连接MySQL? 来试试R2DBC吧 r2dbc框架实操：Spring Data R2DBC响应式操作MySQL
89410编辑于 2022-05-22 - 来自专栏CSDN技术头条
Java 平台反应式编程（Reactive Programming）入门
反应式流 反应式流（Reactive Streams）是一个反应式编程相关的规范。反应式流为带负压的异步非阻塞流处理提供了标准。 流中的元素可能是“1 -> 2 -> 3 -> 2”，也可能是其他合法的序列。每个元素表示了用户的一次操作的结果。订单的总价也是一个流，它的元素表示了由于商品数量变化所对应的总价。 单价10 <input type="number" value="1" data-price="10">
商品2， 下面代码的输出结果是：0、0、1、0、1、2。 Flux.just(1, 2, 3).concatMap(v -> Flux.interval(Duration.ofMillis(100)).take(v)) .toStream()9.4K60发布于 2018-03-26 - 来自专栏咖啡拿铁
反应式编程在微服务下的重生
反应式编程在好几年前就已经出现了，它原理是基于反应式编宣言。但是，由于反应式编程推广速度比较缓慢，导致很多人现在对其不是很了解。 反应式编宣言： https://www.reactivemanifesto.org 本文将从微服务角度阐述反应式编程，在深入解读之前，先为大家简单地介绍一些反应式编程的基本概念。 2. 组成 反应式编程的宣言是指导框架，具体的实现是有不同的版本。但是，它们都有两个共同的特征。 异步编程，非阻塞流：这是实现反应式编程的基础。 ? 但是，很多人把反应式编程和函数式编程混淆了。 这个时候，反应式编程的优点就体现出来了。它不管什么原因，处理不了就不请求发送。而且是立刻的。 微服务环境对反应式编程的新要求 ---- 不能以为反应式编程好像就是可以在微服务环境下安枕无忧。 这对很多现有的反应式编程框架都是挑战。 与云原生环境的整合 一些早期反应式编程框架，有自己的集群管理功能。而且这些功能，是以胖SDK的方式捆绑在反应式编程基本功能上的。
1K20发布于 2019-10-13 - 来自专栏kl的专栏
为什么使用Reactive之反应式编程简介
因为我们不是很了解反应式编程，所以会有这种感觉。没关系，下面看看反应式编程集大者Reactor是怎么阐述反应式编程的。 范例的一个实现，可以概括为： 反应式编程是一种涉及数据流和变化传播的异步编程范例。 反应式编程范例通常以面向对象的语言呈现，作为Observer设计模式的扩展。 异步组合2个值。 在将值List变为可用时将值聚合为a 。 在生产中，我们将继续Flux通过进一步组合或订阅它来异步处理。最有可能的是，我们会回归result Mono。 Callback和Future的这些风险是相似的，并且是反应式编程与该Publisher-Subscriber对的关系。
1K30编辑于 2023-11-18 - 来自专栏一个会写诗的程序员的博客
什么是反应式编程? 这里有你想要了解的反应式编程 (Reactive programming)
常用的反应式编程实现类库包括：Reactor、RxJava 2,、Akka Streams、Vert.x以及Ratpack。 Why 反应式编程的核心是基于事件流、无阻塞、异步的，使用反应式编程不需要编写底层的并发、并行代码。并且由于其声明式编写代码的方式，使得异步代码易读且易维护。 如果这样做，本质上就是将两个Web框架打包成一个，依靠if语句来区分反应式和非反应式。 与其将反应式编程模型硬塞进Spring MVC中，还不如创建一个单独的反应式Web框架，并尽可能多地借鉴Spring MVC。这样，Spring WebFlux就应运而生了。 反应式宣言(The Reactive Manifesto) 反应式系统是： 响应：该系统及时响应，如果在所有可能的。
6.3K42发布于 2020-03-20 - 来自专栏Android群英传
Kotlin上的反应式流-SharedFlow和StateFlow
点击上方蓝字关注我，知识会给你力量 在本教程中，你将学习Kotlin中的反应式流，并使用两种类型的流——SharedFlow和StateFlow，构建一个应用程序。 多年来，RxJava一直是反应式流的标准。现在，Kotlin提供了自己的反应式流实现，称为Flow。与RxJava一样，Kotlin Flow可以创建数据流并对其做出反应。 Kotlin Flow为反应式流提供了更直接和具体的实现。 Getting Started 你将在一个名为CryptoStonks5000的应用程序上工作。这个应用程序有两个界面。 MutableSharedFlow<SharedViewEffects>() // 1 val sharedViewEffects = _sharedViewEffects.asSharedFlow() // 2 viewModelScope.launch { // 1 for (i in 1..100) { // 2 delay(5000) // 3 _sharedViewEffects.emit
2.8K60发布于 2021-11-19 - 来自专栏深度学习与python
反应式单体：如何从 CRUD 转向事件溯源
客户支持平台是实践反应式能力的一个很好的用例。因为客户代理会处理来自不同渠道的案例，在这个过程中，很容易错失对高优先级案例的跟踪。 在讨论我们采取了哪些行动将单体应用变得具有反应式特征之前，我想要描述一下如果没有任何的遗留代码，能够重新开始的情况下，理想的解决方案是什么。 2 使用 Kafka Streams 作为事件溯源框架 有很多相关的文章讨论如何在 Kafka 之上使用 Kafka Streams 实现事件溯源。 如何通过重新划分事件来驱动反应式应用。 如何重新处理命令的历史，确保在响应事件的反应式服务不停机的情况下重建事件。 参考资料： 1.Martin Fowler，2005，https://martinfowler.com/eaaDev/EventSourcing.html 2.Neha Narkhede, 2016，https
1.2K20发布于 2021-11-11 - 来自专栏A周立SpringCloud
反应式编程在微服务下的重生
2. 组成 反应式编程的宣言是指导框架，具体的实现是有不同的版本。但是，它们都有两个共同的特征。 异步编程，非阻塞流：这是实现反应式编程的基础。 ? 但是，很多人把反应式编程和函数式编程混淆了。 所以，用不是很准确的方式总结反应式编程的主要部分，就是异步编程、非阻塞流和背压。 这个时候，反应式编程的优点就体现出来了。它不管什么原因，处理不了就不请求发送。而且是立刻的。 微服务环境对反应式编程的新要求 ---- 不能以为反应式编程好像就是可以在微服务环境下安枕无忧。 这对很多现有的反应式编程框架都是挑战。 与云原生环境的整合 一些早期反应式编程框架，有自己的集群管理功能。而且这些功能，是以胖SDK的方式捆绑在反应式编程基本功能上的。 总结 ---- 最近的趋势告诉我们，在分布式应用架构变成熟的过程中，反应式编程的作用慢慢被重新认识。
1K20发布于 2019-05-14 - 来自专栏vivo互联网技术
反应式编程 RxJava 设计原理解析
本文首发于 vivo互联网技术 微信公众号 链接： https://mp.weixin.qq.com/s/duO1pAfaKUI2_x_GVvZHMg 作者：Yunjie Ma 一、ReactiveX 与 RxJava ReactiveX 的全称为Reactive Extension，一般缩写为 Rx，即我们平常所说的反应式编程。
1.6K20发布于 2020-04-27 - 来自专栏IT技术精选文摘
使用Lagom和Java构建反应式微服务系统
介绍 Lagom是一个帮助您构建反应式微服务的框架。 大多数微服务框架着重于帮助您构建脆弱的单实例微服务，根据定义，这些微服务不具可扩展性或不具有弹性。 反应式微服务架构：分布式系统的设计原则，JonasBonér介绍了现代系统背后的基本原理以及如何构建。 （JonasBonér） 反应式微服务需求 看看基于微服务的架构，您很快就意识到他们有各种需求需要满足。 Lagom支持以下数据库： Cassandra PostgreSQL MySQL Oracle H2 Cassandra完全支持并集成到开发环境中
2.5K50发布于 2018-01-30 - 来自专栏一个会写诗的程序员的博客
【Kotlin 反应式编程】第1讲 你好，Reactive Programming
【Kotlin 反应式编程】第1讲 你好，Reactive Programming ? 1.创建 Gradle Kotlin 项目 ? image.png 2.传统的命令式编程风格 添加 rxkotlin 依赖 compile group: 'io.reactivex.rxjava2', name: 'rxkotlin', version = 10 val flag2 = isOdd(x2) println("flagA2:$flag2") } fun testImperative2() { var x = 7 = Thread { println("flagC2:${flag(10)}") } t1.start() t2.start() t1.join() } t1.start() t2.start() t1.join() t2.join() val t = System.currentTimeMillis()
71820发布于 2018-08-17 - 来自专栏信数据得永生
Java 设计模式最佳实践：六、让我们开始反应式吧
这一章将描述反应式编程范式，以及为什么它能很好地适用于带有函数元素的语言。读者将熟悉反应式编程背后的概念。我们将介绍在创建反应式应用时从观察者模式和迭代器模式中使用的元素。 这些示例将使用反应式框架和名为 RxJava（版本 2.0）的 Java 实现。 我们将讨论以下主题： 什么是反应式编程？ 反应式编程是一种依赖于异步数据流的范例。它是异步编程的事件驱动子集。相反，反应式系统是消息驱动的，这意味着接收器是预先知道的，而对于事件，接收器可以是任何观察者。 现在假设 C2 到 Cn 单元格等于 A2 到 An 加上 B2 到 Bn 的内容；同样的规则适用于所有单元格。 以下代码处理此错误： [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-wNIrKRWU-1657721282485)(img/fd64466a-2b93-43ce-9fe2
2.7K20编辑于 2022-09-08 - 来自专栏一个会写诗的程序员的博客
《Kotlin 反应式编程》使用 RxKotlin 实现一个极简的 http DSL （ Reactive Programming Using Rx Kotlin ）《Kotlin 反应式编程》使用
《Kotlin 反应式编程》使用 RxKotlin 实现一个极简的 http DSL Reactive Programming Using Rx Kotlin https://github.com/ReactiveX } } } @Test fun testHttpOnError() { val testUrl = "https://www2.
2.2K20发布于 2018-08-17 - 来自专栏Play & Scala 技术分享
反应式架构(1)：基本概念介绍 顶
PayPal凭借其基于Akka构建的反应式平台squbs，仅使用8台2vCPU虚拟机，每天可以处理超过10亿笔交易，与基于Spring实现的老系统相比，代码量降低了80%，而性能却提升了10倍。 B、C和D三列每个单元格的值均依赖其左侧的单元格，当我们在A列依次输入1、2和3时，变化会自动传递到了B、C和D三列，并触发相应状态变更，如下图： ? 2 为什么需要反应式？ 2.1 命令式编程 VS 声明式编程 实际上我们绝大多数程序员都在使用传统的命令式编程，这也是计算机的工作方式。 例如JDK1.3及以前的BIO是同步阻塞模式，JDK1.4发布的NIO是同步非阻塞模式，JDK1.7发布的NIO.2是异步非阻塞模式。 假设我们准备开发一个单点登录微服务，微服务框架使用 Dubbo 2.x，该版本尚未支持反应式编程，微服务接口之间调用仍然是同步阻塞方式。
2.1K10发布于 2019-12-12 - 来自专栏IT进修之路
关系数据构建反应式的spring驱动程序
先说说什么是响应式 响应式编程或反应式编程（英语：Reactive programming）是一种面向数据流和变化传播的编程范式，直白的说就是：将变化的值通过数据流进行传播。 反应式架构文章 WebFlux定点推送、全推送灵活websocket运用【推】 WebFlux前后端分离 -- 数据响应式展示 【推】 webflux+redis/mongodb提供响应式API【推】 今天就来整合一下springboot 和r2dbc 与mysql。 主要是采用 Spring Data R2DBC ，Spring Data R2DBC对R2DBC应用了熟悉的Spring抽象和存储库支持。 : org.springframework.data.r2dbc: DEBUG 实现一个简单数据操作 repository： import org.springframework.data.r2dbc.repository.Query
1.2K20发布于 2020-05-21 - 来自专栏wxilejun的专栏
Reactive UI -- 反应式编程UI框架入门学习 (转载非原创)
推荐一个反应式编程的MVVM跨平台框架。 反应式编程 反应式编程是一种相对于命令式的编程范式，由函数式的组合声明来构建异步数据流。要理解这个概念，可以简单的借助Excel中的单元格函数。 图片 上图中，A1=B1+C1，无论B1和C1中的数据怎么变化，A1中的值都会自动变化，这其中就蕴含了反应式/响应式编程的思想。 反应式编程对于数据的处理不关心具体的数据值是多少，只要构建出数据的函数式处理，就能并行的异步处理数据流。 2.控件和后台属性的对应关系更为直观，提高代码的可阅读性。 当然也有一定的缺陷，会增加代码量，并且增加View和ViewModel的耦合性。 >(); DisksSource2.Connect().Bind(out _disks).Subscribe(); 函数式组合声明 以一个读取磁盘文件夹信息的小功能为例。
3.4K20编辑于 2022-08-09
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号