🥇 Mediastreamer2 VoIP इन्जिन सिक्दै। भाग 9

लेखको सामग्री मेरो बाट लिइएको हो zen च्यानल.

डुप्लेक्स इन्टरकॉम

विगतमा लेख एक डुप्लेक्स इन्टरकम घोषणा गरिएको थियो, र यसमा हामी यसलाई बनाउनेछौं।

रेखाचित्र शीर्षक चित्रमा देखाइएको छ। फिल्टरहरूको तल्लो श्रृंखलाले प्रसारण मार्ग बनाउँछ, जुन ध्वनि कार्डबाट सुरु हुन्छ। यसले माइक्रोफोनबाट संकेत नमूनाहरू प्रदान गर्दछ। पूर्वनिर्धारित रूपमा, यो प्रति सेकेन्ड 8000 नमूनाहरूको दरमा हुन्छ। मिडिया स्ट्रिमर अडियो फिल्टरहरूले प्रयोग गर्ने डेटा बिट गहिराई 16 बिट हो (यो महत्त्वपूर्ण छैन; यदि तपाइँ चाहनुहुन्छ भने, तपाइँ फिल्टरहरू लेख्न सक्नुहुन्छ जुन उच्च बिट गहिराइसँग काम गर्दछ)। डाटा 160 नमूनाहरूको ब्लकहरूमा समूहबद्ध गरिएको छ। यसरी, प्रत्येक ब्लक आकारमा 320 बाइट्स छ। अर्को, हामी जेनरेटरको इनपुटमा डाटा फिड गर्छौं, जुन, जब बन्द हुन्छ, डाटामा "पारदर्शी" हुन्छ। तपाईंले डिबगिङको क्रममा माइक्रोफोनमा कुरा गर्दा थाकेको अवस्थामा मैले यसलाई थपेको छु - तपाईंले टोन सिग्नलको साथ मार्ग "शूट" गर्न जनरेटर प्रयोग गर्न सक्नुहुन्छ।

जेनेरेटर पछि, संकेत एन्कोडरमा जान्छ, जसले हाम्रा १६-बिट नमूनाहरूलाई µ-कानून (G.16 मानक) अनुसार आठ-बिटमा रूपान्तरण गर्छ। एन्कोडरको आउटपुटमा, हामीसँग पहिले नै डाटा ब्लक आधा साइज छ। सामान्यतया, यदि हामीले ट्राफिक बचत गर्न आवश्यक छैन भने हामी कम्प्रेसन बिना डाटा प्रसारण गर्न सक्छौं। तर यहाँ यो एन्कोडर प्रयोग गर्न उपयोगी छ, किनकि Wireshark ले RTP स्ट्रिमबाट अडियो पुन: उत्पादन गर्न सक्छ जब यो µ-law वा a-law अनुसार संकुचित हुन्छ।

एन्कोडर पछि, डेटाको हल्का ब्लकहरू rtpsend फिल्टरमा पठाइन्छ, जसले तिनीहरूलाई RTP प्याकेटमा राख्छ, आवश्यक झण्डाहरू सेट गर्दछ र तिनीहरूलाई UDP प्याकेटको रूपमा नेटवर्कमा प्रसारणको लागि मिडिया स्ट्रिमरलाई दिन्छ।

फिल्टरहरूको माथिल्लो श्रृंखलाले प्राप्त गर्ने मार्ग बनाउँछ; नेटवर्कबाट मिडिया स्ट्रिमरले प्राप्त गरेको RTP प्याकेटहरू rtprecv फिल्टरमा प्रवेश गर्छन्, जसको आउटपुटमा तिनीहरू डेटा ब्लकहरूको रूपमा देखा पर्दछ, जसमध्ये प्रत्येक एक प्राप्त प्याकेटसँग मेल खान्छ। ब्लकले पेलोड डेटा मात्र समावेश गर्दछ; अघिल्लो लेखमा तिनीहरूलाई चित्रणमा हरियोमा देखाइएको थियो।

अर्को, ब्लकहरू डिकोडर फिल्टरमा पठाइन्छ, जसले तिनीहरूमा समावेश एकल-बाइट नमूनाहरूलाई रैखिक, 16-बिटमा रूपान्तरण गर्दछ। जुन पहिले नै मिडिया स्ट्रिमर फिल्टरहरू द्वारा प्रशोधन गर्न सकिन्छ। हाम्रो अवस्थामा, हामी तिनीहरूलाई तपाईंको हेडसेटको स्पिकरहरूमा प्लेब्याकको लागि साउन्ड कार्डमा पठाउँछौं।

