Kuongorora iyo Mediastreamer2 VoIP injini. Chikamu 6

Zvinyorwa zvechinyorwa zvakatorwa kubva kwangu zen channel.

Kutumira chiratidzo chekuteerera kuburikidza neRTP rwizi

Pakupedzisira chinyorwa Isu takaunganidza remoti rekudzora redunhu kubva kune toni jenareta uye toni detector inoshanda mukati mechirongwa chimwe chete. Muchikamu chino tichadzidza mashandisiro eRTP protocol (RFC 3550 - RTP: A Transport Protocol for Real-Time Applications) yekugamuchira / kutumira chiratidzo chekuteerera pane network yeEthernet.

RTP protocol (Real Time Protocol) yakashandurwa inoreva chaiyo-nguva protocol, inoshandiswa kutumira odhiyo, vhidhiyo, data, zvese zvinoda kutapurirana munguva chaiyo. Ngatitorei chiratidzo chekuteerera semuenzaniso. Iko kuchinjika kweprotocol ndeyekuti inokutendera kuti utumire odhiyo chiratidzo neyakafanotemerwa mhando.

Kutapurirana kunoitwa uchishandisa UDP mapaketi, zvinoreva kuti kurasikirwa kwepaketi kunogamuchirwa panguva yekufambisa. Paketi yega yega ine yakakosha RTP musoro uye data block yechiratidzo chinofambiswa. Musoro une chinongedzo chakasarudzwa chechiratidzo chechiratidzo, ruzivo nezve rudzi rwechiratidzo chiri kufambiswa, uye yakasarudzika nhamba yekutevedzana yepakiti kuitira kuti mapaketi agone kurongeka nenzira kwayo pakudhirodha, zvisinei nekurongeka kwaakaitwa ne network. Musoro unogonawo kuva neruzivo rwakawedzerwa, iyo inonzi yekuwedzera, iyo inobvumira kuti musoro ugadziriswe kuti ushandiswe mune rimwe basa rekushandisa.

Iyo data block ine mubhadharo wepaketi. Sangano remukati rezviri mukati rinoenderana nerudzi rwemutoro, inogona kunge iri masampuli emono chiratidzo, chiratidzo che stereo, mutsara wevhidhiyo mufananidzo, nezvimwe.

Rudzi rwemutoro unoratidzwa nenomwe-bit nhamba. Recommendation RFC3551 (RTP Mbiri yeOdhiyo uye Vhidhiyo Makonferensi ane Minimal Kudzora) inotangisa marudzi akati wandei emutoro; tafura inoenderana inopa tsananguro yemhando dzemutoro uye zvinorehwa nemakodhi ayo akasarudzwa nawo. Mamwe makodhi haana kusungirirwa kune chero mhando yemutoro; anogona kushandiswa kuratidza mutoro unopokana.

Saizi yedata block inogumira pamusoro nehukuru hwepaketi saizi inogona kufambiswa pane yakapihwa network isina segmentation (MTU parameter). Kazhinji, izvi hazvisi kupfuura 1500 bytes. Saka, kuti uwedzere huwandu hwe data inofambiswa pasekondi, unogona kuwedzera saizi yepakiti kusvika kune imwe nzvimbo, uye ipapo iwe uchafanirwa kuwedzera kuwanda kwekutumira mapaketi. Mune media streamer, iyi igadziriro inogadziriswa. Nekusagadzikana ndeye 50 Hz, i.e. 50 mapaketi pasekondi. Isu tichadaidza kutevedzana kwemapaketi eRTP erukova RTP.

Kuti utange kuendesa data pakati pechibviro neanogamuchira, zvakakwana kuti anotumira anoziva IP kero yeanogamuchira uye nhamba yechiteshi iyo yaanoshandisa kugamuchira. Avo. pasina chero maitiro ekutanga, sosi inotanga kuendesa data, uye anogamuchira, zvakare, akagadzirira kuigamuchira nekukasira kuigadzirisa. Zvinoenderana nechiyero, nhamba yechiteshi inoshandiswa kufambisa kana kugamuchira RTP rukova inofanira kunge yakaenzana.

