Awọn ohun elo ti awọn article ti wa ni ya lati mi .
Lilo TShark lati ṣe itupalẹ awọn apo-iwe RTP
Ni ikẹhin A ṣe apejọ iṣakoso isakoṣo latọna jijin lati olupilẹṣẹ ohun orin ati aṣawari ohun orin, ibaraẹnisọrọ laarin eyiti a ṣe nipasẹ lilo ṣiṣan RTP kan.
Ninu nkan yii, a tẹsiwaju lati ṣe iwadi gbigbe ifihan agbara ohun ni lilo ilana RTP. Ni akọkọ, jẹ ki a pin ohun elo idanwo wa si atagba ati olugba kan ki o kọ ẹkọ bii o ṣe le ṣayẹwo ṣiṣan RTP nipa lilo olutupalẹ ijabọ nẹtiwọọki kan.
Nitorinaa, ki a le rii ni kedere diẹ sii awọn eroja eto wo ni o ni iduro fun gbigbe RTP ati eyiti o jẹ iduro fun gbigba, a pin faili mstest6.c wa si awọn eto ominira meji fun atagba ati olugba; a yoo fi awọn iṣẹ ti o wọpọ ti awọn mejeeji lo. ninu faili kẹta, eyiti a yoo pe mstest_common.c, yoo sopọ nipasẹ atagba ati olugba nipa lilo itọsọna pẹlu:
/* Файл mstest_common.c Общие функции для передатчика и приемника. */
#include <mediastreamer2/msfilter.h>
#include <mediastreamer2/msticker.h>
#include <mediastreamer2/msrtp.h>
#include <ortp/rtpsession.h>
#include <ortp/payloadtype.h>
define PCMU 0
/*---------------------------------------------------------*/
/* Функция регистрации типов полезных нагрузок. */
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;
}
Bayi faili atagba lọtọ:
/* Файл mstest6.c Имитатор пульта управления (передатчика). */
#include <mediastreamer2/dtmfgen.h>
#include <mediastreamer2/msrtp.h>
#include "mstest_common.c"
/*----------------------------------------------------------*/
int main()
{
ms_init();
/* Создаем экземпляры фильтров. */
MSFilter *voidsource = ms_filter_new(MS_VOID_SOURCE_ID);
MSFilter *dtmfgen = ms_filter_new(MS_DTMF_GEN_ID);
/* Создаем фильтр кодера. */
MSFilter *encoder = ms_filter_create_encoder("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);
/* Создаем источник тактов - тикер. */
MSTicker *ticker_tx = ms_ticker_new();
/* Соединяем фильтры передатчика. */
ms_filter_link(voidsource, 0, dtmfgen, 0);
ms_filter_link(dtmfgen, 0, encoder, 0);
ms_filter_link(encoder, 0, rtpsend, 0);
/* Подключаем источник тактов. */
ms_ticker_attach(ticker_tx, voidsource);
/* Настраиваем структуру, управляющую выходным сигналом генератора. */
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);
}
}Ati nikẹhin, faili olugba:
/* Файл mstest7.c Имитатор приемника. */
include <mediastreamer2/mssndcard.h>
include <mediastreamer2/mstonedetector.h>
include <mediastreamer2/msrtp.h>
/* Подключаем заголовочный файл с функциями управления событиями медиастримера.*/
include <mediastreamer2/mseventqueue.h>
/* Подключаем файл общих функций. */
include "mstest_common.c"
/* Функция обратного вызова, она будет вызвана фильтром, как только он обнаружит совпадение характеристик входного сигнала с заданными. */
static void tone_detected_cb(void *data, MSFilter *f, unsigned int event_id,MSToneDetectorEvent *ev)
{
printf("Принята команда: %sn", ev->tone_name);
}
/*----------------------------------------------------------*/
int main()
{
ms_init();
/* Создаем экземпляры фильтров. */
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 *decoder=ms_filter_create_decoder("PCMU");
/* Регистрируем типы нагрузки. */
register_payloads();
/* Создаем 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_rx = ms_ticker_new();
/* Соединяем фильтры приёмника. */
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_rx, rtprecv);
char key='9';
printf( "Для завершения программы введите 0.n");
while(key != '0')
{
key = getchar();
/* Укладываем тред в спячку на 20мс, чтобы другие треды * приложения получили время на работу. */
ms_usleep(20000);
}
}
A ṣe akopọ atagba ati olugba, lẹhinna ṣe ifilọlẹ ọkọọkan ni console tirẹ. Lẹhinna o yẹ ki o ṣiṣẹ bi iṣaaju - nikan a yẹ ki o tẹ awọn nọmba sii lati 1 si 6 ninu console atagba, ati idahun si wọn yẹ ki o han ninu console olugba. Awọn ohun orin yẹ ki o gbọ ni agbọrọsọ. Ti ohun gbogbo ba jẹ bẹ, lẹhinna a ti fi idi asopọ kan mulẹ laarin olugba ati atagba - gbigbe lemọlemọfún ti awọn apo-iwe RTP wa lati atagba si olugba.
Bayi ni akoko lati fi sori ẹrọ olutupalẹ ijabọ; fun eyi a yoo fi ẹya console sori ẹrọ ti eto Wireshark ti o dara julọ - o pe ni TShark. Mo ti yan TShark fun siwaju fanfa ni ibere lati dẹrọ awọn apejuwe ti isakoso eto. Pẹlu Wireshark, Emi yoo nilo okun ti awọn sikirinisoti, eyiti o le di igba atijọ nigbati ẹya tuntun ti Wireshark ti tu silẹ.
Ti o ba mọ bi o ṣe le lo Wireshark, o le lo lati ṣe iwadi awọn apẹẹrẹ wa. Ṣugbọn paapaa ninu ọran yii, Mo ṣeduro pe ki o Titunto si TShark, nitori yoo ṣe iranlọwọ fun ọ lati ṣe adaṣe adaṣe ti awọn ohun elo VoIP rẹ, ati ṣe imudani latọna jijin.
Fi TShark sori ẹrọ pẹlu aṣẹ:
$ sudo apt-get install tsharkNi aṣa, a ṣayẹwo abajade fifi sori ẹrọ nipa bibeere fun ẹya eto naa:
$ tshark --versionTi o ba gba idahun to peye, a tẹsiwaju siwaju.
Niwọn igba ti awọn apo-iwe wa nikan lọ sinu kọnputa fun bayi, a le sọ fun tshark lati ṣafihan awọn apo-iwe bẹ nikan. Lati ṣe eyi, o nilo lati yan idii apo-iwe lati inu wiwo loopback (loopback) nipa gbigbe TShark aṣayan -ilo:
$ sudo tshark -i loAwọn ifiranṣẹ nipa awọn apo-iwe ti a firanṣẹ nipasẹ atagba wa yoo bẹrẹ lẹsẹkẹsẹ lati tú sinu console (tẹsiwaju, laibikita boya a tẹ bọtini naa lori isakoṣo latọna jijin tabi rara). Boya awọn eto wa lori kọnputa rẹ ti o tun fi awọn apo-iwe ranṣẹ nipasẹ lupu agbegbe, ninu eyiti a yoo gba adalu tiwa ati awọn apo-iwe ti awọn eniyan miiran. Lati rii daju pe ninu atokọ ti a rii nikan awọn apo-iwe ti a firanṣẹ nipasẹ iṣakoso latọna jijin wa, a yoo ṣafikun àlẹmọ nipasẹ nọmba ibudo. Nipa titẹ Ctrl-C a da olutupalẹ duro ki o tẹ àlẹmọ kan fun nọmba ibudo ti iṣakoso latọna jijin nlo bi ibudo opin irin ajo fun gbigbe rẹ (8010): -f "udp ibudo 8010". Bayi laini aṣẹ wa yoo dabi eyi:
$ sudo tshark -i lo -f "udp port 8010"Ijade atẹle yoo han ninu console (awọn laini 10 akọkọ):
1 0.000000000 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
2 0.020059705 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
3 0.040044409 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
4 0.060057104 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
5 0.080082311 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
6 0.100597153 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
7 0.120122668 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
8 0.140204789 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
9 0.160719008 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172
10 0.180673685 127.0.0.1 → 127.0.0.1 UDP 214 8010 → 7010 Len=172Fun bayi, iwọnyi kii ṣe awọn apo-iwe, ṣugbọn atokọ nọmba ti awọn iṣẹlẹ, nibiti laini kọọkan jẹ ifiranṣẹ kan nipa soso atẹle ti a ṣe akiyesi lori wiwo. Niwọn bi a ti ṣe itọju ti sisẹ apo-iwe, a rii ninu atokọ awọn ifiranṣẹ nikan nipa awọn apo-iwe lati atagba wa. Nigbamii, jẹ ki a ṣe ipinnu tabili yii nipasẹ awọn nọmba ọwọn:
Nọmba iṣẹlẹ.
Awọn akoko ti awọn oniwe-iṣẹlẹ.
Adirẹsi IP orisun ti apo ati adiresi IP opin irin ajo naa.
Ilana ti apo-iwe naa han bi UDP nitori pe awọn apo-iwe RTP ni a firanṣẹ bi isanwo inu awọn apo-iwe UDP.
Packet iwọn ni awọn baiti.
Nọmba ibudo orisun ti apo ati nọmba ibudo opin irin ajo apo.
Iwọn ti ẹru isanwo, lati ibi a le pinnu pe atagba wa n ṣe awọn apo-iwe RTP ti awọn baiti 172 ni iwọn, eyiti, bi pepeye kan ninu àyà, wa ninu apo UDP kan ti awọn baiti 214 ni iwọn.
Bayi o to akoko lati wo inu awọn apo-iwe UDP, fun eyi a yoo ṣe ifilọlẹ TShark pẹlu awọn bọtini ti o gbooro sii:
sudo tshark -i lo -f "udp port 8010" -P -V -O rtp -o rtp.heuristic_rtp:TRUE -xBi abajade, iṣelọpọ eto yoo jẹ idarato - decryption ti awọn akoonu inu ti package ti o fa yoo ṣafikun si iṣẹlẹ kọọkan. Lati wo abajade ti o dara julọ, o le da TShark duro nipa titẹ Ctrl-C, tabi ṣe pidánpidán iṣelọpọ rẹ si faili kan nipa fifi opo gigun kan kun si eto tee si aṣẹ ṣiṣe, pato orukọ faili, tee :
$ sudo tshark -i lo -f "udp port 8010" -P -V -O rtp -o rtp.heuristic_rtp:TRUE -x | tee log.txtBayi jẹ ki a wo ohun ti a ni ninu faili naa, eyi ni package akọkọ lati ọdọ rẹ:
1 0.000000000 127.0.0.1 → 127.0.0.1 RTP 214 PT=ITU-T G.711 PCMU, SSRC=0x6B8B4567, Seq=58366, Time=355368720
Frame 1: 214 bytes on wire (1712 bits), 214 bytes captured (1712 bits) on interface 0
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1, Dst: 127.0.0.1User Datagram Protocol, Src Port: 8010, Dst Port: 7010
Real-Time Transport Protocol [Stream setup by HEUR RT (frame 1)]
[Setup frame: 1]
[Setup Method: HEUR RT]
10.. .... = Version: RFC 1889 Version (2)
..0. .... = Padding: False
...0 .... = Extension: False
.... 0000 = Contributing source identifiers count: 0
0... .... = Marker: False
Payload type: ITU-T G.711 PCMU (0)
Sequence number: 58366 [Extended sequence number: 58366]
Timestamp: 355368720
Synchronization Source identifier: 0x6b8b4567 (1804289383)
Payload: ffffffffffffffffffffffffffffffffffffffffffffffff...
0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 ..............E.
0010 00 c8 3c 69 40 00 40 11 ff b9 7f 00 00 01 7f 00 ..<i@.@.........
0020 00 01 1f 4a 1b 62 00 b4 fe c7 80 00 e3 fe 15 2e ...J.b..........
0030 7f 10 6b 8b 45 67 ff ff ff ff ff ff ff ff ff ff ..k.Eg..........
0040 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
0050 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
0060 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
0070 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
0080 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
0090 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
00a0 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
00b0 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
00c0 ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ff ................
00d0 ff ff ff ff ff ff ......A yoo yasọtọ nkan ti o tẹle lati ṣe itupalẹ alaye ti o wa ninu atokọ yii ati pe yoo ṣee ṣe lati sọrọ nipa eto inu ti package RTP.
orisun: www.habr.com