Kuwunika injini ya Mediastreamer2 VoIP. Gawo 6

Zomwe zili m'nkhaniyi zatengedwa kuchokera ku wanga zene channel.

Kutumiza siginecha yomvera kudzera pamtsinje wa RTP

Pomaliza nkhani Tasonkhanitsa dera lakutali kuchokera ku jenereta ya ma toni ndi chojambulira ma toni chomwe chimagwira ntchito mkati mwa pulogalamu yomweyo. M'nkhaniyi tiphunzira momwe tingagwiritsire ntchito RTP protocol (RFC 3550 - RTP: Protocol ya Transport for Real-Time Application) polandila/kutumiza mawu omvera pa netiweki ya Ethernet.

Ndondomeko ya RTP (Real Time Protocol) kumasuliridwa kumatanthauza ndondomeko ya nthawi yeniyeni, imagwiritsidwa ntchito potumiza mauthenga, kanema, deta, chirichonse chomwe chimafuna kufalitsa nthawi yeniyeni. Tiyeni titenge chizindikiro cha audio mwachitsanzo. Kusinthasintha kwa protocol ndi kotero kuti kumakupatsani mwayi wotumiza siginecha yamawu ndi mtundu wodziwikiratu.

Kusamutsa kumachitika pogwiritsa ntchito mapaketi a UDP, zomwe zikutanthauza kuti kutayika kwa paketi ndikovomerezeka pakusamutsa. Paketi iliyonse imakhala ndi mutu wapadera wa RTP ndi chipika cha data cha siginecha yopatsirana. Mutuwu uli ndi chizindikiritso cha magwero osankhidwa mwachisawawa, zambiri za mtundu wa siginecha yomwe ikutumizidwa, ndi nambala yapadera yapaketi yotsatizana kuti mapaketiwo athe kukonzedwa mwadongosolo lolondola polemba, mosasamala kanthu za dongosolo lomwe adaperekedwa ndi network. Mutuwu ukhozanso kukhala ndi zowonjezera zowonjezera, zomwe zimatchedwa zowonjezera, zomwe zimalola kuti mutuwo usinthe kuti ugwiritsidwe ntchito pa ntchito inayake yogwiritsira ntchito.

Deta ya data ili ndi malipiro a paketi. Bungwe lamkati lazomwe zilili zimadalira mtundu wa katundu, zikhoza kukhala zitsanzo za chizindikiro cha mono, chizindikiro cha stereo, chithunzi cha kanema, ndi zina zotero.

Mtundu wa katundu umasonyezedwa ndi nambala zisanu ndi ziwiri. Malangizo RFC3551 (Mbiri ya RTP Yamisonkhano Yamawu ndi Makanema ndi Minimal Control) imakhazikitsa mitundu ingapo ya katundu; tebulo lofananira limapereka kufotokozera kwa mitundu ya katundu ndi tanthauzo la ma code omwe amasankhidwa. Ma code ena samangiriridwa kumtundu uliwonse wa katundu; amatha kugwiritsidwa ntchito kuwonetsa katundu mosasamala.

Kukula kwa chipika cha data kumachepetsedwa pamwambapa ndi kukula kwake kwa paketi komwe kumatha kufalitsidwa pamaneti opatsidwa popanda magawo (MTU parameter). Nthawi zambiri, izi siziposa 1500 byte. Choncho, kuti muwonjezere kuchuluka kwa deta yomwe imafalitsidwa pamphindikati, mukhoza kuonjezera kukula kwa paketi mpaka kufika pamalo enaake, ndiyeno mudzafunika kuonjezera maulendo otumizira mapaketi. Mu media streamer, uku ndikusintha kosinthika. Mwachikhazikitso ndi 50 Hz, i.e. 50 mapaketi pa sekondi iliyonse. Tidzatcha kutsatizana kwa mapaketi a RTP otumizidwa kukhala mtsinje wa RTP.

