学懂C++（四十一）：网络编程——深入详解 C++ 网络编程之 WebSocket 应用技术

2024-08-22 17:28
文章标签 c++ 编程 学懂 网络 websocket 四十一 详解 深入 应用 技术

本文主要是介绍学懂C++（四十一）：网络编程——深入详解 C++ 网络编程之 WebSocket 应用技术，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

一、引言

二、WebSocket 概念

1. WebSocket 概述

2. WebSocket 协议

WebSocket 握手请求示例

三、WebSocket 工作原理

四、WebSocket 的实现方式

1. 准备工作

2. WebSocket 服务器实现

服务器代码

3. WebSocket 客户端实现

客户端代码

五、总结

一、引言

        在现代互联网应用中，即时通信、实时数据传输和交互变得越来越重要。传统的 HTTP 协议由于其无状态和请求/响应模型的限制，难以满足这类需求。WebSocket 协议应运而生，提供了持久的双向通信通道。本文将深入解析 WebSocket 的概念、工作原理及其在 C++ 中的实现，并结合经典实例进行讲解。

二、WebSocket 概念
1. WebSocket 概述

        WebSocket 是一种全双工的通信协议，设计用于在 Web 浏览器和服务器之间进行实时、低延迟的双向通信。相较于传统的 HTTP 协议，WebSocket 协议具有以下几个显著特点：

  • 持久连接：一旦连接建立，客户端和服务器之间可以持续通信，避免了频繁的连接建立和关闭过程。
  • 低开销：减少了 HTTP 请求/响应头部的开销，适合高频率数据交换。
  • 双向通信：允许客户端和服务器随时发送数据，支持实时应用场景。
2. WebSocket 协议

        WebSocket 协议通过 HTTP/1.1 协议进行初始握手，然后升级到 WebSocket 协议。握手成功后，通信双方可以通过 TCP 连接进行双向数据传输。

WebSocket 握手请求示例
GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
Sec-WebSocket-Version: 13

WebSocket 握手响应示例

HTTP/1.1 101 Switching Protocols
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=
三、WebSocket 工作原理

WebSocket 的工作流程主要包括以下几个步骤：

  1. 建立连接：客户端发起 HTTP 请求，包含特定的头部字段，用于请求将连接升级为 WebSocket 协议。
  2. 协议升级：服务器接收到请求后，返回相应的头部字段，确认升级为 WebSocket 协议。
  3. 数据传输：建立 WebSocket 连接后，客户端和服务器可以通过该连接进行双向数据传输，数据帧以二进制或文本格式传输。
  4. 关闭连接：任意一方可以随时关闭连接。
四、WebSocket 的实现方式

        WebSocket 的实现方式可以分为客户端和服务器两部分。在 C++ 中，可以使用开源的 WebSocket 库（如 libwebsockets、Boost.Beast）进行实现。本文将使用 Boost.Asio 和 Boost.Beast 库来实现 WebSocket 客户端和服务器。

1. 准备工作

在开始编写代码之前，请确保已经安装了 Boost 库。可以从 Boost 官方网站下载并安装。

在 Linux 上

在基于 Debian 的系统（如 Ubuntu）上，可以使用以下命令安装 Boost 库：

sudo apt-get update sudo apt-get install libboost-all-dev
在 Windows 上

在 Windows 上，可以使用 vcpkg 或从 Boost 官网下载源码并手动编译安装。以下是使用 vcpkg 的示例：

  1. 下载并安装 vcpkg。
  2. 使用 vcpkg 安装 Boost 库：