अब सफ्टवेयर कार्यान्वयनमा जाऔं। यो गर्नको लागि, हामीले पहिले छुट्याएका रिसीभर र ट्रान्समिटर फाइलहरू संयोजन गर्नेछौं। यो भन्दा पहिले, हामीले पोर्ट र ठेगानाहरूको लागि निश्चित सेटिङहरू प्रयोग गर्यौं, तर अब हामीले स्टार्टअपमा निर्दिष्ट गर्ने सेटिङहरू प्रयोग गर्न सक्षम हुनको लागि हामीलाई प्रोग्राम चाहिन्छ। यो गर्नको लागि, हामी कमाण्ड लाइन तर्कहरू प्रशोधन गर्नका लागि कार्यक्षमता थप्नेछौं। जस पछि हामी आईपी ठेगाना र इन्टरकमको पोर्ट सेट गर्न सक्षम हुनेछौं जसको साथ हामी जडान स्थापना गर्न चाहन्छौं।

पहिले, कार्यक्रममा संरचना थपौं जसले यसको सेटिङहरू भण्डार गर्नेछ:

struct _app_vars
{
  int  local_port;              /* Локальный порт. */
  int  remote_port;             /* Порт переговорного устройства на удаленном компьютере. */
  char remote_addr[128];        /* IP-адрес удаленного компьютера. */
  MSDtmfGenCustomTone dtmf_cfg; /* Настройки тестового сигнала генератора. */
};

typedef struct _app_vars app_vars;

कार्यक्रमले vars भनिने यस प्रकारको संरचना घोषणा गर्नेछ।
अर्को, कमाण्ड लाइन तर्कहरू पार्स गर्न एउटा प्रकार्य थपौं:

/* Функция преобразования аргументов командной строки в
* настройки программы. */
void  scan_args(int argc, char *argv[], app_vars *v)
{
    char i;
    for (i=0; i<argc; i++)
    {
        if (!strcmp(argv[i], "--help"))
        {
            char *p=argv[0]; p=p + 2;
            printf("  %s walkie talkienn", p);
            printf("--help      List of options.n");
            printf("--version   Version of application.n");
            printf("--addr      Remote abonent IP address string.n");
            printf("--port      Remote abonent port number.n");
            printf("--lport     Local port number.n");
            printf("--gen       Generator frequency.n");
            exit(0);
        }

        if (!strcmp(argv[i], "--version"))
        {
            printf("0.1n");
            exit(0);
        }

        if (!strcmp(argv[i], "--addr"))
        {
            strncpy(v->remote_addr, argv[i+1], 16);
            v->remote_addr[16]=0;
            printf("remote addr: %sn", v->remote_addr);
        }

        if (!strcmp(argv[i], "--port"))
        {
            v->remote_port=atoi(argv[i+1]);
            printf("remote port: %in", v->remote_port);
        }

        if (!strcmp(argv[i], "--lport"))
        {
            v->local_port=atoi(argv[i+1]);
            printf("local port : %in", v->local_port);
        }

        if (!strcmp(argv[i], "--gen"))
        {
            v -> dtmf_cfg.frequencies[0] = atoi(argv[i+1]);
                printf("gen freq : %in", v -> dtmf_cfg.frequencies[0]);
        }
    }
}

पार्सिङको परिणाम स्वरूप, कमाण्ड लाइन आर्गुमेन्टहरू vars संरचनाको क्षेत्रमा राखिनेछ। अनुप्रयोगको मुख्य कार्य फिल्टरहरूबाट प्रसारण र प्राप्त गर्ने मार्गहरू सङ्कलन गर्न हुनेछ; टिकर जडान गरेपछि, नियन्त्रण एक अनन्त लुपमा स्थानान्तरण हुनेछ, यदि जनरेटर फ्रिक्वेन्सी गैर-शून्यमा सेट गरिएको थियो भने, परीक्षण जनरेटर पुन: सुरु हुनेछ। यो रोक बिना काम गर्दछ।

जेनेरेटरलाई यसको डिजाइनको कारणले यी पुन: सुरु गर्न आवश्यक हुनेछ; केही कारणले गर्दा यसले 16 सेकेन्ड भन्दा बढि टिक्ने संकेत उत्पादन गर्न सक्दैन। यो ध्यान दिनुपर्छ कि यसको अवधि 32-बिट नम्बर द्वारा निर्दिष्ट गरिएको छ।

सम्पूर्ण कार्यक्रम यस प्रकार देखिनेछ:

/* Файл mstest8.c Имитатор переговорного устройства. */

#include <mediastreamer2/mssndcard.h>
#include <mediastreamer2/dtmfgen.h>
#include <mediastreamer2/msrtp.h>

/* Подключаем файл общих функций. */
#include "mstest_common.c"

