recvfrom()
是一個用于接收來自指定套接字上的數據報的函數,通常用于無連接的UDP協議
以下是一個簡單的示例,展示了如何在多線程環境中使用 recvfrom()
函數:
#include<iostream>
#include<thread>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <cstring>
const int BUFFER_SIZE = 1024;
const int PORT = 8080;
void receive_data(int sockfd) {
char buffer[BUFFER_SIZE];
struct sockaddr_in client_addr;
socklen_t client_addr_size = sizeof(client_addr);
while (true) {
ssize_t received = recvfrom(sockfd, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&client_addr, &client_addr_size);
if (received > 0) {
std::cout << "Received message from client: " << inet_ntoa(client_addr.sin_addr) << ":" << ntohs(client_addr.sin_port)<< std::endl;
std::cout << "Message: "<< buffer<< std::endl;
} else {
std::cerr << "Error receiving data"<< std::endl;
break;
}
}
}
int main() {
int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if (sockfd == -1) {
std::cerr << "Error creating socket"<< std::endl;
return 1;
}
struct sockaddr_in server_addr;
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(PORT);
if (bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
std::cerr << "Error binding socket"<< std::endl;
close(sockfd);
return 1;
}
// 創建一個線程來處理接收到的數據報
std::thread receiver_thread(receive_data, sockfd);
// 主線程可以執行其他任務,例如發送數據報或等待用戶輸入
// ...
// 等待接收線程完成
receiver_thread.join();
close(sockfd);
return 0;
}
這個示例中,我們創建了一個線程來處理接收到的數據報。主線程可以執行其他任務,例如發送數據報或等待用戶輸入。當主線程完成其任務時,它會等待接收線程完成,然后關閉套接字并退出程序。
請注意,這個示例僅用于演示目的,實際應用中可能需要根據需求進行更復雜的錯誤處理和資源管理。