流回调乱序解决方案

---

1 操作场景

开发者短时间内频繁对流进行创建和关闭时，ZEGO 提供的流创建回调和流关闭回调不保证结果的时序与开发者执行的时序一致。

当开发者需要依赖流创建和流关闭回调维护本地流列表或进行混流时，回调时序与执行时序的不一致可能会导致部分业务出错。

比如，开发者对一条流的操作顺序为：

1. 流创建
2. 流关闭
3. 流创建

经过回调服务，到达开发者服务器的顺序有可能变为：

1. 流创建
2. 流创建
3. 流关闭

开发者根据回调的顺序更新本地流列表，这条流会被删除，实际上这条流仍然在进行正常推流。

2 操作步骤

为了解决上述回调乱序导致的问题，ZEGO 推荐开发者使用以下方案维护本地流列表。

2.1 关注回调关键参数

关注流创建回调和流删除回调的关键参数。

2.2 维护本地流列表

根据 stream_id，以及对应的 stream_sid 和对应房间的 stream_seq，维护本地流列表。

本地流列表的数据结构如下：

RoomStreamInfo: {
    StreamList: [
        {stream_id_1, stream_sid_1}, 
        {stream_id_2, stream_sid_2}
    ]
    StreamSeq: stream_seq
}

2.3 处理判断逻辑

收到回调后，处理流事件回调逻辑，更新本地流列表。

示例中的字段说明如下：

• 流创建回调

对比 stream_seq，当 zego_stream_seq > local_stream_seq 时，允许创建流，加入本地的流列表。

var localStreamList = [];
var localStreamSeq = 0;
// 流新增时
request("url", function(stream) {
    var streamSeq = stream["strean_seq"];
    var streamSid = stream["stream_sid"];
    if (streamSeq > localStreamSeq) { 
        // 当ZEGO服务器seq大于本地seq时才添加到本地的流列表
        localStreamList.add(stream);
    }
})

• 流删除回调

对比 stream_seq 和 stream_sid，当 zego_stream_seq > local_stream_seq 且 zego_stream_sid == local_stream_sid 时，允许删除流，更新本地的流列表。

var localStreamList = [];
var localStreamSeq = 0;
// 流删除时
request("url", function(stream) {
    var streamSeq = stream["strean_seq"];
    var streamSid = stream["stream_sid"];
    var localStream = localStreamList.find("stream_id")
    if (streamSeq > localStreamSeq && stramSid==localStream.localStreamSid) {
        // 当ZEGO服务器seq大于本地seq且为删除的流时才更新本地的流列表
        localStreamList.delete(localStream)
    }
})