2016-08-14 99 views
5

我正在尝试使用<sys/socket.h>和Qt Creator GUI构建器在C++中创建一个服务器示例,但是在程序的套接字层发生了两个奇怪的行为。首先,我运行服务器,但在第一次尝试我做连接它用telnet到被imediately关闭关闭第一次连接尝试的C++套接字

试图127.0.0.1 ...
连接到127.0.0.1。
转义字符是'^]'。
由外国主机关闭的连接。

当我尝试第二次连接,它的工作原理和终端等待我的输入。第二件事是当我关闭连接时。如果我之后重新运行,在短短的几分钟内,程序上bind暂停退出并返回:

错误的绑定:地址已在使用中

,所以我想,也许是正在举行的连接在我使用函数调用onCortarConexao()或者只是停止调试器来分解它之后。无论如何,我错过了什么?

我的代码:

#include "mainwindow.h" 
#include <QApplication> 

int main(int argc, char *argv[]) 
{ 
    QApplication a(argc, argv); 
    MainWindow w; 
    w.show(); 
    return a.exec(); 
} 

在MainWindow.cpp:

void MainWindow::on_pushButton_clicked() 
{ 
    socket1 = new MSocket(); 
    socket1->start(); 
} 
void MainWindow::on_pushButton_3_clicked() 
{ 
    socket1->onCortarConexao(); 
} 

Socket类:

#ifndef MSOCKET_H 
#define MSOCKET_H 
#include <QString> 
#include <QObject> 
#include <QThread> 
#include <QList> 
#include <string.h> 
#include <stdio.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
#include <netinet/in.h> 
#include <unistd.h> 
#define SERVER_BUFFER 4096 
#define PORTRUN 15000 


class MSocket : public QThread 
{ 
public: 
    MSocket(); 
    void error(char *msg); 
    void onCortarConexao(); 

private: 
    int sockfd; 
    int newsockfd; 
    int portno; 
    int clilen; 
    int n; 
    char buffer[SERVER_BUFFER]; 
    struct sockaddr_in serv_addr, cli_addr; 
    u_short port; 
    void run(); 
}; 

#endif // MSOCKET_H 

套接字实现:

void MSocket::run() 
{ 
sockfd = socket(AF_INET, SOCK_STREAM, 0); 

if (sockfd < 0){ 
    error("ERROR opening socket"); 
    exit(-1); 
} 
bzero((char *) &serv_addr, sizeof(serv_addr)); 

portno = PORTRUN; 
serv_addr.sin_family = AF_INET; 
serv_addr.sin_port = htons(portno); 
serv_addr.sin_addr.s_addr = INADDR_ANY; 

fprintf(stdout,"Iniciando servidor.."); 
if (bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0){ 

    error("ERROR on binding"); 
    exit(-1); 
} 
listen(sockfd,5); 

newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, (socklen_t*) sizeof(cli_addr)); 
if (newsockfd < 0){ 
    error("ERROR on accept"); 
    exit(-1); 
} 

bzero(buffer,SERVER_BUFFER); 
n = read(newsockfd,buffer,SERVER_BUFFER-1); 
if (n < 0) 
    error("ERROR reading from socket"); 

printf("Here is the message: %s",buffer); 

n = write(newsockfd,"I got your message",18); 
if (n < 0) 
    error("ERROR writing to socket"); 




} 

void MSocket::onCortarConexao(){ 
    printf("Encerrando socket"); 
    close(newsockfd); 
    close(sockfd); 

} 

完整的代码为:https://github.com/FabioNevesRezende/BasicCppServer

编辑1:

所以,this是可以graphicaly看到Wireshark的 telnet和我的Qt服务器应用程序之间的通信包的列表( .pcapng文件)。它包含11个帧。 6个第一个来自第一个远程登录,当它被立即关闭时。正如在框架4和5上,应用程序发送[FIN, ACK],服务器通过关闭连接来响应它。帧7,8,9是连接的第二次尝试,帧10和11是我发送abc到服务器的时间。由于在打印屏幕:

sequence of commands

问题是我不知道为什么应用程序在它的代码发送此FIN和地点。

+0

您为github项目提供的链接已损坏。没有它,我不能告诉你是什么意思第二次尝试只是在客户端再次尝试或重新启动服务器。你能澄清吗? – lasaro

+0

对不起,它再次打开。 – Fabiotk

回答

4

使用SO_REUSEADDRsetsockopt

optval = 1; 
setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof optval); 

这使得端口被其他插座被重用并围绕你所面临的问题address already in use得到。

+0

谢谢,它解决了第二个问题。 – Fabiotk

+1

您可能想解释为什么这会使未来的访问者成为一个很好的Q + A。 –

3

这里的第一个严重的问题,我发现:

n = read(newsockfd,buffer,SERVER_BUFFER-1); 
if (n < 0) 
    error("ERROR reading from socket"); 

printf("Here is the message: %s",buffer); 

有没有处理的read返回零。 %s格式说明符仅适用于字符串。您不能将其用于任意未经检查的数据。

3

在unix操作系统上,系统调用有时可能会失败,并将错误号设置为EINTR。这意味着一个信号被传送到中断系统调用的进程,并且应该重试。试试这样:

while ((n = read(newsockfd,buffer,SERVER_BUFFER-1) < 0) { 
if (errno != EINTR) 
break; 
} 
if (n < 0) 
    error("ERROR reading from socket"); 

对于写入的调用应该做同样的事情。

5

以前的答案表明如何正确处理读取以及如何使用SO_RESUEADDR。 我想指出你的程序为什么只能收到一条消息。因为你的run函数没有循环,所以它只能执行一次,然后线程退出。在接受客户端请求后,建立连接,然后进入一个循环等待客户端的输入,并在读取函数返回后写回。

+0

好点。我完全错过了。 –

相关问题