ការរុករកម៉ាស៊ីន Mediastreamer2 VoIP ។ ផ្នែកទី 9

សម្ភារៈនៃអត្ថបទគឺយកពីខ្ញុំ ប៉ុស្តិ៍ zen.

ពីរជាន់ intercom

ក្នុង​អតីតកាល អត្ថបទ duplex intercom ត្រូវបានប្រកាស ហើយនៅក្នុងមួយនេះ យើងនឹងបង្កើតវា។

ដ្យាក្រាមត្រូវបានបង្ហាញក្នុងរូបភាពចំណងជើង។ ខ្សែសង្វាក់ទាបនៃតម្រងបង្កើតជាផ្លូវបញ្ជូន ដែលចាប់ផ្តើមពីកាតសំឡេង។ វាផ្តល់នូវគំរូសញ្ញាពីមីក្រូហ្វូន។ តាមលំនាំដើម វាកើតឡើងក្នុងអត្រា 8000 គំរូក្នុងមួយវិនាទី។ ជម្រៅប៊ីតទិន្នន័យដែលតម្រងអូឌីយ៉ូស្ទ្រីមមេឌៀប្រើគឺ 16 ប៊ីត (វាមិនសំខាន់ទេ ប្រសិនបើអ្នកចង់បាន អ្នកអាចសរសេរតម្រងដែលនឹងដំណើរការជាមួយជម្រៅប៊ីតខ្ពស់ជាងនេះ)។ ទិន្នន័យត្រូវបានដាក់ជាក្រុមទៅជាប្លុកនៃ 160 គំរូ។ ដូច្នេះប្លុកនីមួយៗមានទំហំ 320 បៃ។ បន្ទាប់មក យើងបញ្ជូនទិន្នន័យទៅការបញ្ចូលរបស់ម៉ាស៊ីនភ្លើង ដែលនៅពេលបិទ គឺ "តម្លាភាព" ទៅនឹងទិន្នន័យ។ ខ្ញុំបានបន្ថែមវាក្នុងករណីដែលអ្នកធុញទ្រាន់នឹងការនិយាយទៅកាន់មីក្រូហ្វូនកំឡុងពេលបំបាត់កំហុស - អ្នកអាចប្រើម៉ាស៊ីនភ្លើងដើម្បី "បាញ់" ផ្លូវជាមួយនឹងសញ្ញាសំឡេង។

បន្ទាប់ពីម៉ាស៊ីនភ្លើង សញ្ញាទៅឧបករណ៍បំលែងកូដ ដែលបំប្លែងគំរូ 16 ប៊ីតរបស់យើងយោងទៅតាមច្បាប់ µ-law (G.711 standard) ទៅជាប្រាំបីប៊ីត។ នៅលទ្ធផលនៃកម្មវិធីបំលែងកូដ យើងមានប្លុកទិន្នន័យទំហំពាក់កណ្តាលរួចហើយ។ ជាទូទៅ យើងអាចបញ្ជូនទិន្នន័យដោយគ្មានការបង្ហាប់ ប្រសិនបើយើងមិនត្រូវការរក្សាទុកចរាចរណ៍។ ប៉ុន្តែនៅទីនេះ វាមានប្រយោជន៍ក្នុងការប្រើកម្មវិធីបំប្លែងកូដ ព្រោះ Wireshark អាចផលិតអូឌីយ៉ូពីស្ទ្រីម RTP ឡើងវិញបានលុះត្រាតែវាត្រូវបានបង្ហាប់យោងទៅតាម µ-law ឬ a-law ។

បន្ទាប់ពីកម្មវិធីបំលែងកូដ ប្លុកទិន្នន័យស្រាលជាងមុនត្រូវបានផ្ញើទៅកាន់តម្រង rtpsend ដែលនឹងដាក់ពួកវានៅក្នុងកញ្ចប់ព័ត៌មាន RTP កំណត់ទង់ចាំបាច់ និងផ្តល់ឱ្យវាទៅកម្មវិធីផ្សាយព័ត៌មានសម្រាប់ការបញ្ជូនតាមបណ្តាញក្នុងទម្រង់ជាកញ្ចប់ព័ត៌មាន UDP ។

ខ្សែសង្វាក់ខាងលើនៃតម្រងបង្កើតជាផ្លូវទទួល កញ្ចប់ព័ត៌មាន RTP ដែលទទួលបានដោយអ្នកផ្សាយមេឌៀពីបណ្តាញបញ្ចូលតម្រង rtprecv នៅទិន្នផលដែលពួកវាលេចឡើងក្នុងទម្រង់ជាប្លុកទិន្នន័យ ដែលនីមួយៗត្រូវគ្នានឹងកញ្ចប់ព័ត៌មានដែលទទួលបានមួយ។ ប្លុកនេះផ្ទុកទិន្នន័យបន្ទុកតែប៉ុណ្ណោះ នៅក្នុងអត្ថបទមុន ពួកវាត្រូវបានបង្ហាញជាពណ៌បៃតងនៅក្នុងរូបភាព។

បន្ទាប់មក ប្លុកត្រូវបានបញ្ជូនទៅតម្រងឌិកូដ ដែលបំប្លែងគំរូមួយបៃដែលមាននៅក្នុងពួកវាទៅជាលីនេអ៊ែរ 16 ប៊ីត។ ដែលអាចត្រូវបានដំណើរការដោយតម្រងអ្នកផ្សាយមេឌៀរួចហើយ។ ក្នុងករណីរបស់យើង យើងគ្រាន់តែផ្ញើវាទៅកាតសំឡេងសម្រាប់ចាក់សារថ្មីនៅលើឧបករណ៍បំពងសម្លេងនៃកាសរបស់អ្នក។

