gpt4 book ai didi

c++ - 使用 Boost Asio 接受 IPv6 链接范围地址

转载 作者:塔克拉玛干 更新时间:2023-11-03 00:31:08 27 4
gpt4 key购买 nike

我有一个使用 Boost ASIO 的 TCP 服务器。我注意到,在 Linux 上使用链接作用域的 IPv6 地址时,我无法在不引发异常的情况下创建 boost::asio::ip::tcp::acceptor。使用全局 IPv6 地址或 IPv4 地址都可以正常工作。

我很确定问题出在范围 ID 设置不正确,但我不知道如何解决这个问题。

我正在使用 ubuntu 提供的 boost 1.40.0 库在 Ubuntu 11.04 LTS 上进行开发。这是我的服务器代码的一个非常简单的版本,它显示了问题:

#include <boost/asio.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/bind.hpp>
#include <iostream>
#include <string>

/* To Compile:
g++ -Wall -o ./asio-ipv6 ./asio-ipv6.cpp -lboost_system
*/

typedef boost::shared_ptr<boost::asio::ip::tcp::socket> TcpSocketPtr;
typedef boost::shared_ptr<boost::asio::ip::tcp::acceptor> TcpAcceptorPtr;
typedef boost::shared_ptr<boost::asio::ip::tcp::endpoint> TcpEndpointPtr;

class AsioServer{
public:
AsioServer(boost::asio::io_service& io): io_(io){};

//throws
void accept(const std::string& ipString,unsigned short port){
boost::asio::ip::address addr = boost::asio::ip::address::from_string(ipString);
std::cout << "Valid IP address " << ipString << std::endl;

this->endpoint_.reset(new boost::asio::ip::tcp::endpoint(addr,port));
std::cout << "Created endpoint" << std::endl;

//Will throw if a link local IPv6 address is used
acceptor_.reset(new boost::asio::ip::tcp::acceptor(this->io_,*(this->endpoint_)));

std::cout << "About to accept on " << *(this->endpoint_) << std::endl;
this->socket_.reset(new boost::asio::ip::tcp::socket(this->io_));
this->acceptor_->async_accept(*socket_ ,boost::bind(&AsioServer::handle_accept,this,boost::asio::placeholders::error));
}

private:
boost::asio::io_service& io_;
TcpSocketPtr socket_;
TcpAcceptorPtr acceptor_;
TcpEndpointPtr endpoint_;

void handle_accept(const boost::system::error_code &ec){
if(!ec){
std::cout << "Accepted connection!" << std::endl;
}
else{
std::cout << "Error accepting connection" << std::endl;
}
};

};

int main(int argc, char* argv[]){

boost::asio::io_service io;

std::string ipString("0.0.0.0");
if(argc > 1){
ipString.assign(argv[1]);
}
std::cout << "IP Set to " << ipString << std::endl;

AsioServer server(io);

try{
server.accept(ipString,4444);
}
catch(const std::exception& e){
std::cout << "Error caught: " << e.what() << std::endl;
}

io.run();

std::cout << "Done!" << std::endl;

return 0;
}

在这台机器上,我为 eth0 配置了以下内容:

$ ifconfig eth0
eth0 Link encap:Ethernet HWaddr 00:0c:29:10:cf:0e
inet addr:192.168.97.162 Bcast:192.168.97.255 Mask:255.255.255.0
inet6 addr: 2620:1c:8000:190:20c:29ff:fe10:cf0e/64 Scope:Global
inet6 addr: fe80::20c:29ff:fe10:cf0e/64 Scope:Link
UP BROADCAST RUNNING MULTICAST MTU:1500 Metric:1
RX packets:112470185 errors:2 dropped:1 overruns:0 frame:0
TX packets:5900249 errors:0 dropped:0 overruns:0 carrier:0
collisions:0 txqueuelen:1000
RX bytes:2187237130 (2.1 GB) TX bytes:1640094885 (1.6 GB)
Interrupt:19 Base address:0x2000

使用192.168.97.1620.0.0.0127.0.0.1::1运行程序或 2620:1c:8000:190:20c:29ff:fe10:cf0e 工作正常但使用 fe80::20c:29ff:fe10:cf0e 无法创建接受器抛出“无效参数”异常。

$ ./asio-ipv6 fe80::20c:29ff:fe10:cf0e
IP Set to fe80::20c:29ff:fe10:cf0e
Valid IP address fe80::20c:29ff:fe10:cf0e
Created endpoint
Error caught: Invalid argument
Done!

这让我想起了使用 ping6 并看到相同的“无效参数”错误。解决方法是传递附加到 IPv6 地址的接口(interface)。

$ ping6 fe80::219:b9ff:fe2b:3a53  #Won't work
connect: Invalid argument
$ ping6 fe80::219:b9ff:fe2b:3a53%eth0 #Pass the interface to use to ping6
PING fe80::219:b9ff:fe2b:3a53%eth0(fe80::219:b9ff:fe2b:3a53) 56 data bytes

当我尝试从字符串创建 IP 地址时,这似乎不适用于 Boost Asio。

$ ./asio-ipv6 fe80::20c:29ff:fe10:cf0e%eth0
IP Set to fe80::20c:29ff:fe10:cf0e%eth0
Error caught: Invalid argument
Done!

