Mediastreamer2 VoIP အင်ဂျင်ကို စူးစမ်းခြင်း။ အပိုင်း 9

ဆောင်းပါး၏ အကြောင်းအရာကို ကျွန်ုပ်ထံမှ ယူပါသည်။ zen ချန်နယ်.

Duplex အင်တာကွန်

နောက်ဆုံး၌ ဆောင်းပါး duplex intercom ကိုကြေငြာခဲ့ပြီး၊ ဤတစ်ခုတွင်ကျွန်ုပ်တို့ပြုလုပ်လိမ့်မည်။

ပုံကြမ်းကို ခေါင်းစဉ်ပုံတွင် ပြထားသည်။ ဇကာများ၏ အောက်ကွင်းဆက်သည် အသံကတ်မှ စတင်သည့် ဂီယာလမ်းကြောင်းကို ပုံဖော်သည်။ ၎င်းသည် မိုက်ခရိုဖုန်းမှ အချက်ပြနမူနာများကို ပေးဆောင်သည်။ ပုံမှန်အားဖြင့်၊ ၎င်းသည် တစ်စက္ကန့်လျှင် နမူနာ ၈၀၀၀ နှုန်းဖြင့် ဖြစ်ပေါ်သည်။ media streamer audio filters များအသုံးပြုသော data bit depth သည် 8000 bits (ဒါက အရေးမကြီးပါဘူး; ဆန္ဒရှိပါက၊ သင်သည် ပိုမိုမြင့်မားသော bit depth ဖြင့် အလုပ်လုပ်မည့် filter များကို ရေးနိုင်သည်)။ ဒေတာကို နမူနာ 16 တုံးဖြင့် အုပ်စုဖွဲ့ထားသည်။ ထို့ကြောင့် ဘလောက်တစ်ခုစီသည် 160 bytes အရွယ်အစားရှိသည်။ ထို့နောက်၊ ကျွန်ုပ်တို့သည် ဒေတာကို ပိတ်လိုက်သောအခါတွင် “ဖောက်ထွင်းမြင်နိုင်သည်” ဟူသော ဂျင်နရေတာ၏ အဝင်သို့ ဒေတာကို ကျွေးပါသည်။ အမှားရှာပြင်နေစဉ်တွင် သင်သည် မိုက်ခရိုဖုန်းသို့ စကားပြောရန် ငြီးငွေ့လာသောအခါတွင် ၎င်းကို ထည့်သွင်းထားသည် - သင်သည် လမ်းကြောင်းကို အသံအချက်ပြသည့်စနစ်ဖြင့် “ပစ်ခတ်ရန်” မီးစက်ကို အသုံးပြုနိုင်သည်။

ဂျင်နရေတာပြီးနောက်၊ အချက်ပြမှုသည် µ-law (G.16 စံနှုန်း) အရ ကျွန်ုပ်တို့၏ 711-ဘစ်နမူနာများကို ရှစ်ဘစ်များအဖြစ်သို့ ပြောင်းလဲပေးသည့် ကုဒ်ဒါသို့ အချက်ပြသည်။ ကုဒ်ပြောင်းကိရိယာ၏ အထွက်တွင်၊ ကျွန်ုပ်တို့တွင် အရွယ်အစား ထက်ဝက်ရှိသော ဒေတာဘလောက်တစ်ခု ရှိနှင့်ပြီးဖြစ်သည်။ ယေဘုယျအားဖြင့်၊ ကျွန်ုပ်တို့သည် အသွားအလာကို ချွေတာရန်မလိုအပ်ပါက ဒေတာများကို ချုံ့ခြင်းမရှိဘဲ ပို့လွှတ်နိုင်သည်။ သို့သော် Wireshark သည် µ-law သို့မဟုတ် a-law အရ ချုံ့ထားသည့်အခါတွင်သာ Wireshark သည် RTP တိုက်ရိုက်ထုတ်လွှင့်မှုမှ အသံကို ပြန်လည်ထုတ်ပေးနိုင်သောကြောင့် ဤနေရာတွင် ကုဒ်ဒါတစ်ခုအသုံးပြုရန် အသုံးဝင်ပါသည်။

ကုဒ်ပြောင်းပြီးနောက်၊ ပေါ့ပါးသောဒေတာဘလောက်များကို rtpsend စစ်ထုတ်မှုသို့ ပေးပို့မည်ဖြစ်ပြီး ၎င်းတို့ကို RTP ပက်ကေ့ချ်တစ်ခုတွင် ထည့်သွင်းကာ လိုအပ်သောအလံများကို သတ်မှတ်ကာ UDP ပက်ကတ်ပုံစံဖြင့် ကွန်ရက်မှတစ်ဆင့် ထုတ်လွှင့်ရန်အတွက် မီဒီယာထုတ်လွှင့်သူထံ ပေးအပ်မည်ဖြစ်သည်။