Mumamiriro ezvinhu apo zvisingabviri kuziva kero yeanogamuchira pachine nguva, maseva anoshandiswa uko vanogamuchira vanosiya kero yavo, uye anotumira anogona kuikumbira nekutaura kune rimwe rakasiyana zita reanogamuchira.

Mumamiriro ezvinhu apo mhando yechiteshi chekutaurirana kana kugona kweanogashira kusingazivikanwe, chiteshi chemhinduro chinorongwa kuburikidza neapo mugamuchiri anogona kuzivisa mutakuri nezve kugona kwayo, huwandu hwemapaketi aakapotsa, nezvimwe. Iyi chiteshi inoshandisa iyo RTCP protocol. Chimiro chemapaketi anoparadzirwa muchiteshi ichi chinotsanangurwa muRFC 3605. Zvishoma zvishoma data inoparadzirwa pamusoro peiyi chiteshi, 200..300 bytes pasekondi, saka kazhinji, kuvapo kwayo hakusi kuremedza. Nhamba yechiteshi inotumirwa mapaketi eRTCP inofanira kunge isinganzwisisike uye imwe yakakura kupfuura nhamba yechiteshi kunobva RTP rukova. Mumuenzaniso wedu, isu hatizoshandisa chiteshi ichi, sezvo kugona kweanogamuchira uye chiteshi zviri pachena kuti anopfuura edu, kusvika zvino ane mwero, zvatinoda.

Muchirongwa chedu, dunhu rekutumira data, kusiyana nemuenzaniso wekare, richakamurwa kuita zvikamu zviviri: nzira yekufambisa uye nzira yekugamuchira. Pachikamu chega chega tichagadzira yedu sosi yewachi, sezvakaratidzwa mumufananidzo wemusoro.

Imwe-nzira yekukurukurirana pakati pavo ichaitwa uchishandisa iyo RTP protocol. Mumuenzaniso uyu, isu hatidi network yekunze, sezvo vese vanotumira uye vanogamuchira vachange vari pane imwechete komputa - mapaketi achafamba mukati mayo.

Kugadzira RTP rwizi, media streamer inoshandisa mafirita maviri: MS_RTP_SEND uye MS_RTP_RECV. Yekutanga inotamisa yechipiri uye inogamuchira RTP rwizi. Kuti aya mafirita ashande, anofanirwa kupfuudza chinongedzo kune chimwe chinhu chechikamu cheRTP, chinogona kushandura rwizi rwezvivharo zvedata kuita rukova rweRTP mapaketi kana kuita zvakapesana. Sezvo iyo yemukati data fomati yemedia streamer isingaenderane neiyo data fomati yeRTP packet, usati waendesa iyo data kuMS_RTP_SEND, unofanirwa kushandisa encoder sefa inoshandura 16-bit masaini masampula masampula kuita masere-bit encoded zvinoenderana ne u-law (mu-law). Padivi rekugamuchira, decoder sefa inoita rinopesana nebasa.

Pazasi pane iwo mameseji echirongwa chinoshandisa chirongwa chinoratidzwa mumufananidzo (iyo # zviratidzo zvisati zvaitika zvinosanganisirwa zvabviswa, usakanganwa kuzvibatanidza):

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

Isu tinounganidza uye tinomhanya. Iyo purogiramu ichashanda semumuenzaniso wapfuura, asi iyo data ichafambiswa kuburikidza neRTP rwizi.

Muchinyorwa chinotevera tichagovanisa chirongwa ichi kuita maviri akazvimirira maapplication - anogamuchira uye anotapurirana uye ozvitangisa mumaterminal akasiyana. Panguva imwecheteyo, isu tichadzidza kuongorora RTP mapaketi uchishandisa chirongwa cheTShark.

Source: www.habr.com