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

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

ការបញ្ជូនសញ្ញាអូឌីយ៉ូតាមរយៈស្ទ្រីម RTP

ក្នុង​អតីតកាល អត្ថបទ យើងបានប្រមូលផ្តុំសៀគ្វីបញ្ជាពីចម្ងាយពីម៉ាស៊ីនបង្កើតសម្លេង និងឧបករណ៍ចាប់សំឡេងដែលដំណើរការក្នុងកម្មវិធីតែមួយ។ នៅក្នុងអត្ថបទនេះយើងនឹងរៀនពីរបៀបប្រើពិធីការ RTP (RFC 3550 - RTP៖ ពិធីសារដឹកជញ្ជូនសម្រាប់កម្មវិធីពេលវេលាពិត) សម្រាប់ទទួល/បញ្ជូនសញ្ញាអូឌីយ៉ូតាមបណ្តាញអ៊ីសឺរណិត។

ពិធីការ RTP (ពិធីការពេលវេលាពិត) បកប្រែមានន័យថាពិធីការពេលវេលាពិត វាត្រូវបានប្រើដើម្បីបញ្ជូនអូឌីយ៉ូ វីដេអូ ទិន្នន័យ អ្វីគ្រប់យ៉ាងដែលទាមទារការបញ្ជូនតាមពេលវេលាជាក់ស្តែង។ តោះយកសញ្ញាអូឌីយ៉ូជាឧទាហរណ៍។ ភាពបត់បែននៃពិធីការគឺដូចដែលវាអនុញ្ញាតឱ្យអ្នកបញ្ជូនសញ្ញាសំឡេងជាមួយនឹងគុណភាពដែលបានកំណត់ទុកជាមុន។

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

ប្លុកទិន្នន័យផ្ទុកបន្ទុកនៃកញ្ចប់ព័ត៌មាន។ ការរៀបចំផ្ទៃក្នុងនៃមាតិកាអាស្រ័យលើប្រភេទនៃការផ្ទុក វាអាចជាគំរូនៃសញ្ញាម៉ូណូ សញ្ញាស្តេរ៉េអូ ខ្សែរូបភាពវីដេអូ។ល។

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

ទំហំនៃប្លុកទិន្នន័យត្រូវបានកំណត់ខាងលើដោយទំហំកញ្ចប់អតិបរមាដែលអាចត្រូវបានបញ្ជូននៅលើបណ្តាញដែលបានផ្តល់ឱ្យដោយគ្មានការបែងចែក (ប៉ារ៉ាម៉ែត្រ MTU) ។ ជាទូទៅវាមិនលើសពី 1500 បៃទេ។ ដូច្នេះ ដើម្បីបង្កើនចំនួនទិន្នន័យដែលបានបញ្ជូនក្នុងមួយវិនាទី អ្នកអាចបង្កើនទំហំកញ្ចប់ព័ត៌មានរហូតដល់ចំណុចជាក់លាក់មួយ ហើយបន្ទាប់មកអ្នកនឹងត្រូវបង្កើនភាពញឹកញាប់នៃការផ្ញើកញ្ចប់ព័ត៌មាន។ នៅក្នុងកម្មវិធីផ្សាយមេឌៀ នេះគឺជាការកំណត់ដែលអាចកំណត់បាន។ តាមលំនាំដើមវាគឺ 50 Hz, i.e. 50 កញ្ចប់ក្នុងមួយវិនាទី។ យើង​នឹង​ហៅ​លំដាប់​នៃ​កញ្ចប់ RTP ដែល​បាន​បញ្ជូន​ថា​ជា​ស្ទ្រីម RTP ។

ដើម្បីចាប់ផ្តើមបញ្ជូនទិន្នន័យរវាងប្រភពនិងអ្នកទទួល វាគ្រប់គ្រាន់ហើយដែលអ្នកបញ្ជូនដឹងអាសយដ្ឋាន IP របស់អ្នកទទួល និងលេខច្រកដែលវាប្រើសម្រាប់ការទទួល។ ទាំងនោះ។ ដោយគ្មាននីតិវិធីបឋមណាមួយ ប្រភពចាប់ផ្តើមបញ្ជូនទិន្នន័យ ហើយអ្នកទទួលគឺត្រៀមខ្លួនជាស្រេចក្នុងការទទួល និងដំណើរការវាភ្លាមៗ។ យោងតាមស្តង់ដារ លេខច្រកដែលប្រើដើម្បីបញ្ជូន ឬទទួលស្ទ្រីម RTP ត្រូវតែស្មើ។

