SRS如何启用协程
- 定义了接口ISrsStartable和抽象类SrsCoroutine
- 协程的创建封装在SrsFastCoroutine的实现中
- 需要在协程中处理的业务需要实现ISrsCoroutineHandler,并注入到SrsSTCoroutine中去,这里的cycle并不是真的迭代,如果需要迭代执行的逻辑,需要在cycle方法的实现里手动while(true),考虑到异常,每次还需要调用pull收集系统中出现的错误,决定是否跳出迭代来中止当前协程
- 需要启用协程(io和socket方法等阻塞系统调用)的对象实例化一个SrsSTCoroutine,注入对应的逻辑对象(大部分是this),直接调用start即可
- 协程的上下文切换会执行在IO(可read)和固定的时间点上(定时任务),SRS的read单独起了一个无限等待的协程,来减少系统调用,提高性能
使用协程的类示例
- SrsTcpListener需要循环调用accept创建新的tcp连接
- SrsUdpListener会循环调用recv读取udp(rtc基于udp)网络报文
- SrdRecvThread是用于在tcp连接中循环read网络数据流
- SrsRtmpConn用于处理rtmp连接,内部需要多次处理交互消息,消费SrdRecvThread读取的数据,需要循环调用
协程的优势
用同步的方式写出异步代码,便以维护。如SrsRtmpConn可以将整个连接处理流程线性地写在同一个地方,而不必定义大量割裂的eventHandler分发数据。
|