vcpkg install boost-asio boost-beast
2. WebSocket 服务器实现
服务器代码
#include <boost/beast/core.hpp>
#include <boost/beast/websocket.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <cstdlib>
#include <iostream>
#include <memory>
#include <string>
#include <thread>namespace beast = boost::beast;         // from <boost/beast.hpp>
namespace http = beast::http;           // from <boost/beast/http.hpp>
namespace websocket = beast::websocket; // from <boost/beast/websocket.hpp>
namespace net = boost::asio;            // from <boost/asio.hpp>
using tcp = net::ip::tcp;               // from <boost/asio/ip/tcp.hpp>// 会话类
class session : public std::enable_shared_from_this<session> {websocket::stream<beast::tcp_stream> ws_;beast::flat_buffer buffer_;public:explicit session(tcp::socket socket): ws_(std::move(socket)) {}// 启动异步操作void run() {// 执行 WebSocket 握手ws_.async_accept(beast::bind_front_handler(&session::on_accept, shared_from_this()));}private:// WebSocket 握手的回调函数void on_accept(beast::error_code ec) {if (ec) {std::cerr << "accept: " << ec.message() << std::endl;return;}// 读取消息do_read();}// 读取消息void do_read() {ws_.async_read(buffer_, beast::bind_front_handler(&session::on_read, shared_from_this()));}// 读取消息后的回调函数void on_read(beast::error_code ec, std::size_t bytes_transferred) {if (ec == websocket::error::closed) {return;}if (ec) {std::cerr << "read: " << ec.message() << std::endl;return;}std::cout << "Received: " << beast::make_printable(buffer_.data()) << std::endl;buffer_.consume(buffer_.size()); // 清空缓冲区// 回应消息ws_.text(ws_.got_text());ws_.async_write(boost::asio::buffer("Echo: Hello from server"), beast::bind_front_handler(&session::on_write, shared_from_this()));}// 写消息后的回调函数void on_write(beast::error_code ec, std::size_t bytes_transferred) {if (ec) {std::cerr << "write: " << ec.message() << std::endl;return;}// 继续读取消息do_read();}
};// 监听器类
class listener : public std::enable_shared_from_this<listener> {net::io_context& ioc_;tcp::acceptor acceptor_;public:listener(net::io_context& ioc, tcp::endpoint endpoint) : ioc_(ioc), acceptor_(net::make_strand(ioc)) {beast::error_code ec;// 打开接收器acceptor_.open(endpoint.protocol(), ec);if (ec) {std::cerr << "open: " << ec.message() << std::endl;return;}// 绑定到端点acceptor_.bind(endpoint, ec);if (ec) {std::cerr << "bind: " << ec.message() << std::endl;return;}// 开始监听acceptor_.listen(net::socket_base::max_listen_connections, ec);if (ec) {std::cerr << "listen: " << ec.message() << std::endl;return;}}// 启动异步接受操作void run() {do_accept();}private:// 异步接受操作void do_accept() {acceptor_.async_accept(net::make_strand(ioc_), beast::bind_front_handler(&listener::on_accept, shared_from_this()));}// 接受连接后的回调函数void on_accept(beast::error_code ec, tcp::socket socket) {if (ec) {std::cerr << "accept: " << ec.message() << std::endl;} else {// 创建 WebSocket 会话std::make_shared<session>(std::move(socket))->run();}// 继续接受连接do_accept();}
};int main(int argc, char* argv[]) {try {if (argc != 2) {std::cerr << "Usage: websocket-server <port>\n";return EXIT_FAILURE;}// 解析命令行参数auto const port = static_cast<unsigned short>(std::atoi(argv[1]));// 创建 io_contextnet::io_context ioc{1};// 创建并启动监听器std::make_shared<listener>(ioc, tcp::endpoint{tcp::v4(), port})->run();// 运行 io_contextioc.run();} catch (const std::exception& e) {std::cerr << "Error: " << e.what() << std::endl;return EXIT_FAILURE;}return EXIT_SUCCESS;
}

解析：

  1. session 类：处理 WebSocket 会话，包括握手、读写消息等。
  2. listener 类：负责监听传入的 TCP 连接，并创建新的 WebSocket 会话。
  3. main 函数：解析命令行参数，创建 io_context，启动监听器并运行。

运行方式： 编译并运行服务器程序，例如：

在 Linux 上

假设将服务器代码保存为 websocket_server.cpp，使用以下命令进行编译和运行：

# 编译服务器代码
g++ -o websocket-server websocket_server.cpp -lboost_system -lboost_thread -lssl -lcrypto -lboost_beast# 运行服务器
./websocket-server 8080
在 Windows 上

假设将服务器代码保存为 websocket_server.cpp，使用以下命令进行编译和运行（需要安装 MinGW）：

# 编译服务器代码
g++ -o websocket-server websocket_server.cpp -lboost_system -lws2_32 -lssl -lcrypto# 运行服务器
./websocket-server 8080

 

3. WebSocket 客户端实现
客户端代码
#include <boost/beast/core.hpp>
#include <boost/beast/websocket.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <cstdlib>
#include <iostream>
#include <string>namespace beast = boost::beast;         // from <boost/beast.hpp>
namespace websocket = beast::websocket; // from <boost/beast/websocket.hpp>
namespace net = boost::asio;            // from <boost/asio.hpp>
using tcp = net::ip::tcp;               // from <boost/asio/ip/tcp.hpp>int main(int argc, char* argv[]) {try {if (argc != 3) {std::cerr << "Usage: websocket-client <host> <port>\n";return EXIT_FAILURE;}auto const host = argv[1];auto const port = argv[2];// 创建 io_contextnet::io_context ioc;// 解析地址tcp::resolver resolver(ioc);auto const results = resolver.resolve(host, port);// 创建 WebSocket 流websocket::stream<tcp::socket> ws{ioc};// 连接到服务器net::connect(ws.next_layer(), results.begin(), results.end());// 执行 WebSocket 握手ws.handshake(host, "/");// 发送消息ws.write(net::buffer(std::string("Hello from client")));// 读取响应beast::flat_buffer buffer;ws.read(buffer);std::cout << "Received: " << beast::make_printable(buffer.data()) << std::endl;// 关闭 WebSocket 连接ws.close(websocket::close_code::normal);} catch (const std::exception& e) {std::cerr << "Error: " << e.what() << std::endl;return EXIT_FAILURE;}return EXIT_SUCCESS;
}

解析：

