有名管道，精灵进程

编程实现两个程序&＃xff1a;一个服务器server&＃xff0c;一个客户机client。
要求&＃xff1a;
服务器采用精灵进程的方式在后台运行&＃xff0c;常驻内存。
服务器创建并监视有名管道FIFO&＃xff0c;一旦发现有数据&＃xff0c;服务器将其保存到一个指定的地方。
客户机每隔一段时间产生一个子进程。
客户机的这些子进程将当前系统时间和自身的PID写入有名管道FIFO就退出。

要点&＃xff1a;有名管道&＃xff0c;进程间的通信。

客户端&＃xff1a;

#include "common.h" //头文件就是包含使用到的函数// 信号的响应处理函数&＃xff0c;函数头&＃xff08;接口&＃xff09;是系统规定的
void cleanup(int sig)
{// 回收僵尸子进程wait(NULL);// 使用非阻塞版本来回收僵尸子进程// -1: 查看任意子进程死了没有// NULL: 对子进程怎么死&＃xff08;退出状态&＃xff09;的不感兴趣// WNOHANG: 非阻塞回收&＃xff08;如果死了就立刻释放其资源&＃xff0c;如果没死拉倒&＃xff0c;我就走了&＃xff09;while(waitpid(-1, NULL, WNOHANG) > 0);
}int main()
{// 关联子进程终止的信号及其处理函数signal(SIGCHLD, cleanup);while(1){pid_t pid &＃61; fork();// 父进程if(pid > 0){sleep(1);continue;}// 子进程if(pid &＃61;&＃61; 0){// 1&＃xff0c;打开预谋好的管道int fd &＃61; open("/home/gec/fifo", O_WRONLY);if(fd &＃61;&＃61; -1){perror("服务器未启动或管道文件打开失败");exit(0);}// 2&＃xff0c;将系统时间、自身PID放入buf中char buf[50];bzero(buf, 50);time_t t &＃61; time(&t);snprintf(buf, 50, "PID:%d 时间:%s",getpid(), ctime(&t));// 3&＃xff0c;将buf中的数据写入管道write(fd, buf, strlen(buf));printf("%s", buf);break;}}return 0;
}

服务端

#include "common.h"static bool begin &＃61; true;
static FILE *fp;void saveData(const char *buf, int size)
{if(begin){fp &＃61; fopen("/home/gec/mylog", "a&＃43;");begin &＃61; false;}// 将数据写入文件&＃xff0c;并刷新缓冲区fwrite(buf, size, 1, fp);fflush(fp);
}
void mylog(const char *usrmsg, const char *errmsg)
{char buf[100];bzero(buf, 100);snprintf(buf, 100, "%s:%s\n", usrmsg, errmsg);syslog(LOG_DAEMON, buf);
}int daemon_init(void)
{pid_t pid;int fd0, fd1, fd2, max_fd,i; // 1if((pid &＃61; fork()) < 0){perror("fork faild!");exit(1);}else if(pid > 0){exit(0);}printf("第1步成功\n");// 2signal(SIGHUP, SIG_IGN);printf("第2步成功\n");// 3if(setsid() < 0){exit(1);}printf("第3步成功\n");// 4if((pid &＃61; fork()) < 0){perror("fork faild!");exit(1);}else if(pid > 0)exit(0);printf("第4步成功\n");// 5setpgrp();printf("第5步成功\n");// 6// 准备好写系统日志openlog("Server", LOG_CONS | LOG_PID, LOG_DAEMON);// 7// 首先获取进程所能打开的文件描述符的最大值max_fd &＃61; sysconf(_SC_OPEN_MAX);// 将所有的文件描述符全部关闭&＃xff08;包括标准输入、输出&＃xff09;for (i &＃61; max_fd; i>&＃61;0; i--){close(i);}// 7umask(0);// 8chdir("/");return 0;
}int main()
{// 1&＃xff0c;变神仙daemon_init();// 2&＃xff0c;创建管道&＃xff0c;并打开管道mkfifo("/home/gec/fifo", 0666);int fd &＃61; open("/home/gec/fifo", O_RDWR);if(fd &＃61;&＃61; -1){mylog("打开管道失败", strerror(errno));exit(0);}// 3&＃xff0c;不断地将管道数据读出并保存char buf[50];while(1){bzero(buf, 50);int n &＃61; read(fd, buf, 50);if(n > 0){saveData(buf, n);}else{mylog("读取管道数据失败", strerror(errno));exit(0);}}fclose(fp);close(fd);return 0;
}

思路与步骤&＃xff1a;

一、客户端步骤&＃xff1a;

1. 打开有名管道
2. 往管道写入数据
3. 管道的读写是在子进程进程进行&＃xff0c;执行完任务后就退出了。所以父进程要回收子进程&＃xff0c;避免僵尸的长期存在。

二、服务端步骤

4. 创建有名管道
5. 打开有名管道
6. 阻塞等待客户端的信息
7. 有数据来的话就创建一个文件来保存客户端的数据
8. 服务端应该为一个精灵进程&＃xff0c;即我当前的控制终端关闭也不影响我持续不断的监控客户端的数据。