【问题标题】:Server port doenst get back to listen and is in closed_wait state , because of starting a daemon application from client由于从客户端启动守护程序应用程序,服务器端口无法返回侦听并处于 close_wait 状态
【发布时间】:2015-11-27 18:11:40
【问题描述】:

下面是基本的客户端和服务器代码。 在连接调用期间,我试图启动一个应用程序(一旦我们向服务器发送消息,它就必须在机器中继续运行)。 在客户端代码中使用 system(/bin/myApplication) (这基本上是一个带有无限循环的简单 c 可执行文件,假设我的应用程序必须运行); 一旦我启动应用程序,服务器就处于 CLOSED_WAIT 状态,只有当我停止这个应用程序时它才会回来监听。 问题在于服务器套接字处于 CLOSED_WAIT 状态,有没有办法让这个应用程序继续作为一个单独的进程运行,并且服务器将再次处于侦听状态。 客户端代码:读取后有一个系统命令。它启动一个应用程序(基本上是一个带有无限while循环的c可执行文件)

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <arpa/inet.h> 

int main(int argc, char *argv[])
{
    int sockfd = 0, n = 0;
    char recvBuff[1024];
    struct sockaddr_in serv_addr; 

    if(argc != 2)
    {
        printf("\n Usage: %s <ip of server> \n",argv[0]);
        return 1;
    } 

    memset(recvBuff, '0',sizeof(recvBuff));
    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        printf("\n Error : Could not create socket \n");
        return 1;
    } 

    memset(&serv_addr, '0', sizeof(serv_addr)); 

    serv_addr.sin_family = AF_INET;
    serv_addr.sin_port = htons(5000); 

    if(inet_pton(AF_INET, argv[1], &serv_addr.sin_addr)<=0)
    {
        printf("\n inet_pton error occured\n");
        return 1;
    } 

    if( connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
    {
       printf("\n Error : Connect Failed \n");
       return 1;
    } 

    while ( (n = read(sockfd, recvBuff, sizeof(recvBuff)-1)) > 0)
    {
        recvBuff[n] = 0;
        if(fputs(recvBuff, stdout) == EOF)
        {
            printf("\n Error : Fputs error\n");
        }
    } 
    system(/bin/myApplication);
    if(n < 0)
    {
        printf("\n Read error \n");
    } 

    return 0;

服务器代码:

int main(int argc, char *argv[])
{
    int listenfd = 0, connfd = 0;
    struct sockaddr_in serv_addr; 

    char sendBuff[1025];
    time_t ticks; 

    listenfd = socket(AF_INET, SOCK_STREAM, 0);
    memset(&serv_addr, '0', sizeof(serv_addr));
    memset(sendBuff, '0', sizeof(sendBuff)); 

    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    serv_addr.sin_port = htons(5000); 

    bind(listenfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)); 

    listen(listenfd, 10); 

    while(1)
    {
        connfd = accept(listenfd, (struct sockaddr*)NULL, NULL); 

        ticks = time(NULL);
        snprintf(sendBuff, sizeof(sendBuff), "%.24s\r\n", ctime(&ticks));
        write(connfd, sendBuff, strlen(sendBuff)); 

        close(connfd);
        sleep(1);
     }
} 

我的示例 C 文件,我试图在客户端中使用系统命令执行 代码。与

gcc Sample.c -o myApplication

int main(int argc, char *argv[])
{

    while(1)

    {

    }
}

我尝试过使用fork,但是socket仍然处于相同的状态,无论如何这个应用程序是单独运行并且不影响socket,也不依赖于父进程(这里是服务器)。

【问题讨论】:

  • 在您的客户端中,在通过 system() 启动您的应用程序之前关闭 sockfd。为什么需要保持打开状态?如果您的服务器不接受多个连接,则问题出在代码的其他地方。

标签: c++ c sockets asyncsocket


【解决方案1】:

