在C++中,使用Socket库时,可能会遇到连接中断的情况。为了处理这种情况,我们需要捕获相应的异常并进行适当的处理。以下是一个简单的示例,展示了如何使用C++ Socket库处理连接中断:
#include <iostream>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdexcept>
int main() {
int server_fd, client_fd;
struct sockaddr_in server_addr, client_addr;
socklen_t client_addr_len = sizeof(client_addr);
// 创建socket
if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
throw std::runtime_error("socket failed");
}
// 配置服务器地址
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(8080);
// 绑定socket
if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
throw std::runtime_error("bind failed");
}
// 监听连接
if (listen(server_fd, 3) < 0) {
throw std::runtime_error("listen");
}
std::cout << "Server is listening on port 8080" << std::endl;
// 接受客户端连接
if ((client_fd = accept(server_fd, (struct sockaddr *)&client_addr, (socklen_t *)&client_addr_len)) < 0) {
throw std::runtime_error("accept");
}
std::cout << "Client connected with IP: " << inet_ntoa(client_addr.sin_addr) << ", port: " << ntohs(client_addr.sin_port) << std::endl;
// 处理连接中断
try {
char buffer[1024];
while (true) {
ssize_t recv_len = recv(client_fd, buffer, sizeof(buffer) - 1, 0);
if (recv_len <= 0) {
throw std::runtime_error("recv");
}
buffer[recv_len] = '\0';
std::cout << "Received from client: " << buffer << std::endl;
}
} catch (const std::runtime_error &e) {
std::cerr << "Error: " << e.what() << std::endl;
}
// 关闭socket
close(client_fd);
close(server_fd);
return 0;
}
在这个示例中,我们创建了一个简单的TCP服务器,监听8080端口。当客户端连接到服务器时,服务器会接收客户端发送的数据。如果连接中断,服务器会捕获异常并输出错误信息。
请注意,这个示例仅用于演示目的,实际应用中可能需要根据具体需求进行更复杂的错误处理和重连逻辑。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。