  1. 解析命令行参数：host 和 port。
  2. 创建 io_context：管理 I/O 操作。
  3. 解析服务器地址：通过 tcp::resolver。
  4. 创建 WebSocket 流：通过 websocket::stream<tcp::socket>。
  5. 连接到服务器：通过 net::connect。
  6. 执行 WebSocket 握手：通过 ws.handshake。
  7. 发送消息：通过 ws.write。
  8. 读取响应：通过 ws.read。
  9. 关闭 WebSocket 连接：通过 ws.close。

运行方式： 编译并运行客户端程序，例如：

在 Linux 上

假设将客户端代码保存为 websocket_client.cpp，使用以下命令进行编译和运行：

# 编译客户端代码
g++ -o websocket-client websocket_client.cpp -lboost_system -lboost_thread -lssl -lcrypto -lboost_beast# 运行客户端
./websocket-client localhost 8080
在 Windows 上

假设将客户端代码保存为 websocket_client.cpp，使用以下命令进行编译和运行（需要安装 MinGW）：

# 编译客户端代码
g++ -o websocket-client websocket_client.cpp -lboost_system -lws2_32 -lssl -lcrypto# 运行客户端
./websocket-client localhost 8080

 

运行结果：

Received: Echo: Hello from server
五、总结

        本文深入解析了 WebSocket 的基础概念、工作原理及其在 C++ 中的实现，并结合 Boost.Asio 和 Boost.Beast 库实现了 WebSocket 服务器和客户端。通过详细的示例代码和解析，展示了如何在 C++ 中构建高效、实时的双向通信应用。希望本文能帮助读者更好地理解和掌握 WebSocket 技术及其在 C++ 中的应用，提高网络编程技能。