Kuti muyambe kutumiza deta pakati pa gwero ndi wolandira, ndikwanira kuti wotumizayo adziwe adilesi ya IP ya wolandila ndi nambala ya doko yomwe amagwiritsa ntchito polandila. Iwo. popanda njira zoyambira, gwero limayamba kutumiza deta, ndipo wolandirayo, nayenso, ali wokonzeka kulandira ndikuyikonza. Malinga ndi muyezo, nambala ya doko yomwe imagwiritsidwa ntchito potumiza kapena kulandira mtsinje wa RTP iyenera kukhala yofanana.

M'mikhalidwe yomwe sikungatheke kudziwa adilesi ya wolandila pasadakhale, ma seva amagwiritsidwa ntchito pomwe olandila amasiya ma adilesi awo, ndipo wotumizira amatha kupempha potchula dzina lapadera la wolandila.

Zikadakhala kuti mtundu wa njira yolumikizirana kapena kuthekera kwa wolandila sikudziwika, njira yoyankhira imakonzedwa kudzera momwe wolandila angadziwitse wotumiza za kuthekera kwake, kuchuluka kwa mapaketi omwe adaphonya, ndi zina zambiri. Njirayi imagwiritsa ntchito protocol ya RTCP. Mapangidwe a mapaketi omwe amafalitsidwa mu njira iyi amatanthauzidwa mu RFC 3605. Deta yaing'ono imafalitsidwa pa njira iyi, 200..300 byte pamphindi, kotero kuti kukhalapo kwake sikuli kolemetsa. Nambala ya doko yomwe mapaketi a RTCP amatumizidwa iyenera kukhala yosamvetseka ndi imodzi yokulirapo kuposa nambala ya doko komwe RTP mtsinje umachokera. M'chitsanzo chathu, sitigwiritsa ntchito njira iyi, chifukwa kuthekera kwa wolandila ndi kanjira mwachiwonekere kumaposa zosowa zathu, zocheperako.

Mu pulogalamu yathu, dera lotumizira deta, mosiyana ndi chitsanzo chapitachi, lidzagawidwa m'magawo awiri: njira yotumizira ndi njira yolandirira. Pa gawo lirilonse tidzapanga gwero lathu la wotchi, monga momwe chithunzithunzi chamutu chikusonyezera.

Kuyankhulana kwa njira imodzi pakati pawo kudzachitika pogwiritsa ntchito protocol ya RTP. Muchitsanzo ichi, sitifunikira netiweki yakunja, popeza onse otumiza ndi wolandila adzakhala pakompyuta yomweyo - mapaketiwo aziyenda mkati mwake.

Kukhazikitsa mtsinje wa RTP, media streamer imagwiritsa ntchito zosefera ziwiri: MS_RTP_SEND ndi MS_RTP_RECV. Yoyamba imatumiza yachiwiri ndikulandila mtsinje wa RTP. Kuti zoseferazi zigwire ntchito, ziyenera kudutsa cholozera ku chinthu cha gawo la RTP, chomwe chingasinthe mitsinje yazida za data kukhala mtsinje wa mapaketi a RTP kapena kuchita mosiyana. Popeza mtundu wa data wamkati wa media streamer sufanana ndi mtundu wa data wa paketi ya RTP, musanasamutsire deta ku MS_RTP_SEND, muyenera kugwiritsa ntchito fyuluta ya encoder yomwe imasintha ma siginolo a 16-bit kukhala ma encoded eyiti molingana ndi u-law (mu-law). Pa mbali yolandira, fyuluta ya decoder imagwira ntchito ina.

Pansipa pali zolemba za pulogalamu yomwe imagwiritsa ntchito chiwembu chomwe chawonetsedwa pachithunzichi (zizindikiro # zisanachotsedwe, osayiwala kuziphatikiza):

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

Timasonkhanitsa ndikuthamanga. Pulogalamuyi idzagwira ntchito monga momwe yachitira kale, koma deta idzatumizidwa kudzera mumtsinje wa RTP.

M'nkhani yotsatira tigawa pulogalamuyi m'mapulogalamu awiri odziyimira pawokha - cholandila ndi chotumizira ndikuyambitsa ma terminals osiyanasiyana. Nthawi yomweyo, tiphunzira kusanthula mapaketi a RTP pogwiritsa ntchito pulogalamu ya TShark.

Source: www.habr.com