Ukuphonononga injini yeMediastreamer2 VoIP. Icandelo 6

Izinto zenqaku zithathwe kum zen channel.

Ukusasaza isiginali yesandi ngeRTP umjelo

Ekugqibeleni nqaku Siqokelele isiphaluka solawulo olude ukusuka kwijenereyitha yethoni kunye nethoni yethoni esebenza ngaphakathi kweprogram efanayo. Kweli nqaku siza kufunda indlela yokusebenzisa i-RTP protocol (RFC 3550 - I-RTP: IProtokholi yezoThutho yezicelo zeXesha langempela) ukufumana/ukuhambisa umqondiso wesandi kwinethiwekhi ye-Ethernet.

Iprothokholi ye-RTP (Ixesha lokwenyani Protocol) ukuguqulelwa kuthetha iprotocol yexesha langempela, isetyenziselwa ukuhambisa i-audio, ividiyo, idatha, yonke into efuna ukuhanjiswa ngexesha langempela. Makhe sithathe umqondiso wesandi njengomzekelo. Ukuguquguquka kweprotocol kukuvumela ukuba udlulise isignali yomsindo kunye nomgangatho omiselweyo.

Ukuhanjiswa kuqhutywa kusetyenziswa iipakethi ze-UDP, oku kuthetha ukuba ukulahleka kwepakethi kwamkelekile ngexesha lokuhanjiswa. Ipakethi nganye iqulethe i-header ye-RTP ekhethekileyo kunye nebhloko yedatha yesignali edlulisiweyo. Iheda iqulethe isichongi somthombo womqondiso okhethwe ngokungenamkhethe, ulwazi malunga nohlobo lomqondiso ogqithiselwayo, kunye nenombolo yolandelelwano lwepakethe eyodwa ukwenzela ukuba iipakethi zilungelelaniswe ngolandelelwano oluchanekileyo xa kufakwa ikhowudi, kungakhathaliseki indlela ezihanjiswe ngayo. inethiwekhi. I-header inokuphinda iqulethe ulwazi olongezelelweyo, okubizwa ngokuba yisandiso, esivumela ukuba intloko ilungele ukusetyenziswa kumsebenzi othile wesicelo.

Ibhloko yedatha iqulethe umthwalo wepakethi. Umbutho wangaphakathi womxholo uxhomekeke kuhlobo lomthwalo, ingaba iisampulu zesignali ye-mono, isignali ye-stereo, umgca wevidiyo wevidiyo, njl.

