Flink实战案例（十六）:Flink 异步IO 简介

本文主要是介绍Flink实战案例（十六）:Flink 异步IO 简介，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1 Aysnc I/O是啥？

Async I/O 是阿里巴巴贡献给社区的一个呼声非常高的特性，于1.2版本引入。

 主要目的：是为了解决与外部系统交互时网络延迟成为了系统瓶颈的问题。

 场景：

流计算系统中经常需要与外部系统进行交互，比如需要查询外部数据库以关联上用户的额外信息。通常，我们的实现方式是向数据库发送用户a的查询请求(例如在MapFunction中)，然后等待结果返回，在这之前，我们无法发送用户b的查询请求。这是一种同步访问的模式，如下图左边所示。

 

图中棕色的长条表示等待时间，可以发现网络等待时间极大地阻碍了吞吐和延迟。为了解决同步访问的问题，异步模式可以并发地处理多个请求和回复。也就是说，你可以连续地向数据库发送用户a、b、c等的请求，与此同时，哪个请求的回复先返回了就处理哪个回复，从而连续的请求之间不需要阻塞等待，如上图右边所示。这也正是 Async I/O 的实现原理。

2 提高吞吐量的两种方式对比

目标：提高吞吐量

 

这篇关于Flink实战案例（十六）:Flink 异步IO 简介的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---