ឥឡូវនេះសូមបន្តទៅការអនុវត្តកម្មវិធី។ ដើម្បីធ្វើដូចនេះយើងនឹងបញ្ចូលគ្នានូវឯកសារអ្នកទទួលនិងអ្នកបញ្ជូនដែលយើងបានបំបែកពីមុន។ មុននេះ យើងបានប្រើការកំណត់ថេរសម្រាប់ច្រក និងអាសយដ្ឋាន ប៉ុន្តែឥឡូវនេះយើងត្រូវការកម្មវិធីដើម្បីអាចប្រើការកំណត់ដែលយើងបញ្ជាក់នៅពេលចាប់ផ្តើម។ ដើម្បីធ្វើដូចនេះយើងនឹងបន្ថែមមុខងារសម្រាប់ដំណើរការអាគុយម៉ង់បន្ទាត់ពាក្យបញ្ជា។ បន្ទាប់មកយើងនឹងអាចកំណត់អាសយដ្ឋាន IP និងច្រកនៃ intercom ដែលយើងចង់បង្កើតការតភ្ជាប់។

ដំបូង យើងបន្ថែមរចនាសម្ព័ន្ធទៅកម្មវិធីដែលនឹងរក្សាទុកការកំណត់របស់វា៖

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

ប្រសិនបើវាលបើកដំណើរការនៅក្នុងកុងសូលបង្ហាញតែសារអំពីការចាប់ផ្តើមនៃការចាប់យក នោះនេះគឺជាសញ្ញាល្អ - វាមានន័យថាច្រករបស់យើងទំនងជាមិនត្រូវបានកាន់កាប់ដោយកម្មវិធីផ្សេងទៀតទេ។ នៅក្នុងស្ថានីយមួយផ្សេងទៀត យើងបើកដំណើរការកម្មវិធីមួយដែលនឹងក្លែងធ្វើ "ពីចម្ងាយ" intercom ដោយបញ្ជាក់លេខច្រកនេះ៖

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

ដូចដែលអាចមើលឃើញពីអត្ថបទកម្មវិធី អាសយដ្ឋាន IP លំនាំដើមគឺ 127.0.0.1 (local loopback)។

នៅក្នុងស្ថានីយមួយផ្សេងទៀត យើងបើកដំណើរការកម្មវិធីទីពីរនៃកម្មវិធី ដែលក្លែងធ្វើឧបករណ៍មូលដ្ឋាន។ យើងប្រើអំណះអំណាងបន្ថែមដែលអនុញ្ញាតឱ្យម៉ាស៊ីនភ្លើងតេស្តដែលភ្ជាប់មកជាមួយដំណើរការ៖

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

នៅពេលនេះ កញ្ចប់ព័ត៌មានដែលបានបញ្ជូនទៅកាន់ឧបករណ៍ "ពីចម្ងាយ" គួរតែចាប់ផ្តើមបញ្ចេញពន្លឺនៅក្នុងកុងសូលជាមួយ TShark ហើយសម្លេងបន្តនឹងត្រូវបានឮពីឧបករណ៍បំពងសម្លេងកុំព្យូទ័រ។

ប្រសិនបើអ្វីៗបានកើតឡើងដូចដែលបានសរសេរ នោះយើងចាប់ផ្តើមច្បាប់ចម្លងទីពីរនៃកម្មវិធីឡើងវិញ ប៉ុន្តែដោយគ្មានគន្លឹះ និងអាគុយម៉ង់ “—gen 440” ។ ឥឡូវនេះអ្នកនឹងដើរតួជាម៉ាស៊ីនភ្លើង។ បន្ទាប់ពីនេះ អ្នកអាចបង្កើតសំឡេងរំខានទៅក្នុងមីក្រូហ្វូន អ្នកគួរតែឮសំឡេងដែលត្រូវគ្នានៅក្នុងអូប៉ាល័រ ឬកាស។ ការ​រំជើបរំជួល​ដោយ​សំឡេង​ដោយ​ខ្លួនឯង​អាច​នឹង​កើត​ឡើង​ផង​ដែរ ដោយ​បន្ថយ​កម្រិត​សំឡេង​អូប៉ាល័រ ហើយ​ឥទ្ធិពល​នឹង​បាត់។

ប្រសិនបើអ្នកដំណើរការវានៅលើកុំព្យូទ័រពីរ ហើយមិនច្រឡំអំពីអាសយដ្ឋាន IP នោះលទ្ធផលដូចគ្នាកំពុងរង់ចាំអ្នក - ការទំនាក់ទំនងតាមសំឡេងឌីជីថលពីរផ្លូវ។

នៅក្នុងអត្ថបទបន្ទាប់ យើងនឹងរៀនពីរបៀបសរសេរតម្រងផ្ទាល់ខ្លួនរបស់យើង - កម្មវិធីជំនួយ ដោយសារជំនាញនេះ អ្នកនឹងអាចប្រើ media streamer មិនត្រឹមតែសម្រាប់អូឌីយ៉ូ និងវីដេអូប៉ុណ្ណោះទេ ប៉ុន្តែថែមទាំងនៅក្នុងតំបន់ជាក់លាក់មួយចំនួនផ្សេងទៀតផងដែរ។

ប្រភព: www.habr.com