c++ 套接字关闭第一次连接尝试
c++ socket closing the first connection attempt
我正在尝试使用 <sys/socket.h>
和 Qt Creator gui builder 在 c++ 中制作一个服务器示例,但是在程序的套接字层出现了两个奇怪的行为。首先,我 运行 服务器,但在我第一次尝试使用 telnet
连接到它时立即关闭
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
Connection closed by foreign host.
当我第二次尝试连接时,它成功了,终端等待我的输入。第二件事是当我关闭连接时。如果我在 运行 之后立即重新 运行,几分钟后,程序将停止 bind
退出并返回:
ERROR on binding: Address already in use
所以我想在我使用函数调用 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();
}
套接字class:
#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 是 telnet 和我的 Qt Server 应用程序之间通信的数据包列表,它可以在 WireShark(.pcapng 文件)中以图形方式看到。它包含 11 个帧。前 6 个来自第一个 telnet,当它立即关闭时。正如在第 4 帧和第 5 帧中显示的那样,应用程序发送 [FIN, ACK]
并且服务器通过关闭连接来响应它。第 7、8、9 帧是第二次尝试连接,而第 10 和 11 帧是我将 abc
发送到服务器时。如打印屏幕所示:
问题是我不知道为什么应用程序要发送这个 FIN
以及它在代码中的什么位置。
将 SO_REUSEADDR
与 setsockopt
一起使用:
optval = 1;
setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof optval);
这允许端口被其他套接字重复使用并解决您面临的 address already in use
问题。
这是我发现的第一个严重问题:
n = read(newsockfd,buffer,SERVER_BUFFER-1);
if (n < 0)
error("ERROR reading from socket");
printf("Here is the message: %s",buffer);
没有对 read
返回零的处理。 %s
格式说明符仅适用于字符串。您不能将它用于任意的、未经检查的数据。
在 unix 操作系统上,系统调用有时会失败,错误号设置为 EINTR。这意味着信号已传递到中断系统调用的进程,您应该重试。尝试这样的事情:
while ((n = read(newsockfd,buffer,SERVER_BUFFER-1) < 0) {
if (errno != EINTR)
break;
}
if (n < 0)
error("ERROR reading from socket");
对 write 的调用也应该这样做。
前面的回答已经说明了如何正确处理read以及如何使用SO_RESUEADDR。
我想指出为什么你的程序只能收到一条消息。因为你的运行函数没有循环,所以只能执行一次,然后线程退出。接受客户端的请求后,连接建立,然后你应该进入一个循环等待客户端的输入,并在读取函数returns后将它们写回。
我正在尝试使用 <sys/socket.h>
和 Qt Creator gui builder 在 c++ 中制作一个服务器示例,但是在程序的套接字层出现了两个奇怪的行为。首先,我 运行 服务器,但在我第一次尝试使用 telnet
连接到它时立即关闭
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
Connection closed by foreign host.
当我第二次尝试连接时,它成功了,终端等待我的输入。第二件事是当我关闭连接时。如果我在 运行 之后立即重新 运行,几分钟后,程序将停止 bind
退出并返回:
ERROR on binding: Address already in use
所以我想在我使用函数调用 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();
}
套接字class:
#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 是 telnet 和我的 Qt Server 应用程序之间通信的数据包列表,它可以在 WireShark(.pcapng 文件)中以图形方式看到。它包含 11 个帧。前 6 个来自第一个 telnet,当它立即关闭时。正如在第 4 帧和第 5 帧中显示的那样,应用程序发送 [FIN, ACK]
并且服务器通过关闭连接来响应它。第 7、8、9 帧是第二次尝试连接,而第 10 和 11 帧是我将 abc
发送到服务器时。如打印屏幕所示:
问题是我不知道为什么应用程序要发送这个 FIN
以及它在代码中的什么位置。
将 SO_REUSEADDR
与 setsockopt
一起使用:
optval = 1;
setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof optval);
这允许端口被其他套接字重复使用并解决您面临的 address already in use
问题。
这是我发现的第一个严重问题:
n = read(newsockfd,buffer,SERVER_BUFFER-1);
if (n < 0)
error("ERROR reading from socket");
printf("Here is the message: %s",buffer);
没有对 read
返回零的处理。 %s
格式说明符仅适用于字符串。您不能将它用于任意的、未经检查的数据。
在 unix 操作系统上,系统调用有时会失败,错误号设置为 EINTR。这意味着信号已传递到中断系统调用的进程,您应该重试。尝试这样的事情:
while ((n = read(newsockfd,buffer,SERVER_BUFFER-1) < 0) {
if (errno != EINTR)
break;
}
if (n < 0)
error("ERROR reading from socket");
对 write 的调用也应该这样做。
前面的回答已经说明了如何正确处理read以及如何使用SO_RESUEADDR。 我想指出为什么你的程序只能收到一条消息。因为你的运行函数没有循环,所以只能执行一次,然后线程退出。接受客户端的请求后,连接建立,然后你应该进入一个循环等待客户端的输入,并在读取函数returns后将它们写回。