Използване на именовани тръби
Представената двойка програми реализира чат базирано клиент/сървър приложение, което демонстрира използването на именовани тръби.
pipe-chat-server.c
Създайте файл на име ./pipe-chat-fifo. Отворете за писане ./pipe-chat-fifo в случай на грешка излезте. Стартирайте цикъл, който работи докато получим "q" от клавиатурата. Прочетете символ (key) и го запишете във файла. Ако key е Enter използвайте flush. Затворете и изтрийте файла.
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/types.h>
#include<sys/stat.h>
#define FIFO_FILE "./pipe-chat-fifo"
int main(int argc, char ** argv)
{
mkfifo(FIFO_FILE, 0600);
FILE* f = fopen(FIFO_FILE, "w");
if(f == NULL)
{
printf("Error open file!\n");
return EXIT_FAILURE;
}
char key;
do
{
key = getchar();
fputc(key, f);
if(key == 10) fflush(f);
}
while(key != 'q');
fclose(f);
unlink(FIFO_FILE);
return EXIT_SUCCESS;
}
Компилирайте и стартирайте програмaта:
gcc pipe-chat-server.c -o pipe-chat-server
./pipe-chat-server
pipe-chat-client.c
Отворете за четене файл на име ./pipe-chat-fifo. Стартирайте цикъл, който работи докато получим "q" от клавиатурата. Прочетете символ (key). Изведете получения символ в конзолата. Затворете и изтрийте файла.
#include<stdlib.h>
#include<stdio.h>
#include<unistd.h>
#define FIFO_FILE "./pipe-chat-fifo"
int main(int argc, char ** argv)
{
FILE* f = fopen(FIFO_FILE, "r");
if(f == NULL)
{
printf("Error open file!\n");
return EXIT_FAILURE;
}
char key;
do
{
key = fgetc(f);
putchar(key);
}
while(key != 'q');
fclose(f);
unlink(FIFO_FILE);
return EXIT_SUCCESS;
}
Компилирайте и стартирайте програмaта:
gcc pipe-chat-client.c -o pipe-chat-client
./pipe-chat-client
pipe-echo-chat.c
Представената програма реализира чат базирано приложение което връща ехо и демонстрира използването на именовани тръби.
Създайте файл на име pipe-echo-chat-fifo-file. Създайте дъщерен процес (fork) в случай на грешка излезте от програмата:
Родителски процес: Отворете за писане pipe-echo-chat-fifo-file в случай на грешка излезте. Четете от клавиатурата и пращайте полученото във файлa. Затворете файлов дескриптор.
Дъщерен процес: Отворете за четене pipe-echo-chat-fifo-file в случай на грешка излезте. Прочетете съобщение от входният файлов дескриптор. Отпечатайте полученото съобщение. Затворете файловия дескриптор.
#include<stdio.h>
#include<string.h>
#include<sys/stat.h>
#include<sys/types.h>
#include<stdlib.h>
#include<unistd.h>
#include<fcntl.h>
#define FIFO_FILE "pipe-echo-chat-fifo-file"
int main(int argc, char ** argv)
{
mkfifo(FIFO_FILE, 0644);
int pid = fork();
if(pid == -1)
{
printf("Error fork!\n");
return EXIT_FAILURE;
}
if(pid > 0)
{
int fd = open(FIFO_FILE, O_WRONLY);
if(fd == -1)
{
printf("Error open file for writing!\n");
return EXIT_FAILURE;
}
char writeBuffer[80];
while (1)
{
fgets(writeBuffer, 80, stdin);
write(fd, writeBuffer, strlen(writeBuffer) + 1);
}
close(fd);
}
else
{
int fd = open(FIFO_FILE, O_RDONLY);
if(fd == -1)
{
printf("Error open file for reading!\n");
return EXIT_FAILURE;
}
char readBuffer[80];
while (1)
{
read(fd, readBuffer, sizeof(readBuffer));
printf("%s\n", readBuffer);
}
close(fd);
}
unlink(FIFO_FILE);
return EXIT_SUCCESS;
}
Компилирайте и стартирайте програмата:
gcc pipe-echo-chat.c -o pipe-echo-chat
./pipe-echo-chat
Last updated
Was this helpful?