套接字服务器以缓冲区大小接收数据
Socket server receiving data at buffer size
我一个接一个地发送不同大小的数据包,我怎么能按照我发送的大小分别接收数据包,而不是在缓冲区中累积。似乎现在服务器添加到缓冲区直到它填满,然后我可以处理它们。
示例:
Buffer size: 84.
Send from client: 84 bytes, 76 bytes, 76 bytes, 80 bytes
Receive in server: 84 bytes, 84 bytes, 84 bytes, 64 bytes.
我希望在发送它们时收到它们。可能吗?
int port = stoi(getConfig("server_port"));
std::string ipAddress = getConfig("ip_address");
// Create a socket
int listening = socket(AF_INET, SOCK_STREAM, 0);
if (listening < 0){
std::cerr << "Can't create a socket!" << endl;
Logger("Can't create a socket!");
exit(-1);
}
std::cout << "The socket server was created successfully." << endl;
// Bind the socket to a IP / port
sockaddr_in hint;
hint.sin_family = AF_INET;
hint.sin_port = htons(port);
inet_pton(AF_INET, ipAddress.c_str(), &hint.sin_addr);
if (bind(listening, (sockaddr*)&hint, sizeof(hint)) < 0){
cerr << "Can't bind to IP/port!" << endl;
Logger("Can't bind to IP/port!");
exit(-1);
}
// Mark the socket for listening in
if (listen(listening, SOMAXCONN) < 0){
cerr << "Can't listen!" << endl;
Logger("Can't listen!");
exit(-1);
}
// Accept a call
sockaddr_in client;
socklen_t clientSize = sizeof(client);
char host[NI_MAXHOST];
char svc[NI_MAXSERV];
while(true){
int clientSoket = accept(listening, (sockaddr*)&client, &clientSize);
if(clientSoket < 0){
cerr << "Problem with client connecting!" << endl;
Logger("Problem with client connecting!");
break;
}
cout << "The client whas conected successfully." << endl;
memset(host, 0, NI_MAXHOST);
memset(svc, 0, NI_MAXSERV);
int result = getnameinfo((sockaddr*)&client, clientSize, host, NI_MAXHOST, svc, NI_MAXSERV, 0);
if(result == 0) {
cout << host << " connected on " << svc << endl;
} else {
inet_ntop(AF_INET, &client.sin_addr, host, NI_MAXHOST);
cout << host << " connected on " << ntohs(client.sin_port) << endl;
}
// While receiving
char buff[84];
while(true){
// Clear the buffer
memset(buff, 0, sizeof(buff));
// Wait for a message
int bytesRecv = recv(clientSoket, buff, sizeof(buff), 0);
if(bytesRecv < 0){
cerr << "There was a connection issue!" << endl;
Logger("There was a connection issue!");
break;
}
if(bytesRecv == 0){
cout << "The client disconnected." << endl;
Logger("The client disconnected");
break;
}
cout << "bytesRecv: " << bytesRecv << endl;
}
// Close the socket
close(clientSoket);
}
不,流套接字不能那样工作。
流套接字是一种非结构化字节流,没有任何结构。在这方面,它与普通文件没有什么不同。如果您将不同大小的记录写入普通文件,现在您准备读回它们,您希望如何读取可变大小的记录?
无论您在此处给出哪个答案,相同的答案都适用于套接字,另外一个问题是套接字上的 read()
无法保证您将阅读多少内容,除了它'将小于或等于 size
参数到 read()
。这是您从 read()
.
获得的唯一保证
如果发件人两次调用 write()
(而且,顺便说一句,套接字也不能保证无论您想要多少 write
,都会写入多少,write
也可以 return 一个字节数小于或等于它的 size
参数,这取决于你的代码来弄清楚如何处理它),一次写 76 字节,第二次写 84, read()
在初始读取时(假设缓冲区大小足够大)可以读取 1 到 160 字节之间的任意数量的字节。
如果您希望实现某种形式化的结构、某种记录,则由您自行决定如何在这些限制条件下实现它。也许通过发送每条记录的大小(以字节为单位),然后是记录本身。或者为所欲为。请记住,您无法保证个人 read()
return 有多少。例如,如果您首先发送记录计数,作为一个四字节值。您的初始 read()
可能 return 一个、两个或三个字节。您的代码必须准备好处理任何可能发生的情况。
我一个接一个地发送不同大小的数据包,我怎么能按照我发送的大小分别接收数据包,而不是在缓冲区中累积。似乎现在服务器添加到缓冲区直到它填满,然后我可以处理它们。
示例:
Buffer size: 84.
Send from client: 84 bytes, 76 bytes, 76 bytes, 80 bytes
Receive in server: 84 bytes, 84 bytes, 84 bytes, 64 bytes.
我希望在发送它们时收到它们。可能吗?
int port = stoi(getConfig("server_port"));
std::string ipAddress = getConfig("ip_address");
// Create a socket
int listening = socket(AF_INET, SOCK_STREAM, 0);
if (listening < 0){
std::cerr << "Can't create a socket!" << endl;
Logger("Can't create a socket!");
exit(-1);
}
std::cout << "The socket server was created successfully." << endl;
// Bind the socket to a IP / port
sockaddr_in hint;
hint.sin_family = AF_INET;
hint.sin_port = htons(port);
inet_pton(AF_INET, ipAddress.c_str(), &hint.sin_addr);
if (bind(listening, (sockaddr*)&hint, sizeof(hint)) < 0){
cerr << "Can't bind to IP/port!" << endl;
Logger("Can't bind to IP/port!");
exit(-1);
}
// Mark the socket for listening in
if (listen(listening, SOMAXCONN) < 0){
cerr << "Can't listen!" << endl;
Logger("Can't listen!");
exit(-1);
}
// Accept a call
sockaddr_in client;
socklen_t clientSize = sizeof(client);
char host[NI_MAXHOST];
char svc[NI_MAXSERV];
while(true){
int clientSoket = accept(listening, (sockaddr*)&client, &clientSize);
if(clientSoket < 0){
cerr << "Problem with client connecting!" << endl;
Logger("Problem with client connecting!");
break;
}
cout << "The client whas conected successfully." << endl;
memset(host, 0, NI_MAXHOST);
memset(svc, 0, NI_MAXSERV);
int result = getnameinfo((sockaddr*)&client, clientSize, host, NI_MAXHOST, svc, NI_MAXSERV, 0);
if(result == 0) {
cout << host << " connected on " << svc << endl;
} else {
inet_ntop(AF_INET, &client.sin_addr, host, NI_MAXHOST);
cout << host << " connected on " << ntohs(client.sin_port) << endl;
}
// While receiving
char buff[84];
while(true){
// Clear the buffer
memset(buff, 0, sizeof(buff));
// Wait for a message
int bytesRecv = recv(clientSoket, buff, sizeof(buff), 0);
if(bytesRecv < 0){
cerr << "There was a connection issue!" << endl;
Logger("There was a connection issue!");
break;
}
if(bytesRecv == 0){
cout << "The client disconnected." << endl;
Logger("The client disconnected");
break;
}
cout << "bytesRecv: " << bytesRecv << endl;
}
// Close the socket
close(clientSoket);
}
不,流套接字不能那样工作。
流套接字是一种非结构化字节流,没有任何结构。在这方面,它与普通文件没有什么不同。如果您将不同大小的记录写入普通文件,现在您准备读回它们,您希望如何读取可变大小的记录?
无论您在此处给出哪个答案,相同的答案都适用于套接字,另外一个问题是套接字上的 read()
无法保证您将阅读多少内容,除了它'将小于或等于 size
参数到 read()
。这是您从 read()
.
如果发件人两次调用 write()
(而且,顺便说一句,套接字也不能保证无论您想要多少 write
,都会写入多少,write
也可以 return 一个字节数小于或等于它的 size
参数,这取决于你的代码来弄清楚如何处理它),一次写 76 字节,第二次写 84, read()
在初始读取时(假设缓冲区大小足够大)可以读取 1 到 160 字节之间的任意数量的字节。
如果您希望实现某种形式化的结构、某种记录,则由您自行决定如何在这些限制条件下实现它。也许通过发送每条记录的大小(以字节为单位),然后是记录本身。或者为所欲为。请记住,您无法保证个人 read()
return 有多少。例如,如果您首先发送记录计数,作为一个四字节值。您的初始 read()
可能 return 一个、两个或三个字节。您的代码必须准备好处理任何可能发生的情况。