Joinc Wiki: FIFO 활용

Facebook Joinc 그룹 Joinc QA 사이트

joinc는 Firefox와 chrome에서 테스트 했습니다. IE에서는 테이블이 깨지거나 이미지가 보이지 않을 수 있습니다. 특히 구글 Docs이미지의 경우 엑박처리될 수 있습니다.

FIFO

pipe 에 대한 내용은 Pipe의 사용과 System V IPC 에 대해서를 참조하기 바란다.

FIFO는 PIPE와달리 명명된(이름이 있는) 파일을 통하여 통신이 이루어지게 되므로, 서로다른 세션에 있는 프로세스라도 관계없이 통신을 할수가 있으며, 다중의 클라이언트를 받아들이기 위한 서버모델을 만들수있다. 그러나 Unix Domain 소켓과는 달리, 단일의 파일지시자를 통해서 연결이 되므로, select 등을 통하여 다중의 클라이언트중 원하는 클라이언트에 선별적으로 통신할수 있는 진정한 다중 서버/클라이언트 모델을 구성하는건 쉽지가 않다. 이럴경우는 Unix Domain 소켓과 같은 다른 방법을 찾아봐야 할듯하다.

어쨋든 단지 다중의 클라이언트로 부터 메시지를 받아서 처리하는 것으로 끝나는 경우에는 (READ ONLY), 매우 간단하게 이러한 모델을 구현할수 있음으로 사용하기에 매우 편할것이다. 하나의 서버와 하나의 클라이언트로 구성되어 있고, 이들이 서로 메시지를 주고 받는 서비스를 만들경우에도, 비록 FIFO 가 읽기/쓰기를 지원하지만, 제대로된 작동을 보장받기 위해서는 읽기전용의 FIFO와 쓰기전용의 FIFO를 열어야 할것이다.

FIFO 파일의 생성은 mkfifo(3)를 사용하는데, 다음은 실제 FIFO 파일을 만들어내는 간단한 예제이다.

예제 : fifo.c

#include <sys/types.h> 
#include <sys/stat.h> 

int main(int argc, char **argv)
{
    if (mkfifo(argv[1], 0666) != 0)
    {
        perror("mkfifo failure : ");
    }

    return 0;
}

위의 프로그램을 컴파일한후 실행하면 fifo 파일이 만들어지는데, 이를 ls -al 록 확인해보면 아래와 같이 파일의 특성을 확인해볼수 있다.

[root@localhost test]# ./fifo /tmp/testfifo2
[root@localhost test]# ls -al /tmp/testfifo2
prw-r--r--    1 root     root            0  2월  7 16:26 /tmp/testfifo2

만들어진 fifo 파일의 크기는 해당 파일에 대한 입력이 있더라 하더라도 그 크기는 언제나 0인데 이유는 입력이 파일로 쌓이지 않고, 커널에서 이를 처리하기 때문 이다. 만들어진 fifo 파일은 PIPE 와 달리, 프로세스가 종료하거나, 시스템을 리부팅 시키더라도 사라지지 않으며(파일이니 당연하다), 직접 지워줄때까지 살아있게 된다. 리눅스에서는 FIFO를 만들도록 도와주는 mkfifo(2)라는 프로그램도 있으므로, FIFO 파일을 만들기 위해서 굳이 위의 예제처럼 fifo.c 파일을 만들필요는 없을 것이다.

만들어진 FIFO 파일로의 읽기및 쓰기는 보통의 파일을 위해서 사용하는 open(2)과 fopen(3) 등 일반적인 파일 열기/엑세스 함수군을 사용하면 된다.

예제 : testfifo.c

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

int main()
{
    FILE *fp;

    char buf[255];
    if((fp = fopen("/tmp/testfifo", "rw")) == NULL)
    {
        perror("open error : ");
        exit(0);
    }


    memset(buf, 0x00, 255);
    while(1)
    {
        while(fgets(buf, 255, fp) != NULL)
        {
            printf("%s", buf);
            memset(buf, 0x00, 255);
        }
    }
}

FIFO 를 위한 명명된 파일이름은 "/tmp/testfifo" 로 정했다.
위의 프로그램을 컴파일한다음에 실행시키면, read 에서 블록되는데, 이때 /tmp/testfifo 로 표준출력 시키면 해당 메시지를 read 해서 화면에 출력시켜 줄것이다. echo 를 통해서 간단하게 테스트를 해보자

