我在具有多个网络接口的主机之间使用多播UDP.我正在使用boost :: asio,并且被接收器必须进行的2个操作混淆:bind,然后是join-group.
当您对加入的每个组播组执行此操作时,为什么需要在绑定期间指定接口的本地地址?
姐妹问题是关于多播端口:因为在发送期间,您发送到多播地址和端口,为什么在订阅多播组期间,您只需指定地址,而不是端口 - 在混乱的呼叫中指定的端口绑定.
注意:"join-group"是一个包装器setsockopt(IP_ADD_MEMBERSHIP),如文档所示,可以在同一个套接字上多次调用以订阅不同的组(通过不同的网络?).因此,每次订阅组时,抛弃绑定调用并指定端口是完全合理的.
从我所看到的,总是绑定到"0.0.0.0"并在加入组时指定接口地址,效果非常好.困惑.
以下代码"No such device"在尝试加入多播组(set_option调用)时抛出异常.
#include <boost/asio.hpp>
int main(){
const std::string recv_addr = "232.4.130.147";
const int recv_port = 31338;
boost::asio::io_service io_service;
boost::asio::ip::udp::endpoint recv_endpoint(
boost::asio::ip::address::from_string(recv_addr),
recv_port);
boost::asio::ip::udp::socket recv_sock(io_service, recv_endpoint);
recv_sock.set_option(
boost::asio::ip::multicast::join_group(
boost::asio::ip::address::from_string(recv_addr).to_v4()
));
}
Run Code Online (Sandbox Code Playgroud)
无论网络管理器是否正在运行,都会发生这种情况.并且不考虑IP地址集.
当我连接到手动设置IP地址的内部网络时出现问题.在从DHCP获得IP的另一个网络上,我发现没有问题.
我一直有eth0接口,这是唯一有效的非本地接口.
我已经尝试过如此处所示的 listen接口,但是我得到了一个例外"Invalid argument",而Boost.Asio文档并没有说任何关于设置接口的内容.
我有一个这样的听众:
receiver r(io_service,
boost::asio::ip::address::from_string(argv[1]),
boost::asio::ip::address::from_string(argv[2]));
Run Code Online (Sandbox Code Playgroud)
如果我使用参数运行代码
./BoostAsioMCReceiver 0.0.0.0 239.255.0.1
Run Code Online (Sandbox Code Playgroud)
侦听器从发送者(在另一台计算机上)获取所有多播数据包。但是,如果我实际上输入机器的以太网IP地址,例如
./BoostAsioMCReceiver 172.22.1.5 239.255.0.1
Run Code Online (Sandbox Code Playgroud)
接收方似乎没有收到任何数据包。我需要这样做是因为计算机有多个以太网卡,并且我需要确保数据包从给定的 NIC 发出,并通过扩展到达正确的交换机。
接收器看起来像这样:
receiver(boost::asio::io_service& io_service,
const boost::asio::ip::address& listen_address,
const boost::asio::ip::address& multicast_address)
: socket_(io_service)
{
boost::asio::ip::udp::endpoint listen_endpoint(
listen_address, multicast_port);
socket_.open(listen_endpoint.protocol());
socket_.set_option(boost::asio::ip::udp::socket::reuse_address(true));
socket_.bind(listen_endpoint);
socket_.set_option(
boost::asio::ip::multicast::join_group(multicast_address));
socket_.async_receive_from(
boost::asio::buffer(data, max_length), sender_endpoint,
boost::bind(&receiver::handle_receive_from, this,
boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
}
private:
boost::asio::ip::udp::socket socket;
boost::asio::ip::udp::endpoint sender_endpoint;
Run Code Online (Sandbox Code Playgroud)
为什么会发生这种情况?建议的修复方法是什么?
谢谢。