协程库libco

ゝ一纸荒年。 2022-07-14 00:56 248阅读 0赞

**协程库libco**

libco是微信后台大规模使用的c/c++协程库，2013年至今稳定运行在微信后台的数万台机器上。libco在2013年的时候作为腾讯六大开源项目首次开源，最近做了一次[较大的更新][Link 1]。libco支持后台敏捷的同步风格编程模式，同时提供系统的高并发能力。

libco支持的特性

1.  支持CGI框架，轻松构建web服务(New);
2.  支持gethostbyname、mysqlclient、ssl等常用第三库(New);
3.  可选的共享栈模式，单机轻松接入千万连接(New);
4.  完善简洁的协程编程接口：

▪  类pthread接口设计，通过co\_create、co\_resume等简单清晰接口即可完成协程的创建与恢复;

▪  类\_\_thread的协程私有变量、协程间通信的协程信号量co\_signal (New);

▪  非语言级别的lambda实现，结合协程原地编写并执行后台异步任务 (New);

▪  基于epoll/kqueue实现的小而轻的网络框架，基于时间轮盘实现的高性能定时器。

libco产生的背景

早期微信后台因为业务需求复杂多变、产品要求快速迭代等需求，大部分模块都采用了半同步半异步模型。接入层为异步模型，业务逻辑层则是同步的多进程或多线程模型，业务逻辑的并发能力只有几十到几百。随着微信业务的增长，系统规模变得越来越庞大，每个模块很容易受到后端服务/网络抖动的影响。

异步化改造的选择

为了提升微信后台的并发能力，一般的做法是把现网的所有服务改成异步模型。这种做法工程量巨大，从框架到业务逻辑代码均需要做一次彻底的改造，耗时耗力而且风险巨大。于是开始考虑使用协程。

但使用协程会面临以下挑战：

1.    业界协程在c/c++环境下没有大规模应用的经验;  
    2.    如何控制协程调度;  
    3.    如何处理同步风格的API调用，如Socket、mysqlclient等;  
    4.    如何处理已有全局变量、线程私有变量的使用;

最终通过libco解决了上述的所有问题，实现了对业务逻辑非侵入的异步化改造。使用libco对微信后台上百个模块进行了协程异步化改造，改造过程中业务逻辑代码基本无修改。至今，微信后台绝大部分服务都已是多进程或多线程协程模型，并发能力相比之前有了质的提升，而libco也成为了微信后台框架的基石。

libco框架

![Center][]

同步风格API的处理

对于同步风格的API，主要是同步的网络调用，libco的首要任务是消除这些等待对资源的占用，提高系统的并发性能。一个常规的网络后台服务，可能会经历connect、write、read等步骤，完成一次完整的网络交互。当同步的调用这些API的时候，整个线程会因为等待网络交互而挂起。

虽然同步编程风格的并发性能并不好，但是它具有代码逻辑清晰、易于编写的优点，并可支持业务快速迭代敏捷开发。为了继续保持同步编程的优点，并且不需修改线上已有的业务逻辑代码，libco创新地接管了网络调用接口(Hook)，把协程的让出与恢复作为异步网络IO中的一次事件注册与回调。当业务处理遇到同步网络请求的时候，libco层会把本次网络请求注册为异步事件，本协程让出CPU占用，CPU交给其它协程执行。libco会在网络事件发生或者超时的时候，自动的恢复协程执行。

大部分同步风格的API都通过Hook的方法来接管了，libco会在恰当的时机调度协程恢复执行。

千万级协程支持

libco默认是每一个协程独享一个运行栈，在协程创建的时候，从堆内存分配一个固定大小的内存作为该协程的运行栈。如果用一个协程处理前端的一个接入连接，那对于一个海量接入服务来说，服务的并发上限就很容易受限于内存。为此，libco也提供了stackless的协程共享栈模式，可以设置若干个协程共享同一个运行栈。同一个共享栈下的协程间切换的时候，需要把当前的运行栈内容拷贝到协程的私有内存中。为了减少这种内存拷贝次数，共享栈的内存拷贝只发生在不同协程间的切换。当共享栈的占用者一直没有改变的时候，则不需要拷贝运行栈。

![200406_Qjyr_2896879.png][]

libco协程的共享协程栈模式使得单机很容易接入千万连接，只需创建足够多的协程即可。通过libco共享栈模式创建1千万的协程（E5-2670 v3 @ 2.30GHz \* 2, 128G内存），每10万个协程共享的使用128k内存，整个稳定echo服务的时候总内存消耗大概为66G。

协程私有变量

多进程程序改造为多线程程序时候，可以用\_\_thread来对全局变量进行快速修改，而在协程环境下，创造了协程变量ROUTINE\_VAR，极大简化了协程的改造工作量。

因为协程实质上是线程内串行执行的，所以当定义了一个线程私有变量的时候，可能会有重入的问题。比如定义了一个\_\_thread的线程私有变量，原本是希望每一个执行逻辑独享这个变量的。但当执行环境迁移到协程了之后，同一个线程私有变量，可能会有多个协程会操作它，这就导致了变量冲入的问题。为此，在做libco异步化改造的时候，把大部分的线程私有变量改成了协程级私有变量。协程私有变量具有这样的特性：当代码运行在多线程非协程环境下时，该变量是线程私有的；当代码运行在协程环境的时候，此变量是协程私有的。底层的协程私有变量会自动完成运行环境的判断并正确返回所需的值。

协程私有变量对于现有环境同步到异步化改造起了举足轻重的作用，同时定义了一个非常简单方便的方法定义协程私有变量，简单到只需一行声明代码即可。

gethostbyname的Hook方法

对于现网服务，有可能需要通过系统的gethostbyname API接口去查询DNS获取真实地址。在协程化改造的时候，发现hook的socket族函数对gethostbyname不适用，当一个协程调用了gethostbyname时会同步等待结果，这就导致了同线程内的其它协程被延时执行。

对glibc的gethostbyname源码进行了研究，发现hook不生效主要是由于glibc内部是定义了\_\_poll方法来等待事件，而不是通用的poll方法；同时glibc还定义了一个线程私有变量，不同协程的切换可能会重入导致数据不准确。最终gethostbyname协程异步化是通过Hook \_\_poll方法以及定义协程私有变量解决的。

gethostbyname是glibc提供的同步查询dns接口，业界还有很多优秀的gethostbyname的异步化解决方案，但是这些实现都需要引入一个第三方库并且要求底层提供异步回调通知机制。libco通过hook方法，在不修改glibc源码的前提下实现了的gethostbyname的异步化。

协程信号量

在多线程环境下，会有线程间同步的需求，比如一个线程的执行需要等待另一个线程的信号，对于这种需求，通常是使用pthread\_signal 来解决的。在libco中，定义了协程信号量co\_signal用于处理协程间的并发需求，一个协程可以通过co\_cond\_signal与co\_cond\_broadcast来决定通知一个等待的协程或者唤醒所有等待协程。

总结

libco是一个高效的c/c++协程库，提供了完善的协程编程接口、常用的Socket族函数Hook等，使得业务可用同步编程模型快速迭代开发。随着几年来的稳定运行，libco作为微信后台框架的基石发挥了举足轻重的作用。

[Link 1]: https://github.com/tencent/libco
[Center]: /images/20220714/ed00fe309e014248be2f51acd174c33b.png
[200406_Qjyr_2896879.png]: https://static.oschina.net/uploads/space/2016/1029/200406_Qjyr_2896879.png