我的问题是您如何使用 Boost ASIO 监听链接范围的 IPv6 地址? boost::asio::ip::address_v6 类有一个 scope_id() member function但我不确定从哪里获取 scope id 作为 unsigned long 或者这是否是问题所在。

最佳答案

这可以使用 boost::asio::ip::tcp::resolver

来完成
--- ipv6.cc.orig        2012-04-24 12:03:02.349911481 -0500
+++ ipv6.cc 2012-04-24 12:02:07.053037095 -0500
@@ -10,42 +10,67 @@

typedef boost::shared_ptr<boost::asio::ip::tcp::socket> TcpSocketPtr;
typedef boost::shared_ptr<boost::asio::ip::tcp::acceptor> TcpAcceptorPtr;
+typedef boost::shared_ptr<boost::asio::ip::tcp::resolver> TcpResolverPtr;
typedef boost::shared_ptr<boost::asio::ip::tcp::endpoint> TcpEndpointPtr;

class AsioServer{
public:
AsioServer(boost::asio::io_service& io): io_(io){};

- //throws
- void accept(const std::string& ipString,unsigned short port){
- boost::asio::ip::address addr = boost::asio::ip::address::from_string(ipString);
- std::cout << "Valid IP address " << ipString << std::endl;
-
- this->endpoint_.reset(new boost::asio::ip::tcp::endpoint(addr,port));
- std::cout << "Created endpoint" << std::endl;
-
- //Will throw if a link local IPv6 address is used
- acceptor_.reset(new boost::asio::ip::tcp::acceptor(this->io_,*(this->endpoint_)));
-
- std::cout << "About to accept on " << *(this->endpoint_) << std::endl;
- this->socket_.reset(new boost::asio::ip::tcp::socket(this->io_));
- this->acceptor_->async_accept(*socket_ ,boost::bind(&AsioServer::handle_accept,this,boost::asio::placeholders::error));
+ void resolve(const std::string& ipString, const std::string& service){
+ this->resolver_.reset(new boost::asio::ip::tcp::resolver(io_));
+ boost::asio::ip::tcp::resolver::query query( ipString, service );
+ this->resolver_->async_resolve( query, boost::bind( &AsioServer::handle_resolve, this, boost::asio::placeholders::error, boost::asio::placeholders::iterator ) );
}
-
private:
boost::asio::io_service& io_;
TcpSocketPtr socket_;
TcpAcceptorPtr acceptor_;
TcpEndpointPtr endpoint_;
+ TcpResolverPtr resolver_;
+
+ void accept(const boost::asio::ip::tcp::resolver::iterator iterator) {
+ endpoint_.reset(new boost::asio::ip::tcp::endpoint(iterator->endpoint()));
+ //Will throw if a link local IPv6 address is used
+ acceptor_.reset(new boost::asio::ip::tcp::acceptor(this->io_));
+ acceptor_->open(this->endpoint_->protocol());
+ acceptor_->bind(*(this->endpoint_));
+ acceptor_->listen();
+
+
+ std::cout << "About to accept on " << *(this->endpoint_) << std::endl;
+ socket_.reset(new boost::asio::ip::tcp::socket(this->io_));
+ acceptor_->async_accept(*socket_ ,boost::bind(&AsioServer::handle_accept,this,boost::asio::placeholders::error));
+ }
+

void handle_accept(const boost::system::error_code &ec){
if(!ec){
std::cout << "Accepted connection!" << std::endl;
}
else{
- std::cout << "Error accepting connection" << std::endl;
+ std::cout << "Error accepting connection: " << boost::system::system_error(ec).what() << std::endl;
+ }
+ }
+
+ void handle_resolve(
+ const boost::system::error_code& ec,
+ boost::asio::ip::tcp::resolver::iterator iterator
+ )
+ {
+ if(ec) {
+ std::cerr << "could not resolve: " << boost::system::system_error(ec).what() << std::endl;
+ return;
}
- };
+
+ if ( iterator == boost::asio::ip::tcp::resolver::iterator() ) {
+ std::cerr << "no endpoints resolved" << std::endl;
+ return;
+ }
+
+ this->accept(iterator);
+
+ }

};

@@ -62,7 +87,7 @@
AsioServer server(io);

try{
- server.accept(ipString,4444);
+ server.resolve(ipString,"4444");
}
catch(const std::exception& e){
std::cout << "Error caught: " << e.what() << std::endl;

示例 session

[samm@t410 Desktop]$ ifconfig | grep fe80
inet6 addr: fe80::5a94:6bff:fe7c:e760/64 Scope:Link
[samm@t410 Desktop]$ g++ -g ipv6.cc -lboost_system -lboost_thread-mt
[samm@t410 Desktop]$ ./a.out fe80::5a94:6bff:fe7c:e760%wlan0
IP Set to fe80::5a94:6bff:fe7c:e760%wlan0
About to accept on [fe80::5a94:6bff:fe7c:e760%wlan0]:4444
^C
[samm@t410 Desktop]$

关于c++ - 使用 Boost Asio 接受 IPv6 链接范围地址,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10286042/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com