守护进程实现时间服务器

2022-06-04 20:09:10

　　守护进程是在后台运行不受终端控制的进程（如输入、输出等），一般的网络服务都是以守护进程的方式运行。守护进程脱离终端的主要原因有两点：（1）用来启动守护进程的终端在启动守护进程之后，需要执行其他任务。（2）（如其他用户登录该终端后，以前的守护进程的错误信息不应出现）由终端上的一些键所产生的信号（如中断信号），不应对以前从该终端上启动的任何守护进程造成影响。要注意守护进程与后台运行程序（即加＆启动的程序）的区别。

创建守护进程的过程：

1. 调用fork创建子进程。父进程终止，让子进程在后台继续执行。
2. 子进程调用setsid产生新会话期并失去控制终端调用setsid()使子进程进程成为新会话组长和新的进程组长，同时失去控制终端。
3. 忽略SIGHUP信号。会话组长进程终止会向其他进程发该信号，造成其他进程终止。
4. 调用fork再创建子进程。子进程终止，子子进程继续执行，由于子子进程不再是会话组长，从而禁止进程重新打开控制终端。
5. 改变当前工作目录为根目录。一般将工作目录改变到根目录，这样进程的启动目录也可以被卸掉。
6. 关闭打开的文件描述符，打开一个空设备，并复制到标准输出和标准错误上。避免调用的一些库函数依然向屏幕输出信息。
7. 重设文件创建掩码清除从父进程那里继承来的文件创建掩码，设为0。
8. 用openlog函数建立与syslogd的连接。

创建守护进程的例子如下程序所示：

void daemon_init(const char* pname,int facility)
{
    int                 i;
    pid_t               pid;
    struct  rlimit      rl;
    struct  sigaction   sa;
    /* 清除文件模式创建掩码,使新文件的权限位不受原先文件模式创建掩码的权限位的影响*/
    umask(0);
    if(getrlimit(RLIMIT_NOFILE,&rl) < 0)
    {
        perror("getrlimit() error");
        exit(-1);
    }
    if((pid = fork()) < 0)
    {
        perror("fork() error");
        exit(-1);
    }
    else if(pid > 0)   /*父进程终止 */
        exit(0);
    setsid();         /* 子进程成为会话首进程*/
    sa.sa_handler = SIG_IGN;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = 0;
    if(sigaction(SIGHUP,&sa,NULL) < 0)
    {
        perror("sigaction() error");
        exit(-1);
    }
    if((pid = fork()) < 0)
    {
        perror("fork() error");
        exit(-1);
    }
    else if(pid > 0)
        exit(0);        /* 第一个子程进终止,保证后面操作不会分配终端 */
    if(chdir("/")<0)    /* 改变工作目录 */
    {
        perror("chdir() error");
        exit(-1);
    }
    if(rl.rlim_max == RLIM_INFINITY)
        rl.rlim_max = 1024;
    for(i=0;i<rl.rlim_max;++i)  /*关闭所有打开的文件描述字*/
        close(i);
    openlog(pname, LOG_PID, facility);  /*用syslogd处理错误*/
}

现在要用守护进程实现一个时间服务器，呈现的功能是：服务器运行后自动成为守护进程，返回shell；客户端运行后收到服务器发来的当前时间。

时间服务器程序（timeserver.c）如下：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <sys/types.h>
#include <fcntl.h>
#include <signal.h>
#include <syslog.h>
#include <sys/resource.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <time.h>

#define MAXLINE 100