នៅក្នុងស្ថានភាពដែលមិនអាចដឹងពីអាសយដ្ឋានរបស់អ្នកទទួលជាមុន នោះម៉ាស៊ីនមេត្រូវបានប្រើដែលអ្នកទទួលចាកចេញពីអាសយដ្ឋានរបស់ពួកគេ ហើយអ្នកបញ្ជូនអាចស្នើសុំវាដោយយោងទៅលើឈ្មោះតែមួយគត់របស់អ្នកទទួល។

ក្នុងករណីដែលមិនស្គាល់គុណភាពនៃបណ្តាញទំនាក់ទំនង ឬសមត្ថភាពរបស់អ្នកទទួល ឆានែលមតិត្រឡប់ត្រូវបានរៀបចំឡើង តាមរយៈការដែលអ្នកទទួលអាចជូនដំណឹងដល់អ្នកបញ្ជូនអំពីសមត្ថភាពរបស់វា ចំនួនកញ្ចប់ព័ត៌មានដែលវាបានខកខាន។ល។ ឆានែលនេះប្រើពិធីការ RTCP ។ ទ្រង់ទ្រាយនៃកញ្ចប់ព័ត៌មានដែលបានបញ្ជូននៅក្នុងឆានែលនេះត្រូវបានកំណត់នៅក្នុង RFC 3605 ។ ទិន្នន័យតិចតួចត្រូវបានបញ្ជូនតាមឆានែលនេះ 200..300 បៃក្នុងមួយវិនាទី ដូច្នេះជាទូទៅវត្តមានរបស់វាមិនមានបន្ទុកទេ។ លេខច្រកដែលកញ្ចប់ RTCP ត្រូវបានផ្ញើត្រូវតែជាលេខសេស និងមួយធំជាងលេខច្រកដែលចរន្ត RTP មក។ ក្នុងឧទាហរណ៍របស់យើង យើងនឹងមិនប្រើឆានែលនេះទេ ព្រោះសមត្ថភាពរបស់អ្នកទទួល និងឆានែលច្បាស់ជាលើសពីតម្រូវការរបស់យើង រហូតមកដល់ពេលនេះតិចតួច។

នៅក្នុងកម្មវិធីរបស់យើង សៀគ្វីបញ្ជូនទិន្នន័យមិនដូចឧទាហរណ៍មុនទេ នឹងត្រូវបែងចែកជាពីរផ្នែក៖ ផ្លូវបញ្ជូន និងផ្លូវទទួល។ សម្រាប់ផ្នែកនីមួយៗ យើងនឹងបង្កើតប្រភពនាឡិកាផ្ទាល់របស់យើង ដូចបង្ហាញក្នុងរូបភាពចំណងជើង។

ការទំនាក់ទំនងមួយផ្លូវរវាងពួកវានឹងត្រូវបានអនុវត្តដោយប្រើពិធីការ RTP ។ ក្នុងឧទាហរណ៍នេះ យើងមិនត្រូវការបណ្តាញខាងក្រៅទេ ព្រោះទាំងឧបករណ៍បញ្ជូន និងអ្នកទទួលនឹងមានទីតាំងនៅលើកុំព្យូទ័រតែមួយ - កញ្ចប់ព័ត៌មាននឹងធ្វើដំណើរនៅខាងក្នុងវា។

ដើម្បីបង្កើតការផ្សាយ RTP អ្នកផ្សាយមេឌៀប្រើតម្រងពីរ៖ MS_RTP_SEND និង MS_RTP_RECV ។ ទីមួយបញ្ជូនទីពីរហើយទទួលបានចរន្ត RTP ។ ដើម្បីឱ្យតម្រងទាំងនេះដំណើរការ ពួកគេត្រូវបញ្ជូនទ្រនិចទៅវត្ថុសម័យ RTP ដែលអាចបំប្លែងស្ទ្រីមនៃប្លុកទិន្នន័យទៅជាស្ទ្រីមនៃកញ្ចប់ព័ត៌មាន RTP ឬធ្វើផ្ទុយពីនេះ។ ដោយសារទម្រង់ទិន្នន័យខាងក្នុងរបស់កម្មវិធីផ្សាយមេឌៀមិនត្រូវគ្នានឹងទ្រង់ទ្រាយទិន្នន័យនៃកញ្ចប់ព័ត៌មាន RTP មុនពេលផ្ទេរទិន្នន័យទៅ MS_RTP_SEND អ្នកត្រូវប្រើតម្រងបំលែងកូដដែលបំប្លែងគំរូសញ្ញាអូឌីយ៉ូ 16 ប៊ីតទៅជាប្រាំបីប៊ីតដែលបានអ៊ិនកូដដោយយោងទៅតាម u-law (mu-law) ។ នៅផ្នែកទទួល តម្រងឌិកូដដំណើរការមុខងារផ្ទុយ។