စစ်ထုတ်မှုများ၏အပေါ်ပိုင်းကွင်းဆက်သည် လက်ခံလမ်းကြောင်းကိုဖွဲ့စည်းသည်၊ ကွန်ရက်မှမီဒီယာထုတ်လွှင့်သူမှရရှိသော RTP ပက်ကေ့များသည် ဒေတာဘလောက်ပုံစံဖြင့် ၎င်းတို့ပေါ်လာသည့်အထွက်တွင် rtprecv စစ်ထုတ်မှုသို့ဝင်ရောက်သည်၊ ၎င်းတို့တစ်ခုစီသည် လက်ခံရရှိထားသောပက်ကတ်တစ်ခုနှင့်သက်ဆိုင်သည့်အထွက်တွင် rtprecv စစ်ထုတ်မှုကိုထည့်သွင်းသည်။ ဘလောက်တွင် payload data သာပါဝင်သည်၊ ယခင်ဆောင်းပါးတွင် ပုံတွင် အစိမ်းရောင်ဖြင့် ပြထားသည်။

ထို့နောက်၊ ဘလောက်များကို ကုဒ်ဒါ စစ်ထုတ်ခြင်းသို့ ပို့ပြီး၊ ၎င်းတို့တွင်ပါရှိသော single-byte နမူနာများကို linear၊ 16-bit များအဖြစ်သို့ ပြောင်းလဲပေးပါသည်။ ၎င်းကို မီဒီယာထုတ်လွှင့်သူ စစ်ထုတ်မှုများဖြင့် လုပ်ဆောင်ပြီးဖြစ်သည်။ ကျွန်ုပ်တို့၏အခြေအနေတွင်၊ သင့်နားကြပ်၏စပီကာတွင် ပြန်ဖွင့်ရန်အတွက် ၎င်းတို့ကို အသံကတ်သို့ ပို့ပေးပါသည်။

အခု software အကောင်အထည်ဖော်မှုဆီ ဆက်သွားရအောင်။ ၎င်းကိုလုပ်ဆောင်ရန်၊ ကျွန်ုပ်တို့သည် ယခင်က ကျွန်ုပ်တို့ခွဲထုတ်ထားသည့် လက်ခံကိရိယာနှင့် ထုတ်လွှင့်သည့်ဖိုင်များကို ပေါင်းစပ်မည်ဖြစ်သည်။ ၎င်းမတိုင်မီတွင်၊ ကျွန်ုပ်တို့သည် ဆိပ်ကမ်းများနှင့် လိပ်စာများအတွက် ပုံသေဆက်တင်များကို အသုံးပြုခဲ့သော်လည်း ယခုအခါ စတင်ချိန်တွင် ကျွန်ုပ်တို့သတ်မှတ်ထားသည့် ဆက်တင်များကို အသုံးပြုနိုင်ရန် ပရိုဂရမ်ကို လိုအပ်ပါသည်။ ၎င်းကိုလုပ်ဆောင်ရန်၊ ကျွန်ုပ်တို့သည် command line arguments များကို လုပ်ဆောင်ရန်အတွက် လုပ်ဆောင်နိုင်စွမ်းကို ပေါင်းထည့်မည်ဖြစ်သည်။ ထို့နောက် ကျွန်ုပ်တို့သည် ချိတ်ဆက်မှုတစ်ခုကို ထူထောင်လိုသော intercom ၏ IP လိပ်စာနှင့် ဆိပ်ကမ်းကို သတ်မှတ်နိုင်ပါမည်။

ပထမဦးစွာ၊ ၎င်း၏ဆက်တင်များကို သိမ်းဆည်းမည့် ပရိုဂရမ်တွင် ဖွဲ့စည်းပုံတစ်ခုကို ထည့်ကြပါစို့။

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

typedef struct _app_vars app_vars;

ပရိုဂရမ်သည် vars ဟုခေါ်သော ဤအမျိုးအစား၏ ဖွဲ့စည်းပုံကို ကြေညာမည်ဖြစ်သည်။
ထို့နောက်၊ command line arguments များကိုခွဲခြမ်းစိတ်ဖြာရန် function တစ်ခုထည့်ကြပါစို့။

/* Функция преобразования аргументов командной строки в
* настройки программы. */
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]);
        }
    }
}

ခွဲခြမ်းစိတ်ဖြာခြင်း၏ရလဒ်အနေဖြင့်၊ command line arguments များကို vars တည်ဆောက်မှု၏နယ်ပယ်များတွင် ထားရှိမည်ဖြစ်သည်။ အပလီကေးရှင်း၏အဓိကလုပ်ဆောင်ချက်မှာ filter များမှထုတ်လွှင့်ခြင်းနှင့်လက်ခံခြင်းလမ်းကြောင်းများကိုစုဆောင်းရန်ဖြစ်သည်; ticker ကိုချိတ်ဆက်ပြီးနောက်ထိန်းချုပ်မှုအား generator frequency ကို သုညမဟုတ်ဟုသတ်မှတ်ထားပါက စမ်းသပ်မီးစက်ကိုပြန်လည်စတင်မည်ဖြစ်သည် ။ မရပ်ဘဲ အလုပ်လုပ်တယ်။

