订阅流数据

C++ API 支持两种处理流数据的方式:回调与轮询。我们为这两种场景分别提供了 ThreadedClient 与 PollingClient 两个订阅类。此外回调方式还有多线程版本 ThreadPooledClient ,但该类已不推荐使用。本节将从构造函数、订阅和取消订阅对这三种方式分别进行详细介绍。

为方便用户快速使用,下表对三种订阅方式的适用场景进行简单说明。

Table 1. 三种订阅的适用场景
订阅方式 适用场景
ThreadedClient 收到消息后,以回调的方式通知,单线程回调
ThreadPooledClient (不推荐)收到消息后,以回调的方式通知,多线程并发回调
PollingClient API 端创建一个队列存储收到的消息,用户主动调用接口从队列中取出数据