ខាងក្រោមនេះជាអត្ថបទរបស់កម្មវិធីដែលអនុវត្តគ្រោងការណ៍ដែលបង្ហាញក្នុងរូប (និមិត្តសញ្ញា # មុនពេលការណែនាំរួមបញ្ចូលត្រូវបានដកចេញ កុំភ្លេចបញ្ចូលពួកវា)៖

/* Файл mstest6.c Имитатор пульта управления и приемника. */
#include <mediastreamer2/msfilter.h>
#include <mediastreamer2/msticker.h>
#include <mediastreamer2/dtmfgen.h>
#include <mediastreamer2/mssndcard.h>
#include <mediastreamer2/msvolume.h>
#include <mediastreamer2/mstonedetector.h>
#include <mediastreamer2/msrtp.h>
#include <ortp/rtpsession.h>
#include <ortp/payloadtype.h>
/* Подключаем заголовочный файл с функциями управления событиями
* медиастримера.*/
include <mediastreamer2/mseventqueue.h>
#define PCMU 0
/* Функция обратного вызова, она будет вызвана фильтром, как только он
обнаружит совпадение характеристик входного сигнала с заданными. */
static void tone_detected_cb(void *data, MSFilter *f, unsigned int event_id,
MSToneDetectorEvent *ev)
{
printf("Принята команда: %sn", ev->tone_name);
}
/*----------------------------------------------------------------------------*/
/* Функция регистрации типов полезных нагрузок. */
void register_payloads(void)
{
/*Регистрируем типы нагрузок в таблице профилей. Позднее, по индексу
взятому из заголовка RTP-пакета из этой таблицы будут извлекаться
параметры нагрузки, необходимые для декодирования данных пакета. */
rtp_profile_set_payload (&av_profile, PCMU, &payload_type_pcm8000);
}
/*----------------------------------------------------------------------------*/
/* Эта функция создана из функции create_duplex_rtpsession() в audiostream.c
медиастримера2. */
static RtpSession *
create_rtpsession (int loc_rtp_port, int loc_rtcp_port,
bool_t ipv6, RtpSessionMode mode)
{
RtpSession *rtpr;
rtpr = rtp_session_new ((int) mode);
rtp_session_set_scheduling_mode (rtpr, 0);
rtp_session_set_blocking_mode (rtpr, 0);
rtp_session_enable_adaptive_jitter_compensation (rtpr, TRUE);
rtp_session_set_symmetric_rtp (rtpr, TRUE);
rtp_session_set_local_addr (rtpr, ipv6 ? "::" : "0.0.0.0", loc_rtp_port,
loc_rtcp_port);
rtp_session_signal_connect (rtpr, "timestamp_jump",
(RtpCallback) rtp_session_resync, 0);
rtp_session_signal_connect (rtpr, "ssrc_changed",
(RtpCallback) rtp_session_resync, 0);
rtp_session_set_ssrc_changed_threshold (rtpr, 0);
rtp_session_set_send_payload_type(rtpr, PCMU);
/* По умолчанию выключаем RTCP-сессию, так как наш пульт не будет использовать её. */
rtp_session_enable_rtcp (rtpr, FALSE);
return rtpr;
}
/*----------------------------------------------------------------------------*/
int main()
{
ms_init();
/* Создаем экземпляры фильтров. */
MSFilter *voidsource = ms_filter_new(MS_VOID_SOURCE_ID);
MSFilter *dtmfgen = ms_filter_new(MS_DTMF_GEN_ID);
MSFilter *volume = ms_filter_new(MS_VOLUME_ID);
MSSndCard *card_playback =
ms_snd_card_manager_get_default_card(ms_snd_card_manager_get());
MSFilter *snd_card_write = ms_snd_card_create_writer(card_playback);
MSFilter *detector = ms_filter_new(MS_TONE_DETECTOR_ID);
/* Очищаем массив находящийся внутри детектора тонов, он описывает
* особые приметы разыскиваемых сигналов.*/
ms_filter_call_method(detector, MS_TONE_DETECTOR_CLEAR_SCANS, 0);
/* Подключаем к фильтру функцию обратного вызова. */
ms_filter_set_notify_callback(detector,
(MSFilterNotifyFunc)tone_detected_cb, NULL);
/* Создаем массив, каждый элемент которого описывает характеристику
* одного из тонов, который требуется обнаруживать: Текстовое имя
* данного элемента, частота в герцах, длительность в миллисекундах,
* минимальный уровень относительно 0,775В. */
MSToneDetectorDef scan[6]=
{
{"V+",440, 100, 0.1}, /* Команда "Увеличить громкость". */
{"V-",540, 100, 0.1}, /* Команда "Уменьшить громкость". */
{"C+",640, 100, 0.1}, /* Команда "Увеличить номер канала". */
{"C-",740, 100, 0.1}, /* Команда "Уменьшить номер канала". */
{"ON",840, 100, 0.1}, /* Команда "Включить телевизор". */
{"OFF", 940, 100, 0.1}/* Команда "Выключить телевизор". */
};
/* Передаем "приметы" сигналов детектор тонов. */
int i;
for (i = 0; i < 6; i++)
{
ms_filter_call_method(detector, MS_TONE_DETECTOR_ADD_SCAN,
&scan[i]);
}
/* Создаем фильтры кодера и декодера */
MSFilter *encoder = ms_filter_create_encoder("PCMU");
MSFilter *decoder=ms_filter_create_decoder("PCMU");
/* Регистрируем типы нагрузки. */
register_payloads();
/* Создаем RTP-сессию передатчика. */
RtpSession *tx_rtp_session = create_rtpsession (8010, 8011, FALSE, RTP_SESSION_SENDONLY);
rtp_session_set_remote_addr_and_port(tx_rtp_session,"127.0.0.1", 7010, 7011);
rtp_session_set_send_payload_type(tx_rtp_session, PCMU);
MSFilter *rtpsend = ms_filter_new(MS_RTP_SEND_ID);
ms_filter_call_method(rtpsend, MS_RTP_SEND_SET_SESSION, tx_rtp_session);
/* Создаем RTP-сессию приемника. */
MSFilter *rtprecv = ms_filter_new(MS_RTP_RECV_ID);
RtpSession *rx_rtp_session = create_rtpsession (7010, 7011, FALSE, RTP_SESSION_RECVONLY);
ms_filter_call_method(rtprecv, MS_RTP_RECV_SET_SESSION, rx_rtp_session);
/* Создаем источники тактов - тикеры. */
MSTicker *ticker_tx = ms_ticker_new();
MSTicker *ticker_rx = ms_ticker_new();
/* Соединяем фильтры передатчика. */
ms_filter_link(voidsource, 0, dtmfgen, 0);
ms_filter_link(dtmfgen, 0, volume, 0);
ms_filter_link(volume, 0, encoder, 0);
ms_filter_link(encoder, 0, rtpsend, 0);
/* Соединяем фильтры приёмника. */
ms_filter_link(rtprecv, 0, decoder, 0);
ms_filter_link(decoder, 0, detector, 0);
ms_filter_link(detector, 0, snd_card_write, 0);
/* Подключаем источник тактов. */
ms_ticker_attach(ticker_tx, voidsource);
ms_ticker_attach(ticker_rx, rtprecv);
/* Настраиваем структуру, управляющую выходным сигналом генератора. */
MSDtmfGenCustomTone dtmf_cfg;
dtmf_cfg.tone_name[0] = 0;
dtmf_cfg.duration = 1000;
dtmf_cfg.frequencies[0] = 440;
/* Будем генерировать один тон, частоту второго тона установим в 0. */
dtmf_cfg.frequencies[1] = 0;
dtmf_cfg.amplitude = 1.0;
dtmf_cfg.interval = 0.;
dtmf_cfg.repeat_count = 0.;
/* Организуем цикл сканирования нажатых клавиш. Ввод нуля завершает
* цикл и работу программы. */
char key='9';
printf("Нажмите клавишу команды, затем ввод.n"
"Для завершения программы введите 0.n");
while(key != '0')
{
key = getchar();
if ((key >= 49) && (key <= 54))
{
printf("Отправлена команда: %cn", key);
/* Устанавливаем частоту генератора в соответствии с
* кодом нажатой клавиши. */
dtmf_cfg.frequencies[0] = 440 + 100*(key-49);
/* Включаем звуковой генератор c обновленной частотой. */
ms_filter_call_method(dtmfgen, MS_DTMF_GEN_PLAY_CUSTOM,
(void*)&dtmf_cfg);
}
/* Укладываем тред в спячку на 20мс, чтобы другие треды
* приложения получили время на работу. */
ms_usleep(20000);
}
}

យើងចងក្រងនិងដំណើរការ។ កម្មវិធីនឹងដំណើរការដូចក្នុងឧទាហរណ៍មុន ប៉ុន្តែទិន្នន័យនឹងត្រូវបានបញ្ជូនតាមរយៈស្ទ្រីម RTP ។

នៅក្នុងអត្ថបទបន្ទាប់ យើងនឹងបែងចែកកម្មវិធីនេះជាកម្មវិធីឯករាជ្យពីរ - អ្នកទទួល និងឧបករណ៍បញ្ជូន ហើយបើកដំណើរការពួកវានៅក្នុងស្ថានីយផ្សេងៗគ្នា។ ក្នុងពេលជាមួយគ្នានេះ យើងនឹងរៀនពីរបៀបវិភាគកញ្ចប់ព័ត៌មាន RTP ដោយប្រើកម្មវិធី TShark ។

ប្រភព: www.habr.com