Telnet连接我的套接字监听端口时关闭了套接字。

Question

Telnet连接我的套接字监听端口时关闭了套接字。

3

我是这个网站的新手，如果此问题以前已经有答案，请提前谅解。虽然在向这里的每个人寻求帮助之前，我已经搜索过了。

我正在使用socket编程，在我的C程序中实现。它具有服务器和客户端模块，其中服务器和客户端可以双向通信。由于我能够发送文件和消息，因此程序运行良好。我的服务器程序正在使用端口3873，我已经通过netstat -anp | grep 3873进行了确认。



我观察到一种奇怪的套接字行为，特别是当我尝试使用浏览器（例如http://localhost:3873）或telnet localhost 3873连接套接字时。它立即关闭套接字，并且随后的“netstat -anp | grep 3873”输出确认本地主机不再侦听端口3873。

我真的很感激如果有人能够解释这种行为。这是预期的行为吗？

以下是来自服务器代码的相关部分：主程序启动一个专用线程，并调用startFileServerMT，其随后调用handleClient来服务于连接到套接字的每个客户端。

int handleClient(void *ptr){
    DEBUG("Inside the %s %s() \n",__FILE__,__func__);
    int  connectSOCKET;
    connectSOCKET = (int ) ptr;
    char recvBUFF[4096],sendBUFF[4096];
    char *filename;
    FILE * recvFILE;
    char *header[4096];    
    while(1){
        if( recv(connectSOCKET, recvBUFF, sizeof(recvBUFF), 0) > 0){
            if(!strncmp(recvBUFF,"FBEGIN",6)) {                          
                recvBUFF[strlen(recvBUFF) - 2] = 0;
                parseArgs(header,recvBUFF);                                 
                filename = (char*) strngDup(header[1]);                                
                DEBUG("  About to receive file: %s\n", filename);
            }

            char *rfile = ALLOC(sizeof(char) * (strlen(This.uploadDIR) + strlen(filename) + 35));
            strcpy(rfile,This.uploadDIR);

            if (strngLastChar(rfile) == '/'){
                strcat(rfile,filename);
            }else{
                strcat(rfile,"/");
                strcat(rfile,filename);        
            }
            DEBUG("  Absolute file is : %s\n", rfile);
            recvBUFF[0] = 0;
            if ((recvFILE = fopen (rfile,"w" )) == NULL){
                LogError("Server could not create file %s on the shared location %s.\n",filename,This.uploadDIR);                
            }else{
                bzero(recvBUFF,4096);
                int fr_block_sz, write_sz;
                while((fr_block_sz = recv(connectSOCKET, recvBUFF, 512, 0)) > 0 ){
                    write_sz = fwrite (recvBUFF , sizeof(recvBUFF[0]) , fr_block_sz , recvFILE );
                    DEBUG("  Received buffer is : %s\n", recvBUFF);
                    if(write_sz < fr_block_sz){
                        LogError("Failed writing file %s on the Server shared location.\n",filename);
                        break;
                    }
                    bzero(recvBUFF,4096);
                    recvBUFF[0] = 0;
                    if(write_sz == 0 || fr_block_sz != 512 ){   
                        break;
                    }
                }

                if(fr_block_sz < 0){
                    if(errno == EAGAIN){
                        LogError("Server collection file %s receive timed out.\n",filename);
                    }else{
                        LogError("Failed file %s transfer due to error %d\n",filename,errno);
                        fclose(recvFILE);
                        FREE(rfile);
                        // Start - Following code send failed status to client    
                        sprintf(sendBUFF,"FSTATUS:FAILED\r\n");    

                        if (send(connectSOCKET, sendBUFF, sizeof(sendBUFF), 0) >= 0){
                            DEBUG("File transfer status for file %s sent\n",filename);
                        }else{
                            DEBUG("Failed sending transfer status for file %s\n",filename);
                            return FALSE;
                        } 

                        // End

                        close(connectSOCKET);
                        return FALSE;
                    }
                }
                    DEBUG("File %s received on OM Server successfully.\n",filename);

                    // Start - Following code send failed status to client    
                    sprintf(sendBUFF,"FSTATUS:SUCCESS\r\n");    

                    if (send(connectSOCKET, sendBUFF, sizeof(sendBUFF), 0) >= 0){
                        DEBUG("File transfer status for file %s sent\n",filename);
                    }else{
                        DEBUG("Failed sending transfer status for file %s\n",filename);
                        return FALSE;
                    } 
                    // End

                    fclose(recvFILE);
                    updateTargets(rfile);
                    FREE(rfile);
                    close(connectSOCKET);
                    break;

            }
        }
        else {
            LogInfo("Client dropped connection\n");
        }

/** End*/  
        return TRUE;
    }    
}

