4

我有一个程序在 TCP 端口上侦听特定字符串并使用execlp调用启动应用程序。我正在做一个在这个调用fork()之前启动一个子进程。execlp在此启动后，父进程再次开始在同一端口上侦听。我正在关闭子进程中的套接字。

在绑定套接字之前，我已经编写了一个包装器来boost::asio::tcp_socket设置addr_reuse选项。true

现在我的问题是在 Linux 中，我在应用程序启动几次后收到地址重用错误。在我的程序中，它不断尝试接受连接（或更准确地说，尝试安排接受到boost::asio::io_service）直到绑定然后接受成功。所以我在这个循环中收到错误。

奇怪的是，如果我关闭（或杀死）已启动的可执行文件，此错误将停止出现，这意味着bind成功。我确信在启动的应用程序中没有在任何地方使用相同的端口。我正在使用异步套接字操作。知道为什么我会收到此错误吗？

这是我在套接字上接受的方式：（boost::asio::tcp_socket(_tcpSocket)在开始新的接受之前，我还在共享指针上调用了重置。）

boost::asio::ip::tcp::endpoint endPoint(boost::asio::ip::tcp::v4(), port);
_acceptor.reset ( new boost::asio::ip::tcp::acceptor( *_ioService.get() ) );
_acceptor->open( endPoint.protocol() );
_acceptor->set_option(boost::asio::ip::tcp::acceptor::reuse_address(true));

boost::system::error_code ec;
_acceptor->bind(endPoint, ec);
if ( ec.value() != boost::system::errc::success )
{
    ec.clear();
    _acceptor->close(ec);
    close();
    return false;
}

ec.clear();
_acceptor->listen(boost::asio::socket_base::max_connections, ec);
if ( ec.value() != boost::system::errc::success )
{
    return false;
}
_acceptor->async_accept(*_tcpSocket,
                        boost::bind(&TCPSocket::_handleAsyncAccept,
                                    this,
                                    boost::asio::placeholders::error) );

这是我的分叉方式：

pid_t pid = fork();
switch (pid)
{
    case 0:
    {
        /// close all sockets for child process. as it might cause addr reuse error in parent process
        _asyncNO->closeAll();
        std::string binary = "<binaryName>";
        std::string path = "<binaryPath>";
        if ( execlp( path.c_str(), binary.c_str(), controllerIP.c_str(), (char *)0 ) == -1 )
        {
            LOG_ERROR("System call failed !!")
        }
    }
    break;

    default:
}

为简单起见，我删除了日志记录。

4

1 回答 1

0

正如@TannerSansbury 在评论中所说，这可能是因为 Boost.Asio 需要被通知fork()：

较新版本的关于使用 Boost.Asio 进行分叉的文档。

相关部分转载在这里：

Boost.Asio 支持使用fork()系统调用的程序。如果程序在适当的时间调用io_service.notify_fork()，Boost.Asio 将重新创建任何内部文件描述符（例如用于唤醒反应器的“自管道技巧”描述符）。通知通常如下执行：

io_service_.notify_fork(boost::asio::io_service::fork_prepare);
if (fork() == 0)
{
  io_service_.notify_fork(boost::asio::io_service::fork_child);
  // ...
}
else
{
  io_service_.notify_fork(boost::asio::io_service::fork_parent);
  // ...
}

用户定义的服务也可以通过覆盖io_service::service::fork_service()虚拟功能来实现分叉感知。

请注意，任何可通过 Boost.Asio 的公共 API 访问的文件描述符（例如，底层的描述符basic_socket<>、posix::stream_descriptor等）在分叉期间都不会更改。根据需要管理这些是程序的责任。

于 2015-04-11T02:13:35.450 回答