Ломал голову, почему проект не работает с приемом аудио по RTP. Решил набросать маленький тесковый проект с асинхронной отправкой и приемом. Точнее два: один с отправкой, другой с приемом. Заголовки у них одинаковые:
| C++ |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
| #include "stdafx.h"
#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <boost/format.hpp>
#include <boost/circular_buffer.hpp>
#include <boost/scope_exit.hpp>
#include <boost/scoped_ptr.hpp>
#include <stdio.h>
#include <iostream>
namespace asio = boost::asio;
namespace ip = boost::asio::ip;
using boost::asio::ip::udp;
using namespace boost::asio;
using namespace std;
io_service service;
boost::scoped_ptr<udp::socket> pSocket_2;
char data_2[2048];
int port1 = 29087, port2 = 29187; |
|
Теперь код приемника:
| C++ |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
| void do_recieve1()
{
pSocket_1->async_receive_from(
boost::asio::buffer(data_1, 2048), udp::endpoint(udp::v4(), port2),
[](boost::system::error_code ec, std::size_t bytes_recvd)
{
if (bytes_recvd > 12)// минимальный размер принятого пакета в дальнейшем планируется RTP
{
cout << "\nq" << data_1;
}
});
do_recieve1();
}
//--------------------------------------------------------------
void func(int i)
{
do_recieve1();
}
//--------------------------------------------------------------
void worker_thread()
{
service.run();
}
//--------------------------------------------------------------
int _tmain(int argc, _TCHAR* argv[])
{
cout << "Started\n";
pSocket_1.reset(new udp::socket(service, udp::endpoint(udp::v4(), port1)));
for (int i = 0; i < 1; ++i)
service.post(boost::bind(func, i));
boost::thread_group threads;
for (int i = 0; i < 2; ++i)
threads.create_thread(worker_thread);
cout << "q";
boost::this_thread::sleep(boost::posix_time::millisec(500));
threads.join_all();
system("pause");
return 0;
} |
|
А вот и отправчика:
| C++ |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
| void do_send()
{
pSocket_2->async_send_to(
boost::asio::buffer("qweqweqweqweqweqwe", 2048), udp::endpoint(udp::v4(), port1),
[](boost::system::error_code ec, std::size_t bytes_recvd)
{
cout << "sent\n";
});
do_send();
}
//--------------------------------------------------------------
void func(int i)
{
do_send();
}
//--------------------------------------------------------------
void worker_thread()
{
service.run();
}
//--------------------------------------------------------------
int _tmain(int argc, _TCHAR* argv[])
{
cout << "Started\n";
pSocket_2.reset(new udp::socket(service, udp::endpoint(udp::v4(), port2)));
for (int i = 0; i < 2; ++i)
service.post(boost::bind(func, i));
boost::thread_group threads;
for (int i = 0; i < 2; ++i)
threads.create_thread(worker_thread);
boost::this_thread::sleep(boost::posix_time::millisec(500));
threads.join_all();
system("pause");
return 0;
} |
|
В итоге: отправчик отправляет, приемник принимает пустые пакеты. Где я налажал?
Добавлено через 29 минут
Может, лучше использовать ip::tcp::acceptor acceptor.async_accept?
(