ဂျင်နရေတာသည် ၎င်း၏ ဒီဇိုင်းကြောင့် ဤပြန်လည်စတင်ရန် လိုအပ်လိမ့်မည်၊ အကြောင်းတစ်ခုခုကြောင့် ၎င်းသည် 16 စက္ကန့်ထက် ပိုကြာသည့် အချက်ပြမှုကို မထုတ်ပေးနိုင်ပါ။ ၎င်း၏ကြာချိန်ကို 32-bit နံပါတ်ဖြင့် သတ်မှတ်ထားကြောင်း သတိပြုသင့်သည်။

ပရိုဂရမ်တစ်ခုလုံးသည် ဤကဲ့သို့ဖြစ်လိမ့်မည်-

/* Файл 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

ကွန်ဆိုးလ်ရှိ ပစ်လွှတ်သည့်အကွက်သည် ဖမ်းယူမှုစတင်ခြင်းနှင့်ပတ်သက်၍ မက်ဆေ့ချ်တစ်ခုသာပြသပါက၊ ၎င်းသည် ကောင်းသောလက္ခဏာဖြစ်သည် - ဆိုလိုသည်မှာ ကျွန်ုပ်တို့၏ဆိပ်ကမ်းကို အခြားပရိုဂရမ်များက မသိမ်းပိုက်နိုင်ဟု ဆိုလိုပါသည်။ အခြား terminal တွင်၊ ဤ port နံပါတ်ကိုသတ်မှတ်ခြင်းဖြင့် "remote" intercom ကို အတုယူမည့် program instance ကိုဖွင့်သည်-

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

ပရိုဂရမ်စာသားမှတွေ့မြင်နိုင်သည်အတိုင်း၊ မူရင်း IP လိပ်စာသည် 127.0.0.1 (local loopback) ဖြစ်သည်။

အခြား terminal တွင်၊ ကျွန်ုပ်တို့သည် ဒေသန္တရစက်ကို အတုယူသည့် ပရိုဂရမ်၏ ဒုတိယဥပမာတစ်ခုကို ဖွင့်ပေးပါသည်။ Built-in စမ်းသပ်မှု ဂျင်နရေတာ အလုပ်လုပ်နိုင်စေမည့် နောက်ထပ် အငြင်းအခုံတစ်ခုကို ကျွန်ုပ်တို့ အသုံးပြုသည်-

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

ဤအခိုက်အတန့်တွင်၊ "အဝေးထိန်း" စက်ပစ္စည်းဆီသို့ ပို့လွှတ်သော packets များသည် TShark ဖြင့် ကွန်ဆိုးလ်တွင် flash ရန်စတင်သင့်ပြီး ကွန်ပျူတာစပီကာမှ အဆက်မပြတ်အသံကိုကြားရပါမည်။

အကယ်၍ အရာအားလုံးသည် ရေးထားသည့်အတိုင်း ဖြစ်သွားပါက၊ ပရိုဂရမ်၏ ဒုတိယမိတ္တူကို ကျွန်ုပ်တို့ ပြန်လည်စတင်ပါ၊ သို့သော် သော့နှင့် အကြောင်းပြချက် “—gen 440” မပါဘဲ ပြန်လည်စတင်ပါ။ ယခု သင်သည် ဂျင်နရေတာ၏ အခန်းကဏ္ဍတွင် ပါဝင်လာမည်ဖြစ်သည်။ ၎င်းပြီးနောက်၊ သင်သည် မိုက်ခရိုဖုန်းသို့ ဆူညံသွားစေနိုင်သည်၊ စပီကာ သို့မဟုတ် နားကြပ်များတွင် သက်ဆိုင်သော အသံကို ကြားရပါမည်။ အသံပိုင်းဆိုင်ရာ ကိုယ့်ကိုယ်ကိုယ် စိတ်လှုပ်ရှားမှုတောင် ဖြစ်ပေါ်လာနိုင်သည်၊ စပီကာ၏ အသံအတိုးအကျယ်ကို ပိတ်လိုက်ပြီး အကျိုးသက်ရောက်မှု ပျောက်သွားပါမည်။

အကယ်၍ သင်သည် ၎င်းကို ကွန်ပျူတာ နှစ်လုံးတွင် လည်ပတ်ပြီး IP လိပ်စာများအကြောင်း မရှုပ်ထွေးပါက၊ တူညီသော ရလဒ်သည် သင့်အား စောင့်ကြိုနေပါသည် - two-way digital quality voice communication.

နောက်ဆောင်းပါးတွင် ကျွန်ုပ်တို့၏ကိုယ်ပိုင် filter များရေးသားနည်းကို လေ့လာပါမည်။ ဤကျွမ်းကျင်မှုကြောင့် သင်သည် အသံနှင့် ဗီဒီယိုအတွက်သာမက အခြားသော သီးခြားနယ်ပယ်များတွင်လည်း media streamer ကို သုံးနိုင်မည်ဖြစ်သည်။

source: www.habr.com