之前在项目中引入 libuv,主要是 libuv 是 C 库(意味着回调函数必须是 C 风格的回调),屏蔽 libuv 本身的 api,做了一层 C++11/14 风格的封装。这个库现在跑在一个线上项目上,做过压测,陆陆续续修复掉一些 bug,现在基本比较稳定了。
代码这里:
https://github.com/wlgq2/libuv_cpp11
主要是简化了 TCP 编程,定义或者继承一个 uv::TcpServer、uv::Client 的对象,设置相应回调函数即可使用(回调可以是类成员函数或者 lambda ),以及线程安全的写数据操作( libuv 的所有 api 均非线程安全,所以提供了一个 writeInLoop 接口,会检测当前调用的线程,如果是在 loop 线程中则直接 write,否则添加到 loop 线程中异步 write )。
封装了下 Timer,Async 用于定时器和异步操作,顺带实现了 TimerWheel 一个时间复杂度 O(1)的心跳超时判定机制。
后期写了一个 packet 和环形 buffer,主要为了解决粘包和残包。测试会牺牲 20%~ 30%的性能,以及对每个连接增加一定内存占用(假设每个连接 8K 字节分配,10000 个连接大概 80M 内存占用,还能接受。)