您的客户端应用永远不会关闭套接字,并且由于您生成的示例应用会永远循环,因此客户端永远不会退出。这使得 TCP 连接状态在两边都挂起。

在客户端中,在生成示例应用程序之前尝试关闭套接字。

另外,我认为您对 TCP 状态感到困惑。处于 LISTEN 状态的服务器端点不会转换到 CLOSE_WAIT 并返回。 LISTEN 端点(您调用listen() on 的套接字)将保持该状态直到关闭。连接的端点(accept() 返回的套接字)将在其生命周期内转换各种状态。

如果您使用netstat 命令查看状态,请务必使用-a 标志来显示监听端点。

【讨论】:

  • 但是,这是保持连接,因为我的客户端无法连接到服务器,直到我终止应用程序。另外,有没有办法关闭 TCP 连接。我的意思是我们可以开始一个不影响连接的新进程。
  • 它只是在本地(OSX)运行它并且工作正常(经过一些小改动使其编译)。我可以启动多个客户端,它们都连接到服务器,检索时间戳字符串,然后生成“应用程序”。看到问题的具体步骤是什么?
  • 我工作正常,多个客户端正在运行,但是对于所有这些连接,如果我们执行 netstat -apn |,端口处于 CLOSED_WAIT 状态。 grep 5000。我一直在寻找一种方法(应用程序的单独进程),它不会影响端口,即使应用程序正在运行,它也会正常关闭。截至目前,该应用程序必须关闭才能结束连接。
  • 正如我在回答中所写,您的客户端不会关闭其套接字。在调用system("/bin/myApplication"); 之前添加close(sockfd);,CLOSED_WAIT 消失。我刚刚在 OSX (10.11.1) 和 Linux (Debian 7.9) 下验证了这一点。
【解决方案2】:

我在系统命令之前添加了以下行

fcntl(sockfd, F_SETFD, fcntl(sockfd, F_GETFD) | FD_CLOEXEC);

并将我的客户端代码更改为

#include <sys/types.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <fcntl.h>
int main(int argc, char *argv[])
{
    int sockfd = 0, n = 0;
    char recvBuff[1024];
    struct sockaddr_in serv_addr;

    if(argc != 2)
    {
        printf("\n Usage: %s <ip of server> \n",argv[0]);
        return 1;
    }

    memset(recvBuff, '0',sizeof(recvBuff));
    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        printf("\n Error : Could not create socket \n");
        return 1;
    }

    memset(&serv_addr, '0', sizeof(serv_addr));

    serv_addr.sin_family = AF_INET;
    serv_addr.sin_port = htons(5000);

    if(inet_pton(AF_INET, argv[1], &serv_addr.sin_addr)<=0)
    {
        printf("\n inet_pton error occured\n");
        return 1;
    }

    if( connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
    {
       printf("\n Error : Connect Failed \n");
       return 1;
    }

    while ( (n = read(sockfd, recvBuff, sizeof(recvBuff)-1)) > 0)
    {
        recvBuff[n] = 0;
        if(fputs(recvBuff, stdout) == EOF)
          printf("\n Error : Fputs error\n");
        }

   }

        fcntl(sockfd, F_SETFD, fcntl(sockfd, F_GETFD) | FD_CLOEXEC);

         system("/software/itcsm/itcsm/refasset/bin/start_script.sh 1");

    if(n < 0)
    {
        printf("\n Read error \n");
    }
        printf("\n after system \n");

    return 0;
}

默认情况下,每当我们 fork 一个进程(系统命令执行此操作)时,子进程都会继承父进程的所有文件描述符。如果孩子不需要这些描述符,它应该在文件描述符上使用 fcntl(sockfd, F_SETFD, fcntl(sockfd, F_GETFD) | FD_CLOEXEC) 自愿关闭它们;

【讨论】:

    猜你喜欢
    • 2013-08-21
    • 1970-01-01
    • 1970-01-01
    • 2019-06-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2015-05-14
    • 1970-01-01
    相关资源
    最近更新 更多