/*----------------------------------------------------------*/
struct _app_vars
{
    int  local_port;              /* Локальный порт. */
    int  remote_port;             /* Порт переговорного устройства на удаленном компьютере. */
    char remote_addr[128];        /* IP-адрес удаленного компьютера. */
    MSDtmfGenCustomTone dtmf_cfg; /* Настройки тестового сигнала генератора. */
};

typedef struct _app_vars app_vars;

/*----------------------------------------------------------*/
/* Создаем дуплексную RTP-сессию. */
RtpSession* create_duplex_rtp_session(app_vars v)
{
    RtpSession *session = create_rtpsession (v.local_port, v.local_port + 1, FALSE, RTP_SESSION_SENDRECV);
    rtp_session_set_remote_addr_and_port(session, v.remote_addr, v.remote_port, v.remote_port + 1);
    rtp_session_set_send_payload_type(session, PCMU);
    return session;
}

/*----------------------------------------------------------*/
/* Функция преобразования аргументов командной строки в
* настройки программы. */
void  scan_args(int argc, char *argv[], app_vars *v)
{
    char i;
    for (i=0; i<argc; i++)
    {
        if (!strcmp(argv[i], "--help"))
        {
            char *p=argv[0]; p=p + 2;
            printf("  %s walkie talkienn", p);
            printf("--help      List of options.n");
            printf("--version   Version of application.n");
            printf("--addr      Remote abonent IP address string.n");
            printf("--port      Remote abonent port number.n");
            printf("--lport     Local port number.n");
            printf("--gen       Generator frequency.n");
            exit(0);
        }

        if (!strcmp(argv[i], "--version"))
        {
            printf("0.1n");
            exit(0);
        }

        if (!strcmp(argv[i], "--addr"))
        {
            strncpy(v->remote_addr, argv[i+1], 16);
            v->remote_addr[16]=0;
            printf("remote addr: %sn", v->remote_addr);
        }

        if (!strcmp(argv[i], "--port"))
        {
            v->remote_port=atoi(argv[i+1]);
            printf("remote port: %in", v->remote_port);
        }

        if (!strcmp(argv[i], "--lport"))
        {
            v->local_port=atoi(argv[i+1]);
            printf("local port : %in", v->local_port);
        }

        if (!strcmp(argv[i], "--gen"))
        {
            v -> dtmf_cfg.frequencies[0] = atoi(argv[i+1]);
                printf("gen freq : %in", v -> dtmf_cfg.frequencies[0]);
        }
    }
}

/*----------------------------------------------------------*/
int main(int argc, char *argv[])
{
    /* Устанавливаем настройки по умолчанию. */
    app_vars vars={5004, 7010, "127.0.0.1", {0}};

    /* Устанавливаем настройки настройки программы в
     * соответствии с аргументами командной строки. */
    scan_args(argc, argv, &vars);

    ms_init();

    /* Создаем экземпляры фильтров передающего тракта. */
    MSSndCard *snd_card =
        ms_snd_card_manager_get_default_card(ms_snd_card_manager_get());
    MSFilter *snd_card_read = ms_snd_card_create_reader(snd_card);
    MSFilter *dtmfgen = ms_filter_new(MS_DTMF_GEN_ID);
    MSFilter *rtpsend = ms_filter_new(MS_RTP_SEND_ID);

    /* Создаем фильтр кодера. */
    MSFilter *encoder = ms_filter_create_encoder("PCMU");

    /* Регистрируем типы нагрузки. */
    register_payloads();

    /* Создаем дуплексную RTP-сессию. */
    RtpSession* rtp_session= create_duplex_rtp_session(vars);
    ms_filter_call_method(rtpsend, MS_RTP_SEND_SET_SESSION, rtp_session);

    /* Соединяем фильтры передатчика. */
    ms_filter_link(snd_card_read, 0, dtmfgen, 0);
    ms_filter_link(dtmfgen, 0, encoder, 0);
    ms_filter_link(encoder, 0, rtpsend, 0);

    /* Создаем фильтры приемного тракта. */
    MSFilter *rtprecv = ms_filter_new(MS_RTP_RECV_ID);
    ms_filter_call_method(rtprecv, MS_RTP_RECV_SET_SESSION, rtp_session);

    /* Создаем фильтр декодера, */
    MSFilter *decoder=ms_filter_create_decoder("PCMU");

    /* Создаем фильтр звуковой карты. */
    MSFilter *snd_card_write = ms_snd_card_create_writer(snd_card);

    /* Соединяем фильтры приёмного тракта. */
    ms_filter_link(rtprecv, 0, decoder, 0);
    ms_filter_link(decoder, 0,  snd_card_write, 0);

    /* Создаем источник тактов - тикер. */
    MSTicker *ticker = ms_ticker_new();

    /* Подключаем источник тактов. */
    ms_ticker_attach(ticker, snd_card_read);
    ms_ticker_attach(ticker, rtprecv);

    /* Если настройка частоты генератора отлична от нуля, то запускаем генератор. */   
    if (vars.dtmf_cfg.frequencies[0])
    {
        /* Настраиваем структуру, управляющую выходным сигналом генератора. */
        vars.dtmf_cfg.duration = 10000;
        vars.dtmf_cfg.amplitude = 1.0;
    }

    /* Организуем цикл перезапуска генератора. */
    while(TRUE)
    {
        if(vars.dtmf_cfg.frequencies[0])
        {
            /* Включаем звуковой генератор. */
            ms_filter_call_method(dtmfgen, MS_DTMF_GEN_PLAY_CUSTOM,
                    (void*)&vars.dtmf_cfg);
        }
        /* Укладываем тред в спячку на 20мс, чтобы другие треды
         * приложения получили время на работу. */
        ms_usleep(20000);
    }
}

