最新 最热

【Linux】高级IO --- Reactor网络IO设计模式

1. 多路转接接口select poll epoll所做的工作其实都是事件通知,只向上层通知事件到来,处理就绪事件的工作并不由这些API来完成,这些接口在进行事件通知时,有没有自己的策略呢? 其实是有的,在网络编程中,select poll 只支持LT...

2023-10-17
2

Reactor 第十一篇 WebFlux集成Redis

在现代的分布式系统中,缓存是提高性能和扩展性的重要组成部分之一。Redis 是一个开源、内存中的数据结构存储系统,可以用作数据库、缓存和消息中间件。而 WebFlux 是 Spring 框架提供的响应式编程模型,在处理高并发和大...

2023-09-19
2

Reactor 第十篇 定制一个生产的WebClient

刚开始尝试使用 Spring WebFlux 的时候,很多人都会使用 Mono.fromFuture() 将异步请求转成 Mono 对象,或者 Mono.fromSupplier() 将请求转成 MOno 对象,这两种方式在响应式编程中都是不建议的,都会阻塞当前线程。...

2023-08-25
2

【Reactor第八篇】WebFlux 服务编排

WebFlux 服务编排是指使用 WebFlux 框架来编排多个异步服务的执行顺序和数据流动,从而构建出一个完整的、基于事件驱动的响应式应用程序。

2023-05-01
2

【Netty】主从反应器 ( Reactor ) 多线程模型

单反应器 ( Reactor ) 单线程模型 弊端 : 反应器 ( Reactor ) 运行在一个线程中 , 同时处理客户端连接 , 与客户端数据收发 , 在高并发的情况下会产生阻塞 ;

2023-03-27
2

python twisted deferredlist用法

from twisted.internet import reactor,defer,protocol

2022-05-14
2

python twisted 建立一个简单连接tcpConnection

from twisted.internet import reactor,protocol

2022-05-14
2

反应式编程之flux concatmap

本文基于project reactor,,reactor-bom版本为Dysprosium-SR4,flux concatMap方法作用是将多个publisher组合起来,然后依次消费,消费的顺序跟传入的顺序相同,消费完一个publisher后才开始消费下一个publisher,下面看个例子...

2022-03-28
2

mono subscribe源码分析

https://blog.csdn.net/john1337/article/details/101028908这篇文章已经对整个project reactor工作流程做了概述,本文对mono的subscribe源码进行更细的描述:

2022-03-28
3

修复 Spring Cloud Gateway 项目中无法通过 Skywalking 追踪 WebClient 调用的问题

Skywalking 通过 java agent 的方式为 java 应用带来无侵入的分布式链路采集。

2022-03-05
2