c – 从命名管道读取

2023年3月23日 262次阅读

我必须实现“打印服务器”.我有1个客户端文件和1个服务器文件：

#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>

int get_line( char *dest, int size );

#define MAX 1024

void main ()
{
    char const *pipe = "printservers";
    char buffer[MAX];
    int fd;

    get_line( buffer, MAX );

    if( mkfifo( pipe, 0666 ) < 0 )
    {
        printf( "Cannot create a pipe\n" );
        exit( EXIT_FAILURE );
    }

    fd = open( pipe, O_WRONLY );

    write( fd, buffer, MAX );

    close( fd );

    //unlink( pipe );

}

int get_line( char *dest, int size )
{
    int c, i;
    for( i = 0; i < size - 1 && ( c = getchar() ) != EOF && c != '\n'; ++i )
        dest[i] = c;
    if( c == '\n' )
    {
        dest[i] = c;
        ++i;
    }
    dest[i] = '\0';
    return i;
}

这是客户端,它从标准输入读取一行并写入
命名管道称为printservers.这按预期工作.

#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <unistd.h>

#define MAX_BUF 1024
#define MAX_PID 8

int main()
{
    int fd;
    char * myfifo = "printservers";
    char buf[MAX_BUF];

    /* open, read, and display the message from the FIFO */
    fd = open( myfifo, O_RDONLY );
    while( 1 )
    {
        if( read( fd, buf, MAX_BUF ) > 0 )
            printf("Received: %s\n", buf);
    }
    close(fd);

    return 0;
}

这是服务器,从管道中读取.但它不适用于while循环.如果我从客户端发送消息,则会打印第一条消息,但会忽略以下消息.
有人可以帮我解决我的问题吗？
谢谢
帕特里克

最佳答案 服务器的while循环中存在编码错误 – 即使出现错误或服务器在FIFO上接收到eof,服务器也永远不会退出循环.它应该改为这样的东西：

while(1)
{
    if((bytesread = read( fd, buf, MAX_BUF - 1)) > 0)
    {
        buf[bytesread] = '\0';
        printf("Received: %s\n", buf);
    }
    else
        break;
}

您的另一个问题是您的客户端发送一行然后关闭FIFO.服务器读取直到EOF.所以它将读取单行,然后点击EOF,因为客户端关闭.这是完全正常的.

当您希望服务器为多个客户端提供服务时,问题就出现了.在这种情况下,您不希望在每个客户端关闭其结束后退出读取.语义是这样的,服务器只会在最后一个客户端关闭后才会看到EOF.因此,容纳服务器处理多个客户端的简单方法是将服务器端FIFO打开为读/写.然后总会有一个“编写器”,服务器本身,FIFO的写入结束打开.这将阻止服务器在您决定将其关闭之前看到EOF.

第二个问题是你需要在循环中读写.您无法保证在一次通话中填写完整的数据请求.

此外,让客户端创建服务器读取的FIFO是一种奇怪的方法.通常,您希望服务器创建客户端连接的已知FIFO.

点赞