#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <unistd.h>
#include <arpa/inet.h>
#include <Sys/socket.h>
const int BUF_SIZE = 1024;
void error_handling(const char *message);
int main(int argc, char *argv[]) {
int server_socket;
int client_sock;
char message[BUF_SIZE];
ssize_t str_len;
int i;
struct sockaddr_in server_addr;
struct sockaddr_in client_addr;
socklen_t client_addr_size;
if (argc != 2) {
printf("Usage: %s <port>n", argv[0]);
exit(1);
}
server_socket = socket(PF_INET, SOCK_STREAM, 0);
if (server_socket == -1) {
error_handling("socket() error");
}
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
server_addr.sin_port = htons(atoi(argv[1]));
if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(sockaddr)) == -1) {
error_handling("bind() error");
}
if (listen(server_socket, 5) == -1) {
error_handling("listen() error");
}
client_addr_size = sizeof(client_addr);
for (i = 0; i < 5; ++i) {
client_sock = accept(server_socket, (struct sockaddr*)&client_addr, &client_addr_size);
if (client_sock == -1) {
error_handling("accept() error");
} else {
printf("Connect client %dn", i + 1);
}
while ((str_len = read(client_sock, message, BUF_SIZE)) != 0) {
write(client_sock, message, (size_t)str_len);
message[str_len] = ' ';
printf("client %d: message %s", i + 1, message);
}
}
close(client_sock);
printf("echo servern");
return 0;
}
客户端代码
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>
const int BUF_SIZE = 1024;
void error_handling(const char *message);
int main(int argc, char *argv[]) {
int sock;
struct sockaddr_in server_addr;
char message[BUF_SIZE];
ssize_t str_len;
if (argc != 3) {
printf("Usage : %s <IP> <port>n", argv[0]);
exit(1);
}
sock = socket(PF_INET, SOCK_STREAM, 0);
if (sock == -1) {
error_handling("socket() error");
}
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = inet_addr(argv[1]);
server_addr.sin_port = htons(atoi(argv[2]));
if (connect(sock, (struct sockaddr*)&server_addr, sizeof(server_addr)) == -1) {
error_handling("connect() error");
} else {
printf("Connect...");
}
while (1) {
printf("Input message( Q to quit ): ");
fgets(message, BUF_SIZE, stdin);
if (!strcmp(message, "qn") || !strcmp(message, "Qn")) {
break;
}
write(sock, message, strlen(message));
str_len = read(sock, message, BUF_SIZE);
message[str_len] = 0;
printf("Message from server: %s n", message);
}
close(sock);
return 0;
}
不足
客户端传输数据,通过调用write函数一次性发送,之后调用一次read函数,期望接收自己传输的数据。只是问题所在。因为“TCP不存在数据边界”,存在两个异常情况:
- 客户端多次调用write函数传输的数据有可能一次性发送给服务器。
- 服务器调用一次write函数传输数据,但数据太大,操作系统有可能把数据分成多个数据包发送到客户端。另外,在此过程中,客户端有可能在尚未收到全部数据包时就调用了read函数。
项目代码
github
参考
《TCP/IP网络编程》
脚本宝典总结
以上是脚本宝典为你收集整理的C++回声服务器_1-简单版本全部内容,希望文章能够帮你解决C++回声服务器_1-简单版本所遇到的问题。
如果觉得脚本宝典网站内容还不错,欢迎将脚本宝典推荐好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。