Reactive编程指南

反应式编程在这几个月内一直是许多会议演讲的热门话题。找到简单的代码示例和教程并将它们应用于绿地新项目是毫不费力的。当需要从现有解决方案迁移时，特别是它是具有数百万用户和每秒数千个请求的生产服务时，事情变得有点复杂。在本文中，我想 通过一个Allegro微服务的例子讨论从

本文探讨如何使用RDBC2或MongoDB来使用Spring Reactive的事务支持。 在还没有加入响应式/反应式事务集成之间，Spring认为没有必须进行Reactive事务管理，因此，Spring Framework不支持Reactive

不久前，JDBC驱动程序的反应变体称为R2DBC发布了，它允许数据异步流式传输到已订阅它的任何端点，结合使用像R2DBC这样的反应式驱动程序和Spring WebFlux，可以编写一个完整的响应式应用程序来异步进行数据的接收和发送。在这篇文章中，我们将重点关注数据库端：从连接到数据库，然后最

Spring Cloud Hoxton.M1发布，将支持Spring Cloud Gateway RSocket! Spring Cloud Circuit Breaker项目将退出孵化器状态进入准备正式可用；鉴于Spring Cloud Netflix已经处于维护模式，将从Ribbon中删

不可否认的是，在Dev（和Ops最近）领域出现的数千项创新中，讨论最多的主题之一是反应式编程。新的FW框架不断推出，例如ReactiveX（RxJava）的Java语言的实现，最近推出的带有反应式编程的Spring 5，甚至是Java 8中的lambdas和流的推出（自2014年起），很明显

反应式编程承诺具有较低内存要求的企业Java应用程序的更高性能。通过避免阻塞始终导致操作系统中的进程和上下文切换的调用来实现此承诺。这种上下文切换具有高CPU和存储器开销，当然，这些开关减少了更少。然而，这种反应式编程的性能提升是以软件可维护性较差为代价的。但更高的性能是否物有所值？有哪些替

在看到Jurgen Hoeller引入新的Spring 5功能后，

Spring Framework最近公布了对反应性事务管理的支持。让我们深入了解一下这对于R2DBC（SQL数据库访问的反应规范）是如何工作的。事务管理是一种模

这是使用Reactor的Kafka案例方式，生产者代码如下：

Netifi Proteus是类似Spring Cloud的，但是基于RSocket构建的下一代反应式微服务平台，它让开发人员通过在单个可部署中透明地提供API管理，路由，服务发现，预测负载平衡和超低延迟RPC来专注于他们的产品。Spring Cloud各个组件之间通信时基于通常Pu

遗留代码。我们都讨厌它。因为它只能停留在旧技术上，有时候对代码进行即使轻微地更改也会导致您无法想象的错误。专业工程师不应该害怕遗产。 RxJava是一个库，可以帮助您改善遗留项目的情况，并从创建的代码中获得更多满足感。

本文的重点是使用Java构建RESTFul API，同时受益于反应式编程模型。但与大多数关于此主题的其他文章不同，本文不会急于直接编写代码。它将指导您完成此编程范例的主干，以便您对其有充分的了解。然后使用该知识构建API。该系列由两部分组成。第一部分介绍了反应系统和反应式编程，并清除

如何确保同时处理多个请求，我们可以使用线程或进程进行多任务处理实现，但还有一个选择 - 协作性多任务处理。这个选项是最困难的。在这里我们说操作系统当然很酷，它有调度程序/计划程序，它可以处理进程，线程，组织它们之间的切换，处理锁等，但它仍然不知道应用程序是如何工作的，而这些工作原理应

在本文中，我们将讨论微服务架构中的通信问题，以及如何使用RSocket解决这些问题。我们介绍了它的API和支持简单的“hello world”示例和基本背压机制实现的交互模型。RSocket是一种新的，消息驱动的二进制协议，它标准化了云中的通信方法。它有助于以一致的方式解决常见的应用

反应式系统应该是有弹性，实现这一目标的一种方法是让我们的应用程序彼此相邻地多次部署，如果一个实例出现故障，将会有其他实例负责其任务，从而为系统增加了更多的弹性。如果需要更多处理能力，可以临时调整更多实例，以处理额外的工作量，从而为我们的系统增加弹性。如今，创建这种架构最流行的方法之一

吞吐量性能取决于底层实现。在返回Stream之前将所有行收集到List的查询可能比从ResultSet中按元素读取要慢。Reactive目前会有更多开销，因此较小的结果会产生更高的总查询持续时间。当有大量数据时，这就会导致不同性能。响应式可以在处理已经收到的结果（智能预取）时获取下一