संकलन गरौं। त्यसपछि कार्यक्रम दुई कम्प्युटरमा चलाउन सकिन्छ। वा एउटामा, जस्तो म अहिले गर्नेछु। हामीले TShark लाई निम्न तर्कहरूसँग सुरु गर्छौं:

$ sudo tshark -i lo -f "udp dst port 7010" -P -V -O RTP -o rtp.heuristic_rtp:TRUE -x

यदि कन्सोलमा लन्च फिल्डले क्याप्चरको सुरुवातको बारेमा सन्देश मात्र देखाउँदछ, तब यो राम्रो संकेत हो - यसको मतलब हाम्रो पोर्ट सम्भवतः अन्य प्रोग्रामहरूले ओगटेको छैन। अर्को टर्मिनलमा, हामी यो पोर्ट नम्बर निर्दिष्ट गरेर "रिमोट" इन्टरकम सिमुलेट गर्ने कार्यक्रम उदाहरण सुरु गर्छौं:

$ ./mstest8 --port 9010 --lport 7010

कार्यक्रम पाठबाट देख्न सकिन्छ, पूर्वनिर्धारित IP ठेगाना 127.0.0.1 (स्थानीय लुपब्याक) हो।

अर्को टर्मिनलमा, हामी कार्यक्रमको दोस्रो उदाहरण सुरु गर्छौं, जसले स्थानीय यन्त्रलाई सिमुलेट गर्छ। हामी एक अतिरिक्त तर्क प्रयोग गर्छौं जसले निर्मित परीक्षण जनरेटरलाई काम गर्न अनुमति दिन्छ:

$ ./mstest8  --port 7010 --lport 9010 --gen 440

यस क्षणमा, "रिमोट" उपकरण तर्फ पठाइएका प्याकेटहरू TShark को साथ कन्सोलमा फ्ल्यास गर्न सुरु गर्नुपर्छ, र कम्प्युटर स्पिकरबाट निरन्तर टोन सुनिनेछ।

यदि सबै कुरा लेखिए अनुसार भयो भने, हामी कार्यक्रमको दोस्रो प्रतिलिपि पुन: सुरु गर्छौं, तर कुञ्जी र तर्क बिना "—gen 440"। तपाईले अब जेनेरेटरको भूमिका खेल्नुहुनेछ। यस पछि, तपाईं माइक्रोफोनमा आवाज बनाउन सक्नुहुन्छ; तपाईंले स्पिकर वा हेडफोनमा सम्बन्धित ध्वनि सुन्नुपर्दछ। ध्वनिक आत्म-उत्तेजना पनि हुन सक्छ; स्पिकर भोल्युम बन्द गर्नुहोस् र प्रभाव गायब हुनेछ।

यदि तपाईंले यसलाई दुईवटा कम्प्युटरहरूमा चलाउनुभयो र IP ठेगानाहरूको बारेमा भ्रमित हुनुभएन भने, त्यही परिणामले तपाईंलाई पर्खिरहेको छ - दुई-तर्फी डिजिटल गुणस्तर आवाज संचार।

अर्को लेखमा हामी हाम्रा आफ्नै फिल्टरहरू - प्लगइनहरू कसरी लेख्ने भनेर सिक्नेछौं, यो सीपको लागि धन्यवाद, तपाईंले मिडिया स्ट्रिमरलाई अडियो र भिडियोको लागि मात्र होइन, तर केही अन्य विशिष्ट क्षेत्रमा पनि प्रयोग गर्न सक्नुहुनेछ।

स्रोत: www.habr.com

Mediastreamer2 VoIP इन्जिन अन्वेषण गर्दै। भाग ८

डुप्लेक्स इन्टरकॉम

एक टिप्पणी थप्न Отменить ответ