如何使用getaddrinfo_a与glibc进行异步解析

一个经常被忽视的功能,不需要外部库,但基本上没有任何文档.

更新(2010-10-11):linux手册页现在有getaddrinfo_a的文档,你可以在这里找到它:http://www.kernel.org/doc/man-pages/online/pages/man3/getaddrinfo_a .3.html

作为免责声明,我应该补充一点,我对C很新,但不是一个新手,所以可能有错误或编码错误,请纠正我(我的语法也很糟糕).

在Adam Langley 发表这篇文章之前,我个人并不知道,我将提供一些代码片段来说明它的用法并澄清一些在首次使用时可能不那么清楚的事情.使用它的好处是你可以在socket(),listen()和其他函数中获得可用的数据,如果做得对,你也不必担心ipv4/v6.
所以从基础开始,从上面的链接(你需要链接libanl(-lanl)):
这是函数原型:

int getaddrinfo_a(int mode, struct gaicb *list[], int ent, 
                  struct sigevent *);

该模式是要么GAI_WAIT(这可能不是你想要的)和GAI_NOWAIT用于异步查询

所述gaicb参数接受主机的阵列与所述查找ENT参数指定数组多少个元素具有

该的sigevent将负责告诉函数如何,我们得到通知,更多关于这个瞬间

gaicb结构看起来像这样:

struct gaicb {
    const char *ar_name;
    const char *ar_service;
    const struct addrinfo *ar_request;
    struct addrinfo *ar_result;
};

如果您熟悉getaddrinfo,那么这些字段对应于它们,如下所示:

int getaddrinfo(const char *node, const char *service,
                const struct addrinfo *hints,
                struct addrinfo **res);

节点是ar_name字段,service是端口,hints参数对应于ar_request成员,结果存储在其余成员中.
现在,您可以指定通过sigevent结构通知的方式:

struct sigevent {
    sigval_t sigev_value;
    int sigev_signo;
    int sigev_notify;
    void (*sigev_notify_function) (sigval_t);
    pthread_addr_t *sigev_notify_attributes;
};

您可以通过将_sigev_notify_设置为SIGEV_NONE来忽略该通知

您可以通过将sigev_notify设置为SIGEV_SIGNAL并将sigev_signo设置为所需信号来触发信号.请注意,当使用实时信号(SIGRTMIN - SIGRTMAX,始终通过宏使用它并添加SIGRTMIN +2等)时,您可以传递sigev_value.sival_ptr或sigev_value.sival_int成员respectivley中的指针或值.

您可以通过将sigev_notify设置为SIGEV_NONE来请求新线程中的回调

所以基本上如果你想查找一个主机名,你将ar_name设置为主机并将其他所有内容设置为NULL,如果要连接到设置ar_name和ar_service的主机,并且如果要创建服务器,则指定ar_service和ar_result字段.您当然可以根据自己的心灵内容自定义ar_request成员,查看man getaddrinfo以获取更多信息.

如果你有一个带select/poll/epoll/kqueue的事件循环,你可能想要使用signalfd以方便使用.Signalfd创建一个文件描述符,您可以在其上使用usuall事件轮询机制,如下所示:

#define _GNU_SOURCE //yes this will not be so standardish
#include 
#include 
#include 

void signalfd_setup(void) {
    int sfd;
    sigset_t mask;

    sigemptyset(&mask);
    sigaddset(&mask, SIGRTMIN);
    sigprocmask(SIG_BLOCK, &mask, NULL); //we block the signal
    sfd = signalfd(-1, &mask, 0);
    //add it to the event queue
}
void signalfd_read(int fd) {
    ssize_t s;
    struct signalfd_siginfo fdsi;
    struct gaicb *host;

    while((s = read(fd, &fdsi, sizeof(struct signalfd_siginfo))) > 0){
    if (s != sizeof(struct signalfd_siginfo)) return; //thats bad
    host = fdsi.ssi_ptr; //the pointer passed to the sigevent structure
            //the result is in the host->ar_result member
            create_server(host);
    }
}
void create_server(struct gaicb *host) {
    struct addrinfo *rp, *result;
    int fd;

    result = host->ar_result;
    for(rp = result; rp != NULL; rp = rp->ai_next) {
        fd = socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol);
        bind(fd, rp->ai_addr, rp->ai_addrlen);
        listen(fd, SOMAXCONN);
        //error checks are missing!

        freeaddrinfo(host->ar_request);
        freeaddrinfo(result);
        //you should free everything you put into the gaicb
    }
}
int main(int argc, char *argv[]) {
    struct gaicb *host;
    struct addrinfo *hints;
    struct sigevent sig;

    host = calloc(1, sizeof(struct gaicb));
    hints = calloc(1, sizeof(struct addrinfo));

    hints->ai_family = AF_UNSPEC; //we dont care if its v4 or v6
    hints->ai_socktype = SOCK_STREAM;
    hints->ai_flags = AI_PASSIVE;
    //every other field is NULL-d by calloc

    host->ar_service = "8888"; //the port we will listen on
    host->ar_request = hints;

    sig.sigev_notify = SIGEV_SIGNAL;
    sig.sigev_value.sival_ptr = host;
    sig.sigev_signo = SIGRTMIN;

    getaddrinfo_a(GAI_NOWAIT, &host, 1, &sig);

    signalfd_setup();

    //start your event loop
    return 0;
}

当然,你也可以使用一个简单的信号处理程序来查看这个工作,查看man sigaction以获取更多信息.