您好,登錄后才能下訂單哦!
在C++中,使用Socket庫時,可能會遇到連接中斷的情況。為了處理這種情況,我們需要捕獲相應的異常并進行適當?shù)奶幚?。以下是一個簡單的示例,展示了如何使用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);
// 創(chuàng)建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");
}
// 監(jiān)聽連接
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;
}
在這個示例中,我們創(chuàng)建了一個簡單的TCP服務器,監(jiān)聽8080端口。當客戶端連接到服務器時,服務器會接收客戶端發(fā)送的數(shù)據(jù)。如果連接中斷,服務器會捕獲異常并輸出錯誤信息。
請注意,這個示例僅用于演示目的,實際應用中可能需要根據(jù)具體需求進行更復雜的錯誤處理和重連邏輯。
免責聲明:本站發(fā)布的內容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內容。