int startFileServerMT(){
    DEBUG("Inside %s %s() \n",__FILE__,__func__);

    int listenSOCKET, connectSOCKET[512],thread_status;
    int socketINDEX = 0;

    pthread_t clientFileThread[512];
    socklen_t clientADDRESSLENGTH[512];
    struct sockaddr_in clientADDRESS[512], serverADDRESS;    


    if((listenSOCKET = socket(AF_INET, SOCK_STREAM, 0)) < 0 ){
        LogAbortError("File server could not create socket.\n");
        close(listenSOCKET);
        return FALSE;        
    }

    serverADDRESS.sin_family = AF_INET;
    serverADDRESS.sin_addr.s_addr = htonl(INADDR_ANY);  
    serverADDRESS.sin_port = htons(This.serverport);

    if (bind(listenSOCKET, (struct sockaddr *) &serverADDRESS, sizeof(serverADDRESS)) < 0) {
        LogAbortError("File server could not bind socket and will stop server now.\n");
        close(listenSOCKET);
        This.stopped = TRUE;
        return FALSE;
    }

    if(listen(listenSOCKET, 5) == -1){
        LogAbortError("Server failed to listen on port %d and will stop server now.\n",This.serverport);
        close(listenSOCKET);
        This.stopped = TRUE;
        return FALSE;        
    }else{
        LogInfo("Server listening on port %d successfully.\n",This.serverport);        
    }

    clientADDRESSLENGTH[socketINDEX] = sizeof(clientADDRESS[socketINDEX]);

    while(TRUE){   
       // DEBUG("  Inside the file server main loop index[%d].\n",socketINDEX);

        connectSOCKET[socketINDEX] = accept(listenSOCKET, (struct sockaddr *) &clientADDRESS[socketINDEX], &clientADDRESSLENGTH[socketINDEX]);
            if(connectSOCKET[socketINDEX] < 0){
            LogError("Server could not accept connection.\n");
            close(listenSOCKET);
            return FALSE;
        }else
            DEBUG("  Another client connected to server socket.\n");

        ThreadCreateDetached( &clientFileThread[socketINDEX], handleClient, connectSOCKET[socketINDEX]);     

        if(socketINDEX=512) {
            socketINDEX = 0;
        } else { 
            socketINDEX++;
        }                                  

        if (This.stopped == TRUE){
            close(listenSOCKET);
            return TRUE;
        }      
/** End*/  
//        return TRUE;
    }

    close(listenSOCKET);
    return TRUE;

}

- user1996785

4

听起来你的服务器程序正在崩溃。你检查过服务器发生了什么事情吗？ - Some programmer dude

他希望我们在不公开源代码的情况下调试他的服务器代码... Joachim已经猜得很准了;-) - rockdaboot

请查看我之前上传的关于C语言快速网络编程的教程，或许可以帮到你。链接为http://www.scribd.com/doc/120274805/QGNP 希望对你有所帮助 :) - Afonso Tsukamoto

1

HTTP和Telnet协议通过连接发送数据，而您的代码可能不支持此类数据。您需要对代码进行验证，以防止这种未被识别的数据（例如，通过丢弃它并记录错误）。 - Sander De Dycker

1

recvBUFF[strlen(recvBUFF) - 2] = 0; 让我感到不安。我知道在使用缓冲区之前代码会加载memset/bzero，但这不是最好的方法。请使用您从read() write() recv() send()获得的返回值。 - wildplasser

显示剩余2条评论

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Nik Bougalis · Answer 1

这是你的问题 - 或者至少是你问题的一部分。它不仅仅是一个 off-by-one 错误（connectSOCKET 接受从 0-511 包括的索引，所以如果你在 512，你已经写过 connectSOCKET 数组的末尾），而且你做了一个赋值而不是比较：

    if(socketINDEX=512) { // Error: you are *setting* socketINDEX to 512, 
                          // then immediately *resetting* it back to 0. So
                          // every new connection overrides the existing
                          // socket.
        socketINDEX = 0;
    } else { 
        socketINDEX++;
    }

另外需要注意的是，你真的应该重构你的代码并尝试清理它。