6

我本来打算在我的程序中有一个线程，它将等待两个文件描述符，一个用于套接字，另一个用于描述文件系统的 FD（特别是等待查看是否将新文件添加到目录中）。由于我希望很少看到添加的新文件或传入的新 TCP 消息，因此我希望有一个线程等待任一输入并在发生时处理检测到的任何输入，而不是打扰单独的线程。

然后，我（终于！）获得了“老板”的许可，可以使用 boost。所以现在我想用 boost:asio 替换基本的套接字。只有我遇到了一个小问题。似乎 asio 隐含了它自己的 select 版本，而不是提供我可以直接与 select 一起使用的 FD。这让我不确定如何在新文件和 TCP 输入这两种情况下阻塞，同时一个只适用于 select 而另一个似乎不支持使用 select。有一个简单的解决方法来解决我想念的问题吗？

4

1 回答 1

8

ASIO 最好异步使用（这就是它的含义）：您可以为 TCP 读取和文件描述符活动设置处理程序，并且将为您调用处理程序。

这是一个让您入门的演示示例（为支持 inotify 的 Linux 编写）：

#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <sys/inotify.h>

namespace asio = boost::asio;
void start_notify_handler();
void start_accept_handler();

// this stuff goes into your class, only global for the simplistic demo
asio::streambuf buf(1024);
asio::io_service io_svc;
asio::posix::stream_descriptor stream_desc(io_svc);
asio::ip::tcp::socket sock(io_svc);
asio::ip::tcp::endpoint end(asio::ip::tcp::v4(), 1234);
asio::ip::tcp::acceptor acceptor(io_svc, end);

// this gets called on file system activity
void notify_handler(const boost::system::error_code&,
                    std::size_t transferred)
{
    size_t processed = 0;
    while(transferred - processed >= sizeof(inotify_event))
    {
        const char* cdata = processed
                            + asio::buffer_cast<const char*>(buf.data());
        const inotify_event* ievent =
                                 reinterpret_cast<const inotify_event*>(cdata);
        processed += sizeof(inotify_event) + ievent->len;
        if(ievent->len > 0 && ievent->mask & IN_OPEN)
            std::cout << "Someone opened " << ievent->name << '\n';
    }
    start_notify_handler();
}

// this gets called when nsomeone connects to you on TCP port 1234
void accept_handler(const boost::system::error_code&)
{
    std::cout << "Someone connected from " 
              << sock.remote_endpoint().address() << '\n';
    sock.close(); // dropping connection: this is just a demo
    start_accept_handler();
}

void start_notify_handler()
{
    stream_desc.async_read_some( buf.prepare(buf.max_size()),
        boost::bind(&notify_handler, asio::placeholders::error,
                    asio::placeholders::bytes_transferred));
}

void start_accept_handler()
{
    acceptor.async_accept(sock,
        boost::bind(&accept_handler, asio::placeholders::error));
}

int main()
{
    int raw_fd = inotify_init(); // error handling ignored
    stream_desc.assign(raw_fd);
    inotify_add_watch(raw_fd, ".", IN_OPEN);
    start_notify_handler();
    start_accept_handler();
    io_svc.run();
}
于 2012-09-05T03:45:13.387 回答