- 综合排序
- 最热优先
- 最新优先
- 来自专栏Java编程技术
如何从JDK8 Stream转换为反应式流？
一、前言 最近在做一个项目，获取JDK8 Stream对象后，想要批量消费，不想自己写个集合来做批量处理。 而反应式编程实现比如rxjava或者reactor是有丰富的流操作符，所以调研了下如何把JDK8 Stream转换为反应式流。 如果不想实现上面繁琐代码，我们可以考虑吧JDK 8Stream切换到反应式实现框架比如Reactor或者Rxjava，因为后者有丰富的流操作符。 总结 在Java 8中引入了Stream，它旨在有效地处理数据流（包括原始类型)。
91110发布于 2020-07-03 - 来自专栏johnhuster
反应式编程之flux concatmap
本文基于project reactor，，reactor-bom版本为Dysprosium-SR4，flux concatMap方法作用是将多个publisher组合起来，然后依次消费，消费的顺序跟传入的顺序相同，消费完一个publisher后才开始消费下一个publisher，下面看个例子
73110编辑于 2022-03-28 - 来自专栏响应式编程
关于“反应式宣言”
Reactive Manifesto 的中文版都已经是“反应式宣言”了。看来公众号也要择机改名了。 反应式宣言英文版：https://www.reactivemanifesto.org/ 反应式宣言中文版：https://www.reactivemanifesto.org/zh-CN 前几年开始看到这些没有一行代码的宣言感觉好飘渺 反应式宣言最关键的四个单词：Responsive、Resilient、Elastic、Message Driven。 反应式系统依赖异步的消息传递机制在组件间建立边界，这就保证了组件之间的松耦合、隔离、以及位置透明。【感觉官方中文版翻译的有问题 组件之间的松耦合、隔离、位置透明是实现回弹性、回弹的条件。
85020编辑于 2022-05-30 - 来自专栏johnhuster
反应式编程之Mono.defer
本文基于project reactor，，reactor-bom版本为Dysprosium-SR4，project reactor数据源大致可以分为两类：恶汉型跟懒汉型，
1.2K10编辑于 2022-03-28 - 来自专栏TopCoder
从Redis异步到反应式架构
反应式架构 反应式架构中的反应式就是 Reactive，分析反应式架构之前，先了解下常见的异步化处理机制：线程池、事件驱动、消息驱动等。 线程池：业务中将耗时操作交给线程池来处理，不影响当前线程。 反应式架构，从低纬度来说，比如针对网络通信这块，可以通过Reactor机制（比如Java的NIO/Selector等）来完成异步处理；从高纬度来说，就是在一整个业务链路中，涉及到可能造成阻塞的环节都改造成异步处理 目前针对反应式架构，业界已经有一些对应的开源解决方案，比如Java 8 已经逐渐普及，因为它包含对 Lambda 的支持，这让开发者对 Lambda 的接受度大大提高；同时 Reactive 相关的业务框架在业界已有成熟的实现 最后，包括 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 - 来自专栏CSDN技术头条
Java 平台反应式编程（Reactive Programming）入门
Java 8 的 java.util.stream.Stream 可以看成是对 Iterable 的一种扩展，可以包含无限元素。 Java 8 的 CompletableFuture 的出现解决了上面提到的 Future 的问题。而解决的办法是允许异步操作进行级联。比如有一个服务用来生成报表，另外一个服务用来发送电子邮件。 DOCTYPE html><html> <head> <meta charset="utf-<em>8</em>" /> <meta http-equiv="X-UA-Compatible" content toStream() 是把 Flux 转换成 Java 8 的 Stream ，这样可以阻止主线程退出直到流中全部元素被消费。 在服务器端，WebFlux 支持两种不同的编程模型：第一种是 Spring MVC 中使用的基于 Java 注解的方式；第二种是基于 Java 8 的 Lambda 表达式的函数式编程模型。
9.4K60发布于 2018-03-26 - 来自专栏咖啡拿铁
反应式编程在微服务下的重生
反应式编程在好几年前就已经出现了，它原理是基于反应式编宣言。但是，由于反应式编程推广速度比较缓慢，导致很多人现在对其不是很了解。 反应式编宣言： https://www.reactivemanifesto.org 本文将从微服务角度阐述反应式编程，在深入解读之前，先为大家简单地介绍一些反应式编程的基本概念。 组成 反应式编程的宣言是指导框架，具体的实现是有不同的版本。但是，它们都有两个共同的特征。 异步编程，非阻塞流：这是实现反应式编程的基础。 ? 但是，很多人把反应式编程和函数式编程混淆了。 比如K8s的扩容，每30秒采集一次。还要算平均值。这些都很难及时反应。等到算出有问题，时间已经过了很久。而且很多的时候，故障就是小抖动，突然慢下来，但无法体现在平均值上。 这对很多现有的反应式编程框架都是挑战。 与云原生环境的整合 一些早期反应式编程框架，有自己的集群管理功能。而且这些功能，是以胖SDK的方式捆绑在反应式编程基本功能上的。
1K20发布于 2019-10-13 - 来自专栏kl的专栏
为什么使用Reactive之反应式编程简介
因为我们不是很了解反应式编程，所以会有这种感觉。没关系，下面看看反应式编程集大者Reactor是怎么阐述反应式编程的。 范例的一个实现，可以概括为： 反应式编程是一种涉及数据流和变化传播的异步编程范例。 反应式编程范例通常以面向对象的语言呈现，作为Observer设计模式的扩展。 我们使用Java 8 Stream将处理的建议数限制为五个，并在UI中的图形列表中显示它们。 在每个级别，我们以相同的方式处理错误：在弹出窗口中显示它们。 回到最喜欢的ID级别。 尽管Java 8中带来了改进，但期货比回调要好一些，但它们在构图方面仍然表现不佳CompletableFuture。一起编排多个未来是可行但不容易的。
1K30编辑于 2023-11-18 - 来自专栏一个会写诗的程序员的博客
什么是反应式编程? 这里有你想要了解的反应式编程 (Reactive programming)
反应式编程与Java8提供的Streams有众多相似之处(尤其是API上)，且提供了相互转化的API。 Why 反应式编程的核心是基于事件流、无阻塞、异步的，使用反应式编程不需要编写底层的并发、并行代码。并且由于其声明式编写代码的方式，使得异步代码易读且易维护。 如果这样做，本质上就是将两个Web框架打包成一个，依靠if语句来区分反应式和非反应式。 反应式宣言(The Reactive Manifesto) 反应式系统是： 响应：该系统及时响应，如果在所有可能的。 参考资料 https://baike.baidu.com/item/%E5%8F%8D%E5%BA%94%E5%BC%8F%E7%BC%96%E7%A8%8B/19928105 https://blog.csdn.net
6.3K42发布于 2020-03-20 - 来自专栏Android群英传
Kotlin上的反应式流-SharedFlow和StateFlow
点击上方蓝字关注我，知识会给你力量 在本教程中，你将学习Kotlin中的反应式流，并使用两种类型的流——SharedFlow和StateFlow，构建一个应用程序。 多年来，RxJava一直是反应式流的标准。现在，Kotlin提供了自己的反应式流实现，称为Flow。与RxJava一样，Kotlin Flow可以创建数据流并对其做出反应。 Kotlin Flow为反应式流提供了更直接和具体的实现。 Getting Started 你将在一个名为CryptoStonks5000的应用程序上工作。这个应用程序有两个界面。
2.8K60发布于 2021-11-19 - 来自专栏A周立SpringCloud
反应式编程在微服务下的重生
组成 反应式编程的宣言是指导框架，具体的实现是有不同的版本。但是，它们都有两个共同的特征。 异步编程，非阻塞流：这是实现反应式编程的基础。 ? 但是，很多人把反应式编程和函数式编程混淆了。 所以，用不是很准确的方式总结反应式编程的主要部分，就是异步编程、非阻塞流和背压。 比如K8s的扩容，每30秒采集一次。还要算平均值。这些都很难及时反应。等到算出有问题，时间已经过了很久。而且很多的时候，故障就是小抖动，突然慢下来，但无法体现在平均值上。 这个时候，反应式编程的优点就体现出来了。它不管什么原因，处理不了就不请求发送。而且是立刻的。 微服务环境对反应式编程的新要求 ---- 不能以为反应式编程好像就是可以在微服务环境下安枕无忧。 这对很多现有的反应式编程框架都是挑战。 与云原生环境的整合 一些早期反应式编程框架，有自己的集群管理功能。而且这些功能，是以胖SDK的方式捆绑在反应式编程基本功能上的。
1K20发布于 2019-05-14 - 来自专栏深度学习与python
反应式单体：如何从 CRUD 转向事件溯源
产品的愿景逐渐朝反应式特性演化，这意味着要在正确的背景下对多个领域事件作出实时反应。但是，问题在于我们的单体应用被设计成了一个典型的 CRUD 系统，也就是在状态发生变化时同步运行业务逻辑。 客户支持平台是实践反应式能力的一个很好的用例。因为客户代理会处理来自不同渠道的案例，在这个过程中，很容易错失对高优先级案例的跟踪。 在讨论我们采取了哪些行动将单体应用变得具有反应式特征之前，我想要描述一下如果没有任何的遗留代码，能够重新开始的情况下，理想的解决方案是什么。 如何通过重新划分事件来驱动反应式应用。 如何重新处理命令的历史，确保在响应事件的反应式服务不停机的情况下重建事件。
1.2K20发布于 2021-11-11 - 来自专栏vivo互联网技术
反应式编程 RxJava 设计原理解析
duO1pAfaKUI2_x_GVvZHMg 作者：Yunjie Ma 一、ReactiveX 与 RxJava ReactiveX 的全称为Reactive Extension，一般缩写为 Rx，即我们平常所说的反应式编程 RxJava 是 ReactiveX Java语言的实现，其编程体验与Java 8中的函数式编程和流（Stream）有很大的相似之处，在掌握了Java8的相关知识后，你可以很轻松的就上手使用 RxJava Observable是支持链式操作的，就和Java 8中的Stream一样，我们来考虑这样一行代码。
1.6K20发布于 2020-04-27 - 来自专栏IT技术精选文摘
使用Lagom和Java构建反应式微服务系统
介绍 Lagom是一个帮助您构建反应式微服务的框架。 大多数微服务框架着重于帮助您构建脆弱的单实例微服务，根据定义，这些微服务不具可扩展性或不具有弹性。 反应式微服务架构：分布式系统的设计原则，JonasBonér介绍了现代系统背后的基本原理以及如何构建。 （JonasBonér） 反应式微服务需求 看看基于微服务的架构，您很快就意识到他们有各种需求需要满足。 所有Lagom API都使用Akka Stream的异步IO功能进行异步流; Java API使用JDK8 CompletionStage进行异步计算。 创建您的第一个Lagom应用程序 您需要开始的一切都是JDK（Java Development Kit）8和Maven（3.3或更高版本）。 Maven下载依赖项并为您创建项目结构。
2.5K50发布于 2018-01-30 - 来自专栏一个会写诗的程序员的博客
【Kotlin 反应式编程】第1讲 你好，Reactive Programming
【Kotlin 反应式编程】第1讲 你好，Reactive Programming ? 1.创建 Gradle Kotlin 项目 ?
71820发布于 2018-08-17 - 来自专栏信数据得永生
Java 设计模式最佳实践：六、让我们开始反应式吧
这一章将描述反应式编程范式，以及为什么它能很好地适用于带有函数元素的语言。读者将熟悉反应式编程背后的概念。我们将介绍在创建反应式应用时从观察者模式和迭代器模式中使用的元素。 这些示例将使用反应式框架和名为 RxJava（版本 2.0）的 Java 实现。 我们将讨论以下主题： 什么是反应式编程？ 根据这个页面的说法，一个没有回应的网站在搜索引擎中的排名很低： “响应式设计是谷歌的推荐设计模式” 反应式系统是一种使用元素构成复杂系统的架构风格，有些元素是用反应式编程技术构建的。 反应式编程是一种依赖于异步数据流的范例。它是异步编程的事件驱动子集。相反，反应式系统是消息驱动的，这意味着接收器是预先知道的，而对于事件，接收器可以是任何观察者。 ，然后重点介绍了可用的最常用的反应式库之一——RxJava。
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 "Kotlin") val postBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"
2.2K20发布于 2018-08-17 - 来自专栏Play & Scala 技术分享
反应式架构(1)：基本概念介绍 顶
PayPal凭借其基于Akka构建的反应式平台squbs，仅使用8台2vCPU虚拟机，每天可以处理超过10亿笔交易，与基于Spring实现的老系统相比，代码量降低了80%，而性能却提升了10倍。 1.4 反应式宣言 2013年6月，Roland Kuhn等人发布了《反应式宣言》， 该宣言定义了反应式系统应该具备的一些架构设计原则。符合反应式设计原则的系统称为反应式系统。 根据利特尔法则， 总线程数量(L) = TPS(λ)*平均响应时间(W)， 即： 总线程数量(L) = (1000*0.5) = 500 假设每个计算节点配置为4C8G， 那么一共需要 (500 利用Java 8提供的CompletableFuture和Lambda两个特性，我们对2.2节的示例进行异步化改造，改造后代码如下： private PhonePlanCache cache; Reactive systems，Jonas Bonér and Viktor Klang PayPal Blows Past 1 Billion Transactions Per Day Using Just 8
2.1K10发布于 2019-12-12 - 来自专栏IT进修之路
关系数据构建反应式的spring驱动程序
先说说什么是响应式 响应式编程或反应式编程（英语：Reactive programming）是一种面向数据流和变化传播的编程范式，直白的说就是：将变化的值通过数据流进行传播。 反应式架构文章 WebFlux定点推送、全推送灵活websocket运用【推】 WebFlux前后端分离 -- 数据响应式展示 【推】 webflux+redis/mongodb提供响应式API【推】 configuration> <source>${java.version}</source> <target>${java.version}</target> <encoding>UTF-8<
1.2K20发布于 2020-05-21 - 来自专栏wxilejun的专栏
Reactive UI -- 反应式编程UI框架入门学习 (转载非原创)
推荐一个反应式编程的MVVM跨平台框架。 反应式编程 反应式编程是一种相对于命令式的编程范式，由函数式的组合声明来构建异步数据流。要理解这个概念，可以简单的借助Excel中的单元格函数。 图片 上图中，A1=B1+C1，无论B1和C1中的数据怎么变化，A1中的值都会自动变化，这其中就蕴含了反应式/响应式编程的思想。 反应式编程对于数据的处理不关心具体的数据值是多少，只要构建出数据的函数式处理，就能并行的异步处理数据流。 Reactive UI Reactive UI 是一种反应式编程的跨平台MVVM框架，支持Xamarin Forms、Xamarin.iOS、Xamarin.Android、Xamarin.Mac、Tizen
3.4K20编辑于 2022-08-09
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号