void daemon_init(const char* pname,int facility)
{
   int                 i;
   pid_t               pid;
   struct  rlimit      rl;
   struct  sigaction   sa;
   /* 清除文件模式创建掩码,使新文件的权限位不受原先文件模式创建掩码的权限位的影响*/
   umask(0);
   if(getrlimit(RLIMIT_NOFILE,&rl) < 0)
   {
       perror("getrlimit() error");
       exit(-1);
   }
   if((pid = fork()) < 0)
   {
       perror("fork() error");
       exit(-1);
   }
   else if(pid > 0)   /*父进程终止 */
       exit(0);
   setsid();         /* 子进程成为会话首进程*/
   sa.sa_handler = SIG_IGN;
   sigemptyset(&sa.sa_mask);
   sa.sa_flags = 0;
   if(sigaction(SIGHUP,&sa,NULL) < 0)
   {
       perror("sigaction() error");
       exit(-1);
   }
   if((pid = fork()) < 0)
   {
       perror("fork() error");
       exit(-1);
   }
   else if(pid > 0)
       exit(0);        /* 第一个子程进终止,保证后面操作不会分配终端 */
   if(chdir("/")<0)    /* 改变工作目录 */
   {
       perror("chdir() error");
       exit(-1);
   }
   if(rl.rlim_max == RLIM_INFINITY)
       rl.rlim_max = 1024;
   for(i=0;i<rl.rlim_max;++i)  /*关闭所有打开的文件描述字*/
       close(i);
   openlog(pname, LOG_PID, facility);  /*用syslogd处理错误*/
}

int main(int argc,char *argv[])
{
   int                 listenfd, connfd;
   socklen_t           addrlen, len;
   struct sockaddr     cliaddr;
   struct sockaddr_in  server;
   char                buff[MAXLINE];
   time_t              ticks;
   int                 n;
   bzero(&server, sizeof(server));
   bzero(&cliaddr,sizeof(cliaddr));
   server.sin_family = AF_INET;
   server.sin_port = htons(5050);
   server.sin_addr.s_addr = htonl(INADDR_ANY);
   daemon_init(argv[0], 0);
   if((listenfd=socket(AF_INET, SOCK_STREAM, 0))==-1)
   {
       syslog(LOG_NOTICE|LOG_LOCAL0,"socket error");
       exit(-1);
   }
   if (bind(listenfd, (struct sockaddr *)&server, sizeof(struct sockaddr))==-1)
   {
       syslog(LOG_NOTICE|LOG_LOCAL0,"socket error");
       exit(-1);
   }
   if(listen(listenfd,5)==-1)
   {
       syslog(LOG_NOTICE|LOG_LOCAL0,"listen error");
       exit(-1);
   }
   for ( ; ; )
   {
       len = sizeof(cliaddr);
       connfd = accept(listenfd,&cliaddr, &len);
       ticks = time(NULL);
       snprintf(buff, sizeof(buff), "%.24s\r\n", ctime(&ticks));
       if((n= write(connfd, buff, strlen(buff)))==-1)
          syslog(LOG_NOTICE|LOG_LOCAL0,"write error");
       close(connfd);
   }
}

客户端程序（timeclient.c）如下：

#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#define PORT            5050
#define MAXDATASIZE     100

int main(int argc, char *argv[])
{
   int                  fd, numbytes;
   char                 buf[MAXDATASIZE];
   struct sockaddr_in   server;
   if ((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
   {
       perror("Create socket failed.");
       exit(-1);
   }
   bzero(&server, sizeof(server));
   server.sin_family = AF_INET;
   server.sin_port = htons(PORT);
   server.sin_addr.s_addr = htonl(INADDR_ANY);
   if (connect(fd, (struct sockaddr *)&server, sizeof(struct sockaddr)) == -1)
   {
       perror("connect failed.");
       exit(-1);
   }
   if( ((numbytes = recv(fd, buf, MAXDATASIZE, 0)) == -1))
   {
       perror("recv error.");
       exit(-1);
   }
   buf[numbytes] ='\0';
   printf("Server Message: %s\n",buf);
   close(fd);
}

程序运行过程：先运行时间服务器程序，再在运行客户端程序。

运行时间服务器程序结果如下:

此时timeserver是个守护进程，已经在运行，通过ps -axj命令可以查看该进程，查看结果如下：

运行客户端程序结果如下：

守护进程实现时间服务器

客户端收到服务器发送的当前时间。

码农公寓

相关文章