[yundream@localhost /tmp]# echo "hello world" > testfifo

이번에는 좀더 복잡한 프로그램을 만들어 보도록 하자.
위의 예제는 단지 서버측에서 받아서 뿌리기만 했었는데, 이번에는 클라이언트측 에서 서버측으로 메시지를 보내면 서버측에서 메시지를 받은다음 다시 클라이언트 측에 보내고 클라이언트측에서 이 값을 출력하는 프로그램을 만들도록 하겠다

읽기/쓰기를 위해서 2개의 FIFO 파일을 만들어서 통신을 하게 될것이며, 각각의 이름은 fifo_c, fifo_s 로 하도록 하겠다.
프로그램이 하는 일은 fifo_c.c 에서 fifo_s.c 로 숫자를 보내면 fifo_s.c 에서는 받은 숫자를 "거듭제곱" 해서 fifo_c.c 로 다시 보내주고 fifo_c 에서는 이를 출력시켜주는 간단 프로그램이다.
쉘에서 mkfifo 명령을 이용해서 /tmp/fifo_c, /tmp/fifo_s 두개의 FIFO 파일을 생성하도록 하자.

fifo_s.c

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

#define chop(x) x[strlen(x) - 1] = 0x00 

int main()
{
    int fp_w;
    int fp_r;

    int n;
    char buf_r[11];
    char buf_w[11];
    if((fp_r = open("/tmp/fifo_c", O_RDONLY)) < 0)
    {
        perror("open error : ");
        exit(0);
    }
    if((fp_w = open("/tmp/fifo_s", O_WRONLY)) < 0)
    {
        perror("open error : ");
        exit(0);
    }


    memset(buf_r, 0x00, 11);
    memset(buf_w, 0x00, 11);

    while((n = read(fp_r, buf_r, 11)) > 0)
    {
        printf("%s", buf_r);
        chop(buf_r);
        sprintf(buf_w, "%d\n", atoi(buf_r) * atoi(buf_r));

        write(fp_w, buf_w, 11);

        memset(buf_r, 0x00, 11);
        memset(buf_w, 0x00, 11);
    }
    exit(1);
}

프로그램이 하는일은 간단하다.
/tmp/fifo_c 에서 메시지를 읽어서 이걸 제곱해서 /tmp/fifo_s 로 쓴다.

fifo_c.c

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

#define chop(x) x[strlen(x) - 1] = 0x00 

int main()
{
    int fp_r;
    int fp_w;
    int n;
    int i;
    char buf_r[11];
    char buf_w[11];

    if((fp_w = open("/tmp/fifo_c", O_WRONLY)) < 0)
    {
        perror("open error : ");
        exit(0);
    }
    if((fp_r = open("/tmp/fifo_s", O_RDONLY)) < 0)
    {
        perror("open error : ");
        exit(0);
    }


    i = 1;

    memset(buf_r, 0x00, 11);
    memset(buf_w, 0x00, 11);
    sprintf(buf_w, "%d\n", i);

    while((n = write(fp_w, buf_w, 11)) > 0)
    {
        read(fp_r, buf_r, 11);

        printf("%6d^2 = %s", atoi(buf_w), buf_r);
        memset(buf_r, 0x00, 11);
        memset(buf_w, 0x00, 11);
        i++;
        sprintf(buf_w, "%d\n", i);
        sleep(1);
    }
}

이 프로그램은 1부터 프로그램을 종료시킬때까지 순차적으로 (1씩증가) /tmp/fifo_c에 쓰고, 그 결과값(제곱)을 /tmp/fifo_s 에서 읽어오고, 그 값을 화면에 출력한다. fifo_s 를 먼저 실행하고 그다음 fifo_c 를 실행하면 된다. 다음은 실행화면이다.

[yundream@localhost test]#./fifo_s
1
2
3
4
5
6
7
8
9
10
11

[yundream@localhost test]#./fifo_c
     1^2 = 1
     2^2 = 4
     3^2 = 9
     4^2 = 16
     5^2 = 25
     6^2 = 36
     7^2 = 49
     8^2 = 64
     9^2 = 81
    10^2 = 100
    11^2 = 121
...

FIFO

관련문서