当前位置： 首页 > news >正文

使用C++11的`std::future`和`std::promise`实现异步网络通信

news 2025/6/24 1:08:20

使用C++11的std::future和std::promise实现异步网络通信

在现代C++编程中，异步编程是一个重要的主题。C++11引入了std::future和std::promise，为异步编程提供了强大的工具。本文将详细介绍如何使用std::future和std::promise实现异步网络通信，并提供丰富的示例代码。

什么是std::future和std::promise？

std::future和std::promise是C++11标准库中的两个类，用于实现异步操作：

  • std::promise：用于设置一个值或异常，该值或异常可以在另一个线程中被获取。
  • std::future：用于获取由std::promise设置的值或异常。

通过std::promise和std::future，我们可以在一个线程中启动一个异步操作，并在另一个线程中等待其完成。

实现异步网络通信的步骤
  1. 创建Socket：使用socket函数创建一个Socket。
  2. 连接服务器：使用connect函数连接到服务器。
  3. 发送和接收消息：使用send和recv函数进行消息传递。
  4. 使用std::promise和std::future：在异步操作中使用std::promise和std::future来实现异步通信。
示例代码

以下是实现一个简单的异步TCP客户端的完整代码示例：

#include <iostream>
#include <cstring>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <future>const int PORT = 8080;
const int BUFFER_SIZE = 1024;std::string async_send_receive(const std::string& server_ip, const std::string& message) {// 创建Socketint client_socket = socket(AF_INET, SOCK_STREAM, 0);if (client_socket == -1) {throw std::runtime_error("Failed to create socket");}// 服务器地址sockaddr_in server_addr;std::memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(PORT);inet_pton(AF_INET, server_ip.c_str(), &server_addr.sin_addr);// 连接服务器if (connect(client_socket, (sockaddr*)&server_addr, sizeof(server_addr)) == -1) {close(client_socket);throw std::runtime_error("Failed to connect to server");}// 发送消息send(client_socket, message.c_str(), message.size(), 0);// 接收响应char buffer[BUFFER_SIZE];std::memset(buffer, 0, BUFFER_SIZE);int bytes_received = recv(client_socket, buffer, BUFFER_SIZE, 0);if (bytes_received < 0) {close(client_socket);throw std::runtime_error("Failed to receive response");}// 关闭连接close(client_socket);return std::string(buffer, bytes_received);
}int main() {std::string server_ip = "127.0.0.1";std::string message = "Hello, Server!";// 创建promise和futurestd::promise<std::string> promise;std::future<std::string> future = promise.get_future();// 启动异步任务std::thread([&promise, &server_ip, &message]() {try {std::string response = async_send_receive(server_ip, message);promise.set_value(response);} catch (const std::exception& e) {promise.set_exception(std::current_exception());}}).detach();// 等待并获取结果try {std::string response = future.get();std::cout << "Received response: " << response << std::endl;} catch (const std::exception& e) {std::cerr << "Error: " << e.what() << std::endl;}return 0;
}
代码解析

  1. 创建Socket：

    int client_socket = socket(AF_INET, SOCK_STREAM, 0);
if (client_socket == -1) {throw std::runtime_error("Failed to create socket");
}

    这行代码创建了一个TCP Socket。AF_INET表示使用IPv4地址，SOCK_STREAM表示使用TCP协议。

  2. 连接服务器：

    sockaddr_in server_addr;
std::memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
inet_pton(AF_INET, server_ip.c_str(), &server_addr.sin_addr);if (connect(client_socket, (sockaddr*)&server_addr, sizeof(server_addr)) == -1) {close(client_socket);throw std::runtime_error("Failed to connect to server");
}

    这段代码将客户端连接到指定的服务器地址和端口。

  3. 发送和接收消息：

    send(client_socket, message.c_str(), message.size(), 0);char buffer[BUFFER_SIZE];
std::memset(buffer, 0, BUFFER_SIZE);
int bytes_received = recv(client_socket, buffer, BUFFER_SIZE, 0);
if (bytes_received < 0) {close(client_socket);throw std::runtime_error("Failed to receive response");
}close(client_socket);return std::string(buffer, bytes_received);

    这段代码发送消息给服务器，然后等待接收服务器的响应。接收到响应后，关闭连接并返回响应内容。

  4. 使用std::promise和std::future：

    std::promise<std::string> promise;
std::future<std::string> future = promise.get_future();std::thread([&promise, &server_ip, &message]() {try {std::string response = async_send_receive(server_ip, message);promise.set_value(response);} catch (const std::exception& e) {promise.set_exception(std::current_exception());}
}).detach();try {std::string response = future.get();std::cout << "Received response: " << response << std::endl;
} catch (const std::exception& e) {std::cerr << "Error: " << e.what() << std::endl;
}

    这段代码创建了一个std::promise对象，并通过get_future方法获取对应的std::future对象。然后启动一个新线程，在新线程中执行异步任务，并将结果设置到std::promise中。主线程等待std::future获取结果，并处理异常。

进一步优化

虽然上述代码实现了一个基本的异步TCP客户端，但在实际应用中，我们可能需要进一步优化和扩展功能：

  1. 错误处理：添加更多的错误处理逻辑，处理各种可能的网络错误。
  2. 超时机制：实现超时机制，避免异步操作无限期等待。
  3. 多线程处理：使用线程池或异步I/O来提高并发性能。
  4. 数据序列化：使用数据序列化技术（如JSON或Protobuf）来传输复杂的数据结构。
超时机制示例

以下是一个实现超时机制的示例：