        本文提供的示例代码可以在 Linux 和 Windows 上运行，主要依赖于跨平台的 Boost.Asio 和 Boost.Beast 库。无论您使用哪种操作系统，都需要确保系统上安装了相应的编译器和 Boost 库。通过本文的详细解释和示例，您应该能够在 C++ 环境中实现高效的 WebSocket 客户端和服务器。

这篇关于学懂C++（四十一）：网络编程——深入详解 C++ 网络编程之 WebSocket 应用技术的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1096916。

相关文章

Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
中文分词jieba库的使用与实景应用（一）

中文分词jieba库的使用与实景应用（一）

知识星球：https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义： 精确模式（默认模式）： 全模式： 搜索引擎模式： paddle 模式（基于深度学习的分词模式）： 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...
【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画（下）

【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画（下）

【课程链接】 AntV G6：深入图形与图形分组、自定义节点、节点动画（下）_哔哩哔哩_bilibili 本章十吾老师讲解了一个复杂的自定义节点中，应该怎样去计算和绘制图形，如何给一个图形制作不间断的动画，以及在鼠标事件之后产生动画。（有点难，需要好好理解） <!DOCTYPE html><html><head><meta charset="UTF-8"><title>06
阅读更多...
【C++ Primer Plus习题】13.4

【C++ Primer Plus习题】13.4

大家好,这里是国中之林! ❥前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站。有兴趣的可以点点进去看看← 问题: 解答: main.cpp #include <iostream>#include "port.h"int main() {Port p1;Port p2("Abc", "Bcc", 30);std::cout <<
阅读更多...
深入探索协同过滤：从原理到推荐模块案例

深入探索协同过滤：从原理到推荐模块案例

文章目录 前言一、协同过滤1. 基于用户的协同过滤（UserCF）2. 基于物品的协同过滤（ItemCF）3. 相似度计算方法 二、相似度计算方法1. 欧氏距离2. 皮尔逊相关系数3. 杰卡德相似系数4. 余弦相似度 三、推荐模块案例1.基于文章的协同过滤推荐功能2.基于用户的协同过滤推荐功能 前言     在信息过载的时代，推荐系统成为连接用户与内容的桥梁。本文聚焦于
阅读更多...
csu 1446 Problem J Modified LCS （扩展欧几里得算法的简单应用）

csu 1446 Problem J Modified LCS （扩展欧几里得算法的简单应用）

这是一道扩展欧几里得算法的简单应用题，这题是在湖南多校训练赛中队友ac的一道题，在比赛之后请教了队友，然后自己把它a掉 这也是自己独自做扩展欧几里得算法的题目 题意：把题意转变下就变成了：求d1*x - d2*y = f2 - f1的解,很明显用exgcd来解 下面介绍一下exgcd的一些知识点：求ax + by = c的解 一、首先求ax + by = gcd(a,b)的解 这个
阅读更多...
C++包装器

C++包装器

包装器 在 C++ 中，“包装器”通常指的是一种设计模式或编程技巧，用于封装其他代码或对象，使其更易于使用、管理或扩展。包装器的概念在编程中非常普遍，可以用于函数、类、库等多个方面。下面是几个常见的 “包装器” 类型： 1. 函数包装器 函数包装器用于封装一个或多个函数，使其接口更统一或更便于调用。例如，std::function 是一个通用的函数包装器，它可以存储任意可调用对象（函数、函数
阅读更多...
hdu1394(线段树点更新的应用)

hdu1394(线段树点更新的应用)

题意：求一个序列经过一定的操作得到的序列的最小逆序数 这题会用到逆序数的一个性质，在0到n-1这些数字组成的乱序排列，将第一个数字A移到最后一位，得到的逆序数为res-a+(n-a-1) 知道上面的知识点后，可以用暴力来解 代码如下： #include<iostream>#include<algorithm>#include<cstring>#include<stack>#in
阅读更多...
OpenHarmony鸿蒙开发（ Beta5.0）无感配网详解

OpenHarmony鸿蒙开发（ Beta5.0）无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息，即可快速实现设备配网，是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递，利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力，实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后，即可发送相关配网数据。同时还支持与常规Sof
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2