進程間通訊
pipe, 親屬間進程通訊,
#include <unistd.h>
int pipe(int pipefd[2]);
參數(shù):
- pipedfd :用于接收pipe函數(shù)創(chuàng)建的管道文件的讀寫文件描述
- pipefd[0] :指向管道文件的讀端
- pipefd[1]:指向文件寫端
返回值：成功腺律，返回0；失敗返回1贷腕；
mkfifo ,任意進程之間通訊
#include <sys/types.h>
#include <sys/stat.h>
int mkfifo(const char *pathname, mode_t mode);
參數(shù)：
const char *pathname蜜另；管道文件
-
mode_t mode 文件權限
?
//親屬進程間的通訊
#include <stdio.h>
#include <unistd.h>
#define BUFFER_SIZE 1024
// int pipe(int pipefds[2]);
// 參數(shù)：
// pipefds 用于接收pipe函數(shù)創(chuàng)建的管道文件的讀寫文件描述符
// pipefds[0] 指向管道文件的讀端
// pipefds[1] 指向管道文件的寫端
// 返回值：成功返回0，失敗等缀，返回-1
int main(int argc, char *argv[])
{
pid_t child_pid = 0;
int pipe_fds[2] = {0};
char buf[BUFFER_SIZE] = {'\0'};
// 創(chuàng)建pipe
if(pipe(pipe_fds) == -1)
{
perror("pipe failed");
return 1;
}
// 數(shù)據(jù)從子進程傳遞給父進程
if((child_pid = fork()) == 0)
{
int n = 0;
// child process
// 1.關閉子進程中管道的讀文件描述符
close(pipe_fds[0]);
while(1)
{
// 2.從標準輸入文件中讀入數(shù)據(jù)
n = read(STDIN_FILENO, buf, BUFFER_SIZE);
// 3.將讀到的數(shù)據(jù)寫入到管道中
write(pipe_fds[1], buf, n);
}
}
else if(child_pid > 0)
{
int n =0;
// parent process
// 1.在父進程中關閉管道的寫文件描述符
close(pipe_fds[1]);
while(1)
{
// 2.從管道中讀取數(shù)據(jù)
n = read(pipe_fds[0], buf, BUFFER_SIZE);
// 3.將從管道中讀取的數(shù)據(jù)寫入到標準輸出文件
write(STDOUT_FILENO, buf, n);
}
}
else
{
// error
}
return 0;
}
任意兩個進程間的通訊：
實例一：
//寫管道程序**********************************************
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdio.h>
#include <unistd.h>
int main(int argc, char *argv[])
{
int n = 0;
char buf[1024] = {'\0'};
int fd = 0;
// 判斷有名管道文件是否村子蜂绎，不存在則創(chuàng)建
if(access("test_file.fifo", F_OK) != 0 )
{
mkfifo("test_file.fifo",
S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
}
// 1.打開管道文件
if((fd = open("test_file.fifo", O_WRONLY)) == -1)
{
perror("open failed");
return 1;
}
printf("waiting for input data...\n");
while(1)
{
// 2.從標準輸入文件中讀入數(shù)據(jù)
n = read(STDIN_FILENO, buf, 1024);
// 3.將讀到的數(shù)據(jù)寫入到管道文件中
write(fd, buf, n);
}
printf("writer process exit...\n");
return 0;
}
//讀管道程序*************************************************
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <fcntl.h>
#include <sys/stat.h>
int main(int argc, char *argv[])
{
int n = 0;
char buf[1024] = {'\0'};
int fd = 0;
// 判斷管道文件是否存在搓逾，不存在則創(chuàng)建
if(access("test_file.fifo", F_OK) != 0 )
{
mkfifo("test_file.fifo",
S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
}
// 1.打開管道文件
fd = open("test_file.fifo", O_RDONLY);
if(fd == -1)
{
perror("open failed");
return 1;
}
printf("waiting for read data...\n");
// 2.從管道文件中讀取數(shù)據(jù)
while((n = read(fd, buf, 1024)) > 0)
{
// 3.將讀到的數(shù)據(jù)寫入到標準輸出文件中
write(STDOUT_FILENO, buf, n);
}
printf("reader process exit...\n");
return 0;
}
實例二：
簡易聊天程序
// ./named-pipe-chat user_name
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>
// 用戶名的最大長度
#define USER_NAME_MAX_LEN 100
// 發(fā)送消息文本的最大長度
#define MSG_MAX_LEN 500
// 文件名的最大長度
#define FILE_NAME_MAX_LEN 100
// 聊天消息結構體類型
struct msg_node
{
// 發(fā)送消息用戶名
char src_username[USER_NAME_MAX_LEN];
// 接收消息用戶名
char dst_username[USER_NAME_MAX_LEN];
// 消息文本
char text[MSG_MAX_LEN];
};
int main(int argc, char *argv[])
{
// 判斷命令行參數(shù)是否滿足條件
if(argc != 2)
{
printf("usage : %s <username>\n", argv[0]);
return 1;
}
// 子進程ID
pid_t child_pid;
// 登陸用戶的命令管道文件名
char filename[FILE_NAME_MAX_LEN] = {'\0'};
// 構造登陸用戶的命令管道文件名，并判定用戶是否存在
sprintf(filename, "%s.fifo", argv[1]);
if(access(filename, F_OK) != 0)
{
mkfifo(filename, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
}
// 創(chuàng)建子進程
if((child_pid = fork()) == 0) // 子進程中執(zhí)行的代碼骗露，子進程負責接收其他用戶發(fā)送的消息并打印顯示
{
int n = 0;
struct msg_node msg;
int fd = 0;
// 1.打開登陸用戶的管道文件岭佳，用于接收其他用戶發(fā)送的消息數(shù)據(jù)結構體
if((fd = open(filename, O_RDONLY)) == -1)
{
perror("open failed");
return 1;
}
// 2.循環(huán)的從管道文件中讀入消息信息，并打印顯示
while((n = read(fd, &msg, sizeof(msg))) > 0)
{
printf("%s ----> %s : %s\n",
msg.src_username, msg.dst_username, msg.text);
}
// 3.關閉管道文件
close(fd);
}
else if(child_pid > 0) // 父進程萧锉，負責從鍵盤讀入相關數(shù)據(jù)珊随，寫入執(zhí)行用戶的管道文件
{
struct msg_node msg;
int fd = 0;
// 接收用戶的管道文件名
char dst_filename[FILE_NAME_MAX_LEN] = {'\0'};
// 發(fā)送者永遠為當前登錄用戶
strcpy(msg.src_username, argv[1]);
// 1.輸入接收消息的用戶名名稱
printf("to>");
fgets(&msg.dst_username, USER_NAME_MAX_LEN, stdin);
// 1.1將用戶名末尾的'\n'替換為'\0'
msg.dst_username[strlen(msg.dst_username)-1] = '\0';
// 1.3構造接收用戶的管道文件名
sprintf(dst_filename, "%s.fifo", msg.dst_username);
// 1.3打開管道文件
if((fd = open(dst_filename, O_WRONLY)) == -1)
{
perror("open failed");
return 1;
}
// 循環(huán)的發(fā)送從鍵盤讀入的數(shù)據(jù)
while(1)
{
// 2.輸入待發(fā)送的消息字符串
printf("text>");
fgets(&msg.text, MSG_MAX_LEN, stdin);
// 2.2將消息文本末尾的'\n'替換為'\0'
msg.text[strlen(msg.text)-1] = '\0';
// 3.將構造的消息結構體寫入管道文件
write(fd, &msg, sizeof(msg));
}
// 3.3close
close(fd);
}
else
{
}
// 刪除登陸用戶的管道文件
remove(filename);
return 0;
}