#include <iostream>
#include <cstring>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <future>
#include <chrono>const int PORT = 8080;
const int BUFFER_SIZE = 1024;std::string async_send_receive(const std::string& server_ip, const std::string& message) {// 创建Socketint client_socket = socket(AF_INET, SOCK_STREAM, 0);if (client_socket == -1) {throw std::runtime_error("Failed to create socket");}// 服务器地址sockaddr_in server_addr;std::memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(PORT);inet_pton(AF_INET, server_ip.c_str(), &server_addr.sin_addr);// 连接服务器if (connect(client_socket, (sockaddr*)&server_addr, sizeof(server_addr)) == -1) {close(client_socket);throw std::runtime_error("Failed to connect to server");}// 发送消息send(client_socket, message.c_str(), message.size(), 0);// 接收响应char buffer[BUFFER_SIZE];std::memset(buffer, 0, BUFFER_SIZE);int bytes_received = recv(client_socket, buffer, BUFFER_SIZE, 0);if (bytes_received < 0) {close(client_socket);throw std::runtime_error("Failed to receive response");}// 关闭连接close(client_socket);return std::string(buffer, bytes_received);
}int main() {std::string server_ip = "127.好的，我们继续。#### 超时机制示例（续）以下是一个实现超时机制的完整示例：```cpp
#include <iostream>
#include <cstring>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <future>
#include <chrono>const int PORT = 8080;
const int BUFFER_SIZE = 1024;std::string async_send_receive(const std::string& server_ip, const std::string& message) {// 创建Socketint client_socket = socket(AF_INET, SOCK_STREAM, 0);if (client_socket == -1) {throw std::runtime_error("Failed to create socket");}// 服务器地址sockaddr_in server_addr;std::memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(PORT);inet_pton(AF_INET, server_ip.c_str(), &server_addr.sin_addr);// 连接服务器if (connect(client_socket, (sockaddr*)&server_addr, sizeof(server_addr)) == -1) {close(client_socket);throw std::runtime_error("Failed to connect to server");}// 发送消息send(client_socket, message.c_str(), message.size(), 0);// 接收响应char buffer[BUFFER_SIZE];std::memset(buffer, 0, BUFFER_SIZE);int bytes_received = recv(client_socket, buffer, BUFFER_SIZE, 0);if (bytes_received < 0) {close(client_socket);throw std::runtime_error("Failed to receive response");}// 关闭连接close(client_socket);return std::string(buffer, bytes_received);
}int main() {std::string server_ip = "127.0.0.1";std::string message = "Hello, Server!";// 创建promise和futurestd::promise<std::string> promise;std::future<std::string> future = promise.get_future();// 启动异步任务std::thread([&promise, &server_ip, &message]() {try {std::string response = async_send_receive(server_ip, message);promise.set_value(response);} catch (const std::exception& e) {promise.set_exception(std::current_exception());}}).detach();// 等待并获取结果，设置超时时间为5秒if (future.wait_for(std::chrono::seconds(5)) == std::future_status::ready) {try {std::string response = future.get();std::cout << "Received response: " << response << std::endl;} catch (const std::exception& e) {std::cerr << "Error: " << e.what() << std::endl;}} else {std::cerr << "Request timed out" << std::endl;}return 0;
}

在这个示例中，我们使用std::future::wait_for方法设置了一个超时时间为5秒。如果在5秒内没有收到响应，程序将输出“Request timed out”。

总结

通过本文，我们详细介绍了如何使用C++11的std::future和std::promise实现异步网络通信。我们探讨了std::future和std::promise的基本概念、实现异步TCP客户端的具体步骤和代码，并展示了如何实现超时机制。

理解和掌握这些技术可以帮助你在异步编程和网络编程领域取得更大的进步。希望这篇文章能帮助你更好地理解和应用std::future和std::promise。如果你有任何问题或需要进一步的帮助，请随时联系我。Happy coding!

http://www.lryc.cn/news/435876.html

相关文章：

  • 【C++登堂入室】类与对象(上)
  • 【西电电装实习】5. 无人机模块及作用、上位机的操作
  • 有关WSL和docker的介绍
  • 以太坊入门
  • 秃姐学AI系列之：实战Kaggle比赛：狗的品种识别（ImageNet Dogs）
  • 图神经网络介绍3
  • 浅谈 React Fiber
  • Winform实现石头剪刀布小游戏
  • 计算机的错误计算（九十）
  • 对游戏语音软件Oopz遭遇DDoS攻击后的一些建议
  • 解锁Android开发利器：MVVM架构_android的mvvm
  • llama.cpp demo
  • OpenCV结构分析与形状描述符（19）查找二维点集的最小面积外接旋转矩形函数minAreaRect()的使用
  • [SWPU2019]Web1 超详细教程
  • 【区块链通用服务平台及组件】基于向量数据库与 LLM 的智能合约 Copilot
  • mfc140u.dll丢失有啥方法能够进行修复？分享几种mfc140u.dll丢失的解决办法
  • 【PyQt6 应用程序】在用户登录界面实现密码密文保存复用
  • 赋能百业：多模态处理技术与大模型架构下的AI解决方案落地实践
  • 游戏论坛网站|基于Springboot+vue的游戏论坛网站系统游戏分享网站(源码+数据库+文档)
  • 【go】pprof 性能分析
  • Python | Leetcode Python题解之第397题整数替换
  • JDBC使用
  • 633. 平方数之和-LeetCode(C++)
  • Linux shell编程学习笔记79：cpio命令——文件和目录归档工具（下）
  • 《 C++ 修炼全景指南：七 》优先级队列在行动：解密 C++ priority_queue 的实现与应用
  • 通信工程学习：什么是HSS归属用户服务器
  • mysql workbench 如何访问远程数据库
  • ICMAN触摸感应芯片方案
  • 面向个小微型企业的开源大模型(Qwen2等)商业化， AI部署成本分析与优化策略(费用分析、资源消耗分析)
  • pandas判断一列中存在nan值