Uhlobo lomthwalo luboniswa ngamanani asixhenxe. Ingcebiso RFC3551 (Iprofayile ye-RTP yeeNkomfa zeAudio kunye neVidiyo enoLawulo oluncinciiseka iintlobo ezininzi zomthwalo, itheyibhile ehambelanayo ibonelela ngenkcazo yeentlobo zomthwalo kunye nentsingiselo yeekhowudi ezichongwe ngazo. Ezinye iikhowudi azibotshelelwanga ngokungqongqo kulo naluphi na uhlobo lomthwalo; zingasetyenziselwa ukumisela umthwalo ongekho mthethweni.

Ubungakanani bebhloko yedatha bukhawulelwe ngasentla ngobungakanani bepakethe enkulu enokuthi idluliselwe kumnatha onikiweyo ngaphandle kokwahlula (MTU parameter). Ngokubanzi, oku akukho ngaphezu kwe-1500 bytes. Ngaloo ndlela, ukwenzela ukwandisa inani leedatha ezithunyelwa ngesekhondi, unokwandisa ubungakanani bepakethi ukuya kwindawo ethile, kwaye emva koko kuya kufuneka ukwandise ukuphindaphinda kokuthumela iipakethi. Kusasazo lwemidiya, olu lulungiselelo oluqwalaselweyo. Ngokungagqibekanga yi-50 Hz, okt. Iipakethi ezingama-50 ngesekhondi. Siza kubiza ukulandelelana kweepakethi ze-RTP ezigqithisiweyo ngumjelo we-RTP.

Ukuqala ukudlulisa idatha phakathi komthombo kunye nommkeli, kwanele ukuba umthumeli uyazi idilesi ye-IP yomamkeli kunye nenombolo ye-port esetyenziselwa ukufumana. Ezo. ngaphandle kweenkqubo zokuqala, umthombo uqala ukuhambisa idatha, kwaye umamkeli, naye, ulungele ukuyifumana ngokukhawuleza kwaye ayiqhube. Ngokomgangatho, inombolo yezibuko esetyenziselwa ukuhambisa okanye ukufumana umjelo we-RTP kufuneka ilingane.

Kwiimeko apho kungenakwenzeka ukwazi idilesi yomamkeli kwangaphambili, iiseva zisetyenziswa apho abamkeli beshiya idilesi yabo, kwaye umthumeli unokucela ngokubhekisa kwelinye igama elikhethekileyo lomamkeli.

Kwiimeko apho umgangatho wejelo lonxibelelwano okanye amandla omntu owamkelayo angaziwa, ishaneli yempendulo ihlelwe apho ummkeli anokwazisa umthumeli malunga nobuchule bakhe, inani leepakethi eziphosiweyo, njl. Eli jelo lisebenzisa iprotocol ye-RTCP. Ifomathi yeepakethi ezihanjiswe kule tshaneli ichazwe kwi-RFC 3605. Idatha encinci ihanjiswa phezu kwesi siteshi, i-200.. Inombolo yezibuko apho iipakethi ze-RTCP zithunyelwa khona kufuneka ibe ngumnqakathi kwaye enye inkulu kunenombolo yezibuko apho umsinga we-RTP uvela khona. Kumzekelo wethu, asiyi kusebenzisa eli jelo, kuba amandla omamkeli kunye nejelo ngokucacileyo adlula iimfuno zethu, ukuza kuthi ga ngoku.

Kwiprogram yethu, isekethe yokuhanjiswa kwedatha, ngokungafaniyo nomzekelo wangaphambili, iya kwahlulwa ibe ngamacandelo amabini: indlela yokudlulisa kunye nendlela yokufumana. Kwinxalenye nganye siya kwenza umthombo wethu wewotshi, njengoko kubonisiwe kumfanekiso wesihloko.

Unxibelelwano lwendlela enye phakathi kwabo luya kwenziwa kusetyenziswa iprotocol ye-RTP. Kulo mzekelo, asiyidingi inethiwekhi yangaphandle, kuba zombini i-transmitter kunye ne-receiver iya kufumaneka kwikhompyuter enye - iipakethi ziya kuhamba ngaphakathi kwayo.

Ukuseka umjelo we-RTP, i-media streamer isebenzisa izihluzo ezimbini: MS_RTP_SEND kunye ne-MS_RTP_RECV. Eyokuqala idlulisela eyesibini kwaye ifumana umsinga we-RTP. Ukuze ezi zihluzo zisebenze, kufuneka zigqithise isalathisi kwinto yeseshoni ye-RTP, enokuthi iguqule umlambo weebhloko zedatha kwi-packet ye-RTP okanye yenza okuchaseneyo. Kuba ifomathi yedatha yangaphakathi ye-media streamer ayihambelani nefomathi yedatha yepakethe ye-RTP, ngaphambi kokudlulisela idatha kwi-MS_RTP_SEND, kufuneka usebenzise isihluzo se-encoder esiguqula iisampulu ze-16-bit zesandi kwi-bit-bit encoded ngokwe- u-law (mu-law). Kwicala lokufumana, isihluzo sedekhowuda senza umsebenzi ochaseneyo.

Apha ngezantsi kumbhalo wenkqubo ophumeza iskimu esiboniswe kumzobo (iisimboli # phambi kokuba izikhokelo zisuswe, ungalibali ukuzibandakanya):

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

Siyaqokelela kwaye siqhube. Inkqubo iya kusebenza njengakumzekelo wangaphambili, kodwa idatha iya kuhanjiswa nge-RTP stream.

Kwinqaku elilandelayo siya kwahlula le nkqubo ibe zizicelo ezimbini ezizimeleyo - umamkeli kunye nomthumeli kwaye uziqalise kwii-terminals ezahlukeneyo. Ngelo xesha, siya kufunda indlela yokuhlalutya iipakethi ze-RTP usebenzisa inkqubo ye-TShark.

umthombo: www.habr.com