如何在此代码C中使用管道？

发布时间：2020-12-16 06:57:51 所属栏目：百科来源：网络整理

导读：我遇到了大麻烦,因为我不知道如何做到这一点. 我只需要创建两个可以通信的进程. 这是代码： /* Wrappers */this-sock_fd = this-w_socket();this-w_bind();this-w_listen();std::cout "[info] Server is running..." std::endl;while(1){ /*Connection stuff

我遇到了大麻烦,因为我不知道如何做到这一点.
我只需要创建两个可以通信的进程.
这是代码：

/* Wrappers */
this->sock_fd = this->w_socket();
this->w_bind();
this->w_listen();

std::cout << "[info] Server is running..." << std::endl;

while(1)
{
    /*Connection stuff */
    struct sockaddr_in client_addr;
    int client_fd = this->w_accept(&client_addr);
    char client_ip[64];
    int client_port = ntohs(client_addr.sin_port);
    inet_ntop(AF_INET,&client_addr.sin_addr,client_ip,sizeof(client_ip));
    std::cout << "[info] Connection from (" << client_ip
        << "," << client_port << ")" << std::endl;

    /*Login manager*/
    ...

    /* Crate PID */
    int pid = fork();
    if (pid == 0)
    {
        close(this->sock_fd);
        this->manage(client_fd,client_port);
        exit(0);
    }   
    /* End connection */
    close(client_fd);
}

好.在登录管理器成功验证客户端后,可以将数据发送到服务器.
如果客户端已连接且另一个客户端已登录,则第二个客户端必须向第一个客户端发送消息“您已断开连接”.
我怎样才能用叉子和管子做到这一点？
我试着读一些关于此事的内容,但我对此感到有点困惑.

谢谢.

解决方法

我不确定你的项目的具体设计,但如果你使用fork()从现有的客户端创建一个新的客户端,并且你想使用pipe()进行通信,这里是一个示例代码.

int pfds[2];         //pipe() always return pair of file descriptors(fds).
char buf[30];

pipe(pfds);         //fds will be stored in pfds.

if (!fork()) {
    printf(" CHILD CLIENT: writing to pipen");
    write(pfds[1],"New Client",11);
    printf(" CHILD CLIENT: exitingn");
    exit(0);
} else {
    printf("PARENT CLIENT: reading from pipen");
    read(pfds[0],buf,11);
    printf("PARENT CLIENT: read "%s"n",buf);
    //Take appropriate Action upon read!!!
    wait(NULL);
}

我个人认为有比使用管道更好的选择(信号或共享内存).

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!