linux 几种IPC例子总结

1.管道

1.1普通管道

#include <unistd.h>

#include <sys/types.h>

#include <stdio.h>

#include <errno.h>

#include <stdlib.h>

int main()

{

int pipe_fd[2];

pid_t pid;

char buf_r[100];

char *p_wbuf;

int r_num;

memset(buf_r, 0, sizeof(buf_r));

if(pipe(pipe_fd) < 0)

{

printf("pipe create error!/n");

return -1;

}

if((pid = fork()) == 0)

{

printf("/n");

close(pipe_fd[1]);

sleep(2);

if((r_num = read(pipe_fd[0], buf_r, 100)) > 0)

{

printf("%d numbers read from the pipe is %s/n", r_num, buf_r);

}

close(pipe_fd[0]);

exit(0);

}

else if(pid > 0)

{

close(pipe_fd[0]);

if(write(pipe_fd[1], "Hello", 5) != -1)

printf("parent write surcess/n");

if(write(pipe_fd[1], "pipe", 5) != -1)

printf("parent write success/n");

close(pipe_fd[1]);

sleep(2);

waitpid(pid, NULL, 0);

exit(0);

}

1.2 基于文件流管理

/*流管道*/

#include <unistd.h>

#include <sys/types.h>

#include <errno.h>

#include <stdio.h>

#include <stdlib.h>

#define BUFSIZE 1024

int main()

{

FILE *fp;

char *cmd = "ps -ef";

char buf[BUFSIZE];

buf[BUFSIZE] = '/0';

if((fp = popen(cmd, "r")) == NULL)

perror("popen");

while((fgets(buf, BUFSIZE, fp)) != NULL)

printf("%s", buf);

pclose(fp);

exit(0);

}

1.3命名管道

读

#include <sys/types.h>

#include <sys/stat.h>

#include <unistd.h>

#include <fcntl.h>

#include <errno.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#define FIFO "/tmp/myfifo"

int

main(int argc, char **argv)

{

char buf_r[100];

int fd;

int nread;

if((mkfifo(FIFO, O_CREAT | O_EXCL) < 0) && (errno != EEXIST))

printf("cannot create fifoserver/n");

printf("Preparing for reading bytes../n");

memset(buf_r, 0 , sizeof(buf_r));

fd = open(FIFO, O_RDONLY | O_NONBLOCK, 0);

if(fd == -1)

{

perror("open FIFO failed!/n");

exit(1);

}

while(1)

{

memset(buf_r, 0, sizeof(buf_r));

if((nread = read(fd, buf_r, 100)) == -1)

{

if(errno == EAGAIN)

printf("no data yet]n");

}

printf("read %s, from FIFO/n", buf_r);

sleep(1);

}

pause();

unlink(FIFO);

}

写

#include <unistd.h>

#include <sys/types.h>

#include <sys/stat.h>

#include <fcntl.h>

#include <errno.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#define FIFO_SERVER "/tmp/myfifo"

int

main(int argc, char ** argv)

{

int fd;

char w_buf[100];

int nwrite;

fd = open(FIFO_SERVER, O_WRONLY | O_NONBLOCK, 0);

if(fd == -1)

{

if(errno == ENXIO)

printf("open error, no reading process/n");

}

if(argc == 1)

printf("Please send something/n");

strcpy(w_buf, argv[1]);

if((nwrite = write(fd, w_buf, 100)) == -1)

{

if(errno == EAGAIN)

printf("no data yet/n");

}

else

printf("write %d characters: %s/n", nwrite, w_buf);

}

信号及信号集

#include <signal.h>

#include <stdio.h>

#include <stdlib.h>

void my_func(int sig_no)

{

if(sig_no == SIGINT)

printf("I have get SIGINT/n");

else if(sig_no == SIGQUIT)

printf("I have get SIGQUIT/n");

}

int main()

{

printf("Waiting for signal SIGINT or SIGQUIT/n");

signal(SIGINT, my_func);

signal(SIGQUIT, my_func);

pause();

exit(0);

}

2. 信号集

#include <stdio.h>

#include <stdlib.h>

#include <signal.h>

void my_func(int signum)

{

printf("If you want to quit, please try SIGQUIT/n");

}

int main()

{

sigset_t set, pendset;

struct sigaction action1, action2;

if(sigemptyset(&set) < 0)

perror("sigemptyset");

if(sigaddset(&set, SIGQUIT) < 0)

perror("sigaddset");

if(sigaddset(&set, SIGINT) < 0)

perror("sigaddset");

if(sigprocmask(SIG_BLOCK, &set, NULL) < 0)

perror("sigprocmask");

else

{

printf("block/n");

sleep(5);

}

if(sigprocmask(SIG_UNBLOCK, &set, NULL) < 0)

perror("sigprocmask");

else

printf("unblock/n");

while(1)

{

if(sigismember(&set, SIGINT))

{

sigemptyset(&action1.sa_mask);

action1.sa_handler = my_func;

sigaction(SIGINT, &action1, NULL);

}

else if(sigismember(&set, SIGQUIT))

{

sigemptyset(&action2.sa_mask);

action2.sa_handler = SIG_DFL;

sigaction(SIGTERM, &action2, NULL);

}

3. 共享内存（大型数据传输）

#include <stdio.h>

#include <unistd.h>

#include <stdlib.h>

#include <string.h>

#include <sys/types.h>

#include <sys/ipc.h>

#include <sys/shm.h>

#define BUFSZ 2048

int main()

{

int shmid;

char *shmadd;

key_t key;

if((key = ftok(".", 'a')) == -1)

{

perror("ftok");

exit(1);

}

if((shmid = shmget(IPC_PRIVATE, BUFSZ, 0666)) < 0)

{

perror("shmget");

exit(1);

}

else

{

printf("created shared-memory: %d/n", shmid);

system("ipcs –m");

}

if((shmadd = shmat(shmid, 0, 0)) < (char*)0)

{

perror("shmat");

exit(1);

}

else

{

printf("attached shared-memory/n");

system("ipcs –m");

}

if(shmdt(shmadd) < 0)

{

perror("shmdt");

exit(1);

}

else

{

printf("dettached shared-memory/n");

system("ipcs -m");

}

exit(0);

}

4. 消息队列（少量数据传输）

#include <stdio.h>

#include <unistd.h>

#include <stdlib.h>

#include <string.h>

#include <sys/types.h>

#include <sys/ipc.h>

#include <sys/msg.h>

#define BUFSZ 512

struct message

{

long msg_type;

char msg_text[BUFSZ];

};

int main()

{

int qid;

key_t key;

int len;

struct message msg;

if((key = ftok(".", 'a')) == -1)

{

perror("ftok");

exit(1);

}

if((qid = msgget(key, IPC_CREAT | 0666)) == -1)

{

perror("msgget");

exit(1);

}

printf("opened queue %d/n", qid);

puts("Please enter the message to queue:");

if((fgets(msg.msg_text, BUFSZ, stdin)) == NULL)

{

puts("no message");

exit(1);

}

msg.msg_type = getpid();

len = strlen(msg.msg_text);

if(msgsnd(qid, &msg, len, 0) < 0)

{

perror("message posted");

exit(1);

}

printf("message is :%s/n", msg.msg_text);

if(msgctl(qid, IPC_RMID, NULL) < 0)

{

perror("msgctl");

exit(1);

}

exit(0);

}

5. 守护进程

守护进程（daemon）是生存期长的一种进程。它们常常在系统引导装入时启动，在系统关闭时终止。因为它们没有控制终端，所以说它们是在后台进程的。所有守护进程都以超级用户优先级运行。所有守护进程的父进程都init进程。守护进程一般是进程组的首进程。

查看守护进程命令：

ps –ef

创建守护进程的步骤：

（1）创建子进程，父进程退出。

保证子进程不是一个进程组的首进程，是调用setsid调用的必要的前提条件。

（2）调用setsid以创建一个新的会话，并担任该会话组的组长。调用setsid作用有三：

（a）成为新的会话组（一个或多个进程组）的首进程。

（b）成为一个新进程组的首进程。

（c）脱离控制终端。

chdir(“/”);

（4）重设文件权限掩码

unmask(0);表示打开所有文件权限

（5）关闭不再需要的文件描述符

#include <stdio.h>

#include <stdlib.h>

#include<string.h>

#include <fcntl.h>

#include <sys/types.h>

#include <unistd.h>

#include <sys/wait.h>

#define MAXFILE 65535

int main()

{

pid_t pc;

int i, fd, len;

char *buf = "This is a Dameon/n";

len = strlen(buf);

pc = fork();

if(pc < 0)

{

printf("error fork/n");

exit(1);

}

else if(pc > 0)

{

exit(0);

}

setsid();

chdir("/");

umask(0);

for(i = 0; i < MAXFILE; i++)

close(i);

while(1)

{

if((fd = open("/tmp/dameon.log", O_CREAT | O_WRONLY | O_APPEND, 0600)) < 0)

{

perror("open");

exit(1);

}

write(fd, buf, len+1);

close(fd);

sleep(5);

}

转载于:https://my.oschina.net/fuyajun1983cn/blog/263872

linux 几种IPC例子总结相关推荐

linux怎么配置命令模式,Linux几种命令模式
原标题:Linux几种命令模式必须掌握的几个Linux命令我们为什么要学习Linux的命令? 初学者上手Linux系统会很懵.不管你是否安装了图形化界面,或者去网上找一些教程.或者一些Linux的 ...
20155301 滕树晨linux基础——linux进程间通信（IPC）机制总结
20155301 滕树晨linux基础--linux进程间通信(IPC)机制总结共享内存共享内存是在多个进程之间共享内存区域的一种进程间的通信方式,由IPC为进程创建的一个特殊地址范围,它将出现在 ...
Linux五种IO模型性能分析
转载:http://blog.csdn.net/jay900323/article/details/18141217 Linux五种IO模型性能分析目录(?)[-] 概念理解 Linux下的 ...
2017-2018-1 20155222 《信息安全系统设计基础》第10周 Linux下的IPC机制
2017-2018-1 20155222 <信息安全系统设计基础>第10周 Linux下的IPC机制 IPC机制在linux下的多个进程间的通信机制叫做IPC(Inter-Process ...
linux基础——linux进程间通信（IPC）机制总结
原 linux基础--linux进程间通信(IPC)机制总结 2016年07月23日 21:33:12 yexz 阅读数:18224更多 <div class="tags-box sp ...
Linux进程+进程间通信IPC
一 Linux进程 1) 进程的内存映像 2)解释 BSS段:在采用段式内存管理的架构中,BSS段(bss segment)通常是指用来存放程序中未初始化的全局变量的一块内存区域.BSS是英文Bloc ...
Windows五种IO模型性能分析和Linux五种IO模型性能分析
Windows五种IO模型性能分析和Linux五种IO模型性能分析 http://blog.csdn.net/jay900323/article/details/18141217 http://blo ...
Linux ns 5. IPC Namespace 详解
文章目录 1. 简介 2. 源码分析 2.1 copy_ipcs() 2.2 ipcget() 2.3 ipc_check_perms() 2.4 相关系统调用参考文档: 1. 简介进程间通讯的机 ...
Linux的常见IPC机制简介
IPC机制:Inter-Process Communication,进程间通信机制本文简述的IPC机制有:管道pipe.命名管道FIFO.信号.信号量.消息队列.共享内存.内存映射 1.管道pipe ...

linux 几种IPC例子总结

linux 几种IPC例子总结相关推荐

最新文章

热门文章