流媒体服务器SMS-语音对讲（一）

news2024/11/23 12:04:06

1.简介

在国标语音对讲对接中，会发现不同的厂商或不同型号的设备，对讲流程都不一样，本文主要介绍流媒体与设备之间的交互情况。

SMS流媒体服务代码库地址：https://gitee.com/inyeme/simple-media-server

2.流媒体与设备交互的可能情况

对讲流程中，流媒体与设备的交互场景大致可以分为几种：

作为服务端，被动等待设备来建链，并发送数据
作为服务端，被动等待设备来建链，等待设备发数据
作为服务端，被动等待设备来建链，既发送也接收数据
作为客户端，主动向设备建链，并发送数据
作为客户端，主动向设备建链，等待设备发数据
作为客户端，主动向设备建链，既发送也接收数据

3.几种常见对讲流程

3.1.单向通道

情况1：

情况2：

3.2.双向通道

情况1：

情况2：

4.SMS对讲接口

目前SMS支持单向对讲的几种场景，对应的对讲接口如下：

void GB28181Api::initApi()
{
    g_mapApi.emplace("/api/v1/gb28181/recv/create", GB28181Api::createGB28181Receiver);
    g_mapApi.emplace("/api/v1/gb28181/send/create", GB28181Api::createGB28181Sender);
    g_mapApi.emplace("/api/v1/gb28181/recv/stop", GB28181Api::stopGB28181Receiver);
    g_mapApi.emplace("/api/v1/gb28181/send/stop", GB28181Api::stopGB28181Sender);
}

从接口上，可以创建发送者或者接受者

void GB28181Api::createGB28181Sender(const HttpParser& parser, const UrlParser& urlParser, 
                        const function<void(HttpResponse& rsp)>& rspFunc)
{
    HttpResponse rsp;
    rsp._status = 200;
    json value;

    checkArgs(parser._body, {"active", "ssrc", "port", "socketType", "streamName", "appName", "ip"});

    int active = toInt(parser._body["active"]);
    // logInfo << "json active: " << parser._body["active"];
    // logInfo << "active: " << active;
    if (active) {
        int ssrc = toInt(parser._body["ssrc"]);
        int port = toInt(parser._body["port"]);
        int socketType = toInt(parser._body["socketType"]); //1:tcp,2:udp,3:both
        string streamName = parser._body["streamName"];
        string appName = parser._body["appName"];
        string ip = parser._body["ip"];

        auto push = make_shared<GB28181ClientPush>(ip, port, appName, streamName, ssrc, socketType);
        push->create();
        push->start();

        string key = ip + "_" + to_string(port) + "_" + to_string(ssrc);
        GB28181Client::addClient(key, push);

        value["port"] = push->getLocalPort();
        value["ip"] = push->getLocalIp();
        value["ssrc"] = ssrc;
    } else {
        int ssrc = toInt(parser._body["ssrc"]);
        int port = toInt(parser._body["port"]);
        int socketType = toInt(parser._body["socketType"]); //1:tcp,2:udp,3:both
        string streamName = parser._body["streamName"];
        string appName = parser._body["appName"];

        GB28181Server::instance()->startSend("0.0.0.0", port, socketType, appName, streamName, ssrc);

        value["port"] = port;
        value["ip"] = Config::instance()->get("LocalIp");
        value["ssrc"] = ssrc;
    }

    value["code"] = "200";
    value["msg"] = "success";
    rsp.setContent(value.dump());
    rspFunc(rsp);
}

在创建发送者或接收者的时候，又可以指定是主动建链还是被动等待建链。基本满足了单向通道的对讲流程。