Explorans machinam Mediastreamer2 VoIP. Pars I

Materia articuli sumitur ex my rhoncus channel.

Audio signum transmittendi per RTP stream

In novissimis articulus Convenimus in dicione remota a tono generante et tono detectore qui in eodem programmate operantur. In hoc capitulo quomodo uti RTP protocollo discemus (RFC 3550 - RTP: onerariam Protocollum ad Verus-Tempus Applications) Recipiendi / tradendi signum audio super network Aer.

RTP protocol (Verus tempus Protocol) translatum significat protocollum reale tempus, adhibetur ut transmittat audio, video, datam, omnia quae in reali tempore postulat transmissionem. Sit signum audio in exemplum. Flexibilitas protocolli talis est ut signum auditionis transmittere sinat cum qualitate praefinita.

Transmissio fit per UDP facis, quod significat damnum fasciculum satis acceptum in transmissione. Singulis fasciculus peculiarem RTP caput continet et truncum notitiae signum transmittendum. Capitulus passim selectas continet signum fontis identificantis, informationes de speciei signo transmissae, ac singularem seriem sequentiarum numeri ita ut fasciculi in recto ordine disponi possint cum decoding, cuiuscumque ordinis in quo traditum est. ornatum. Caput potest etiam habere informationem informationem, extensionem sic dictam, quae sinit caput usui aptari in certa applicatione operis.

Notitia stipes continet payload fasciculi. Organizationis contenti interna pendet a genere oneris, potest esse exempla monos significationis, signum stereo, linea imaginis video, etc.

Onus genus significatur per numerum septem frenum. Commendatio RFC3551 (RTP Profile for Audio and Video Conferenceswith Minimal Control) varia genera oneris constituit, mensa debita descriptionem praebet generum oneris ac sensum notarum quibus designantur. Nonnulli codices ad quodvis oneris genus stricte non ligantur, ad arbitrarium onus designandum adhiberi possunt.

Magnitudo scandali notitiae supra limitatur a magnitudine maxima fasciculi, quae in retis datis sine segmentatione transfundi potest (parameter MTU). In genere, hoc non plus quam 1500 bytes est. Sic, ut per secundam transmissam datarum quantitatem augeat, fasciculum ad certum punctum augere potes, et frequentiam mittendis fasciculis augere debes. In media streamer, haec occasus configurabilis est. Defalta facta est 50 Hz, i.e. L secunda per facis. Ordinem RTP transmissarum appellabimus packets RTP rivuli.

Ut notitias transmittens inter principium et accipientem committitur, satis est transfusor cognoscere IP oratio recipientis et numerum portum quem utitur ad recipiendum. Illae. sine praemissis processibus, fons incipit notitias tradendas, et recipiens vicissim paratus est ut statim recipiat et processum faciat. Secundum mensuram portus numerus usus est ut transmittere vel recipere RTP amnis necesse sit.

In casibus in quibus impossibile est cognoscere orationem recipientis in antecessum, ministri adhibentur ubi accipientes electronicam relinquunt, et transfusor id petere possunt referendo ad aliquod nomen accipientis singulare.

In casibus in quibus qualitas canalis communicationis vel recipientis facultates ignotae sunt, canalis feedback ordinatur per quos receptor transmittentes de suis facultatibus certiorem facere potest, numerum fasciculorum quem desiderant, etc. Hic canalis utitur protocollo RTCP. Forma fasciculorum in hoc canali transmissa definitur in RFC 3605. Relativa parva notitia super hunc canalem transmittitur, 200.. 300 bytes secundo, sic generatim, praesentia eius gravis non est. Numerus portus ad quem RTCP mittuntur facis esse impar et unus maior quam numerus portus ex quo RTP rivus venit. In nostro exemplo, hoc canali non utemur, cum facultates accipientis et canalis nostros manifesto excedant, quantum modesti sunt, necessitates.

In nostro programmate, notitia circuli transmissionis, dissimilis exemplo praecedenti, in duas partes dividetur: iter transmittens et iter acceptum. Pro unaquaque parte nostrum proprium horologii fontem faciemus, ut in titulo picturae ostensum est.

Una communicatio inter eos via RTP protocollo adhibita peragetur. In hoc exemplo retis externa non indigemus, cum tam transfusor quam accipiens in eodem computatorio collocabuntur - in eo intrabunt fasciculi.

Ad rivum RTP constituendum, media streaming duobus eliquationibus utitur: MS_RTP_SEND et MS_RTP_RECV. Prima transmittit alterum, et recipit RTP rivum. Ut hae columellae ad laborem exerceantur, monstratorem ad RTP sessionis obiectum transmittere oportet, quod vel rivum notitiarum stipitibus in rivum RTP conicere vel contrarium facere potest. Cum interna data forma instrumentorum instrumentorum streaming informativum RTP fasciculi non congruit, antequam notitias ad MS_RTP_SEND transferat, colum ecoder colum quod conversis 16-bit auditionis exemplaribus signo dato in octingentos secundum formam redactis uti necesse est. u-ius (mu-ius). In latere accepto, decoder colum oppositum munus fungitur.

Infra est textus programmatis quod schema quod in figura exhibet (significat # ante signa includere normas remotas, eas includere noli);

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

Compilamus et currimus. Propositum faciet ut in exemplo priore, sed notitia per flumen RTP tradetur.

In proximo articulo hoc propositum in duas applicationes independentes - receptaculum et transmittentem dividemus et in diversis terminationibus deducemus. Simul discemus quomodo RTP analyses facis cum programmate TShark utendo.

Source: www.habr.com