C++与JS实现WebSocket通信(C++服务端JS客户端)

news2024/11/23 6:26:00

天行健,君子以自强不息;地势坤,君子以厚德载物。


每个人都有惰性,但不断学习是好好生活的根本,共勉!


文章均为学习整理笔记,分享记录为主,如有错误请指正,共同学习进步。

文章目录

  • 一、简介
  • 二、环境
  • 三、C++服务端代码
  • 四、JS客户端代码
  • 五、通信测试


一、简介

其他语言实现websocket参考如下:
java实现websocket(java客户端java服务端)
js实现websocket(html客户端js服务端)
c++实现websocket(c++服务端c++客户端)

二、环境

如果没有C++和JS的环境需要先装一下,C++装MinGW,JS装nodejs
C++环境配置:MinGW下载安装配置
JS环境配置:Nodejs下载安装配置

三、C++服务端代码

server.cpp

#include <stdio.h>  
#include <winsock2.h>  
 
#pragma comment(lib,"ws2_32.lib")  
// 解决中文乱码问题
// #pragma execution_character_set("gbk");
#pragma execution_character_set("utf-8");
 
int main(int argc, char* argv[])  
{  
    //一、初始化WSA  
    WORD sockVersion = MAKEWORD(2,2);

    WSADATA wsaData;

    if(WSAStartup(sockVersion, &wsaData)!=0)  
    {  
        return 0;  
    }  
 
    //二、创建套接字  socket(参数1:协议族,参数2:socket类型,参数3:协议类型)
    //AF_INET指IPv4 Internet协议
    //SOCK_STREAM指TCP连接,提供序列化的可靠的,双向连接的字节流,支持带外数据传输
    //IPPROTO_TCP指TCP协议
    SOCKET slisten = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);  

    if(slisten == INVALID_SOCKET)  
    {  
        printf("socket error !");  
        return 0;  
    }  
      
    //三、通信协议地址赋值
    //声明通信协议地址参数
    sockaddr_in sin;  
    //定义地址族 AF_INET指IPv4 Internet协议
    sin.sin_family = AF_INET;  
    //定义端口号 16位TCP/UDP端口号
    sin.sin_port = htons(8888);  
    // sin.sin_endpoint = htons(8888);
    //定义ip地址 32位IP地址
    // sin.sin_addr.S_un.S_addr = INADDR_ANY;   
    sin.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");   
    
    //四、绑定 //绑定IP和端口
    //bing()的三个参数:
    //参数1:创建的socket,声明方式SOCKET socket
    //参数2:通信协议地址,声明方式const struct sockaddr_in * addr
    //参数3:对应协议地址的长度,声明方式socklen_t addrlen
    if(bind(slisten, (LPSOCKADDR)&sin, sizeof(sin)) == SOCKET_ERROR)  
    {  
        printf("bind error !");  
    }  
 
    //五、开始监听  
    //listen()的两个参数:
    //参数1:监听的socket描述字,声明方式SOCKET socket
    //参数2:相应socket可排队的最大连接数,声明方式int backlog
    if(listen(slisten, 5) == SOCKET_ERROR)  
    {  
        printf("listen error !");  
        return 0;  
    }  
    

    //循环接收数据  
    SOCKET sClient;  
    sockaddr_in remoteAddr;  
    int nAddrlen = sizeof(remoteAddr);  
    char revData[255];

    //六、接收请求(接收来自客户端的请求)
    //accept()的三个参数:
    //参数1:服务器的socket描述字,监听socket描述字,声明方式SOCKET socket
    //参数2:通信协议地址,声明方式struct sockaddr_in * addr
    //参数3:协议地址的长度,声明方式socklen_t * addrlen
    //accept()返回值是一个由内核自动生成的全新socket描述字,代表与返回客户端的TCP连接
    printf("\nwait connect ...\n");

    sClient = accept(slisten, (SOCKADDR *)&remoteAddr, &nAddrlen);
    if(sClient == INVALID_SOCKET)  
    {  
        printf("accept error !");
        return 0;
    }  
    // printf("接受到一个连接:%s \r\n", inet_ntoa(remoteAddr.sin_addr));  
    printf("accept a connetction and stay : %s \r\n", inet_ntoa(remoteAddr.sin_addr));

    while (true)
    {  
        // printf("等待连接...\n");  
        
        

        
 
        //七、接收数据  
        //recv()的四个参数:
        //参数1:链接socket描述字,声明方式[in] SOCKET socket
        //参数2:接收的多字节数据缓冲区,声明方式[in] const char * recvbuf
        //参数3:接受的多字节长度,声明方式[in] int buflen
        //参数4:指定进行调用的方式,声明方式[in] int flags
        //注:
            //recvbuf:接收数据之前,必须memset进行清空,接收的数据不一定填满空间
            //返回值:
                //未发生错误,则将返接收到的字符数,recvbuf指向的缓冲区将包含接收的数据
                //如果连接已正常关闭,则返回0
                //否则返回SOCKET_ERROR,通过调用WSAGetLastError来检索特定的错误代码
                //错误代码参考微软官网地址https://learn.microsoft.com/zh-cn/windows/win32/api/winsock2/nf-winsock2-recv
        int ret = recv(sClient, revData, 255, 0);         
        if(ret > 0)  
        {  
            printf("\naccept info from client, content: \n\t\t\t\t\t");  
            revData[ret] = 0x00;  
            // printf("接收到来自客户端的消息:"+revData+"\n");  
            // printf("accept info from client, content: ",revData,"\n");  
            
            printf(revData);
        }  
 
        //发送数据  
        // const char * sendData = "你好,TCP客户端!\n";  
        const char * sendData = "hello tcp client!\n";  
        send(sClient, sendData, strlen(sendData), 0);  

        //八、关闭socket
        //closesocket()的参数为socket描述字,声明方式为int closesocket([in] SOCKET s);
        //注:返回值:
            //无异常,返回0
            //否则返回一个SOCKET_ERROR的值:错误代码和意义如下:
                //WSANOTINITIALISED 未初始化调用WSAStartup
                //WSAENETDOWN 网格子系统出现故障
                //WSAENOTSOCK 描述符不是套接字
                //WSAEINPROGRESS 阻止Windows套接字1.1调用正在进行中,后者服务提供商仍在处理回调函数
                //WSAEINTR 阻止Windows socket 1.1 调用已通过WSACancelBlockingCall取消
                //WSAEWOULDBLOCK 套接字标记为非阻塞,但延迟结构的l_onoff成员设置为非零,l_linger成员的延迟结构设置为非零超时值
                //注:
                    //close标记TCP socket为已关闭,不可作为读写数据的第一个参数
                    //#include<unistd.h> int close(int socket)
                    //注: close只是使socket描述字的引用计数-1,当引用计数为0才会触发TCP客户端向服务器发送中止连接请求
        // closesocket(sClient);  
    }  
 
    // closesocket(slisten);  

    //九、停止使用WSACleanup
    //使用方式int WSACleanup();
    //返回值:
        //无异常则返回0;
        //否则返回SOCKET_ERROR值,调用WSAGetLastError来检索特定的错误代码,错误代码和含义如下:
            //WSANOTINITIALISED* 未初始化调用WSAStartup
            //WSAENETDOWN 网络子系统出现故障
            //WSAEINPROGRESS 阻止Windows套接字1.1调用正在进行中,后者服务提供商仍在处理回调函数
        
    WSACleanup();  
    // printf("WSACleanup!!!")
    return 0;  
} 

四、JS客户端代码

client.js

//引入net模块
var net = require('net');
//定义连接的ip地址和端口
var client = net.connect(8888, '127.0.0.1', function() {
    //连接成功后打印内容
    console.log("connetct successfully");
});

//触发事件 接收服务端推送来的数据
client.on('data', data=>{
    //数据转为字符串,字符编码使用utf-8
    console.log(data.toString('utf-8'));
});

//触发事件 报错
client.on('error', function(ex) {
    //报错时打印内容
    console.log("handled error");
    //报错信息打印
    console.log(ex);
});

//定义变量,发消息的次数
let varint = 1;

//创建循环,持续发送消息
setInterval(function(){
    //打印发送消息的条数
    console.log(varint);
    //将内容写入发给服务端
    client.write(`hello server ${varint}`);
    varint ++;
    //每条消息间隔1秒
},1000);

五、通信测试

编译C++的websocket服务端代码,命令如下

g++ server.cpp -o server -lwsock32

在这里插入图片描述
运行服务端代码

server

在这里插入图片描述

运行js客户端代码

node client.js

可以看到客户端持续发送消息
在这里插入图片描述
再看服务端窗口,也在持续收到消息
在这里插入图片描述
以上即C++与JS的websocket通信实现内容


感谢阅读,祝君暴富!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1010201.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

即时通讯如何做好安全防御

即时通讯工具该怎么样做好防御可以分为以下几点 1、清理安全漏洞定期定时的扫描服务器的网络节点&#xff0c;排查网络中的安全漏洞隐患&#xff0c;及时清理安全漏洞。避免这些漏洞被黑客利用&#xff0c;攻击服务器。 2、设置防火墙在服务器的骨干节点配置防火墙&#xff0c;…

前端面试要点

0914 JScript深拷贝和浅拷贝&#xff08;js解构赋值算哪个&#xff1f;&#xff09; 深拷贝和浅拷贝 回流和重绘 回流和重绘 webpack打包流程 Webpack打包 虚拟DOM 虚拟DOM git合并分支 git合并分支 CSS盒子模型 CSS盒子模型 0911 WebPack分包 webpack分包 ts泛型 ts泛型 优化…

java包的介绍

包 包就是文件夹&#xff0c;用来管理各种不同功能的 java 类&#xff0c;方便后续管理 包名的规则: 公司域名反写&#xff0b;包的作用&#xff0c;需要全部英文小写&#xff0c;见名知意。 导包的规则 使用同一个包中的类时&#xff0c;不需要导包。使用 java. Lang 包中的…

9月13日上课内容 第三章 ELK日志分析系统

本章结构 ELK日志分析系统简介 ELK日志分析系统分为 Elasticsearch Logstash Kibana 日志处理步骤 1.将日志进行集中化管理 2.将日志格式化(Logstash) 并输出到Elasticsearch 3.对格式化后的数据进行索引和存储 (Elasticsearch) 4.前端数据的展示(Kibana) Elasticsearch介…

【深度学习】 Python 和 NumPy 系列教程(十六):Matplotlib详解:2、3d绘图类型(2)3D散点图(3D Scatter Plot)

目录 一、前言 二、实验环境 三、Matplotlib详解 1、2d绘图类型 2、3d绘图类型 0. 设置中文字体 1. 线框图&#xff08;Wireframe Plot&#xff09; 2. 3D散点图&#xff08;3D Scatter Plot&#xff09; 一、前言 Python是一种高级编程语言&#xff0c;由Guido van Ross…

窗帘导轨轮小柱

实物 difference(){union(){cylinder(1, 3.5, 3.5, $fn360);cylinder(8, 2, 2, $fn360);}rotate([90,0,0])translate([0,6,-3])cylinder(6, 1, 1, $fn360); }

STM32WB55开发(3)----配置串口打印Debug调试信息

STM32WB55开发----3.配置串口打印Debug调试信息 概述硬件准备视频教学样品申请选择芯片型号配置时钟源配置时钟树RTC时钟配置查看开启STM32_WPAN条件配置HSEM配置IPCC配置RTC启动RF开启蓝牙开启串口调试配置蓝牙参数设置工程信息工程文件设置Keil工程配置代码配置结果演示 概述…

云原生服务无状态(Stateless)特性的实现

文章目录 为何要使用无状态服务&#xff1f;无状态服务的实现方法1. 会话状态外部化2. 负载均衡3. 自动伸缩4. 容器编排5. 数据存储6. 安全性 示例&#xff1a;使用Spring Boot实现无状态服务结论 &#x1f389;欢迎来到云计算技术应用专栏~云原生服务无状态&#xff08;Statel…

2023年云南省职业院校技能大赛中职组“网络安全”赛项样题

2023年云南省职业院校技能大赛 中职组“网络安全”赛项样题 一、竞赛时间 总计&#xff1a;180分钟 二、竞赛阶段 竞赛阶段 任务阶段 竞赛任务 竞赛时间 分值 A、B模块 A-1 登录安全加固 180分钟 200分 A-2 数据库加固 A-3 服务加固SSH\VSFTPD A-4 防火墙策…

数据结构与算法-堆树

一&#xff1a;引入 1.优先队列&#xff1a;大家还记得我们上节课讲的赫夫曼树&#xff0c;我使用了一个优先队列大大减轻了我们的开发任务&#xff0c;但是大家知道这个优先队列内部是如何实现的呢&#xff1f; 解决&#xff1a; 大顶堆&#xff0c;优先删除堆顶 2.如何实现一…

云原生Kubernetes:pod资源管理与配置

目录 一、理论 1.pod 2.pod容器分类 3.镜像拉取策略 4.pod 的重启策略 二、实验 1.Pod容器的分类 2.镜像拉取策略 三、问题 1.apiVersion 报错 2.pod v1版本资源未注册 3.格式错误 4.取行显示指定pod信息 四、总结 一、理论 1.pod (1) 概念 Pod是kubernetes中…

PWA及小程序在系统生态方面的支持对比

PWA代表“渐进式网络应用”&#xff08;Progressive Web Application&#xff09;。它是一种结合了网页和移动应用程序功能的技术概念。PWA旨在提供类似于原生应用程序的用户体验&#xff0c;包括离线访问、推送通知、后台同步等功能&#xff0c;同时又具有网页的优势&#xff…

Linux自动化构建项目工具——Makefile/makefile

目录 一&#xff0c;背景知识 二&#xff0c;makefile/Makefile的编写 1.创建makefile/Makefile文件 2.在Makefile文件里写编译代码 3.伪目标——.PHONY 1.伪目标的特点 2.怎样实现总是被执行 4.Makefile/makefile文件的不同编写风格 1.背景知识 2.改写 一&#xff0c;背…

kali安装volatility及插件mimikatz

1.准备工作 kali安装pip2 wget https://bootstrap.pypa.io/pip/2.7/get-pip.py python2 get-pip.py 查看pip2版本 python2 -m pip -v pip2安装升级 pip2 install --upgrade setuptools 安装2个库 pip2 install construct2.10.54 pip2 install pycryptodome 下载文件d…

python开发之个微的二次开发

简要描述&#xff1a; 自动通过群&#xff08;url&#xff09; 请求URL&#xff1a; http://域名地址/acceptUrl 请求方式&#xff1a; POST 请求头Headers&#xff1a; Content-Type&#xff1a;application/jsonAuthorization&#xff1a;Authorization值&#xff08;…

同一台电脑安装两个版本的idea

在同一台电脑中安装两个idea&#xff0c;例如idea2019和idea2023都正常安装&#xff0c;但是第二个idea2023版本&#xff0c;双击打不开程序&#xff0c;那就就需要安装下面的操作流程进行解决。 第一步&#xff1a;创建 .IntelliJIdea2023.2.1文件夹 在C:\Users\用户\目录下…

企业面对负面舆论时应当如何有效应对?

随着网络的快速发展&#xff0c;网络舆情已经成为影响企业形象的重大因素&#xff0c;一条不起眼的负面新闻报道&#xff0c;如果不注意的话&#xff0c;其影响是难以预料的。当负面舆论来临&#xff0c;企业应该怎么做才能化解消极影响呢&#xff1f;接下来媒介盒子就来告诉大…

【Redis】深入探索 Redis 的数据类型 —— 列表 List

文章目录 一、List 类型介绍二、List 类型相关命令2.1 LPUSH 和 RPUSH、LPUSHX 和 RPUSHX2.2 LPOP 和 RPOP、BLPOP 和 BRPOP2.3 LRANGE、LINDEX、LINSERT、LLEN2.4 列表相关命令总结 三、List 类型内部编码3.1 压缩列表&#xff08;ziplist&#xff09;3.2 链表&#xff08;lin…

铝及铝合金产品标识知识学习记录

声明 本文是学习GB-T 42916-2023 铝及铝合金产品标识. 而整理的学习笔记,分享出来希望更多人受益,如果存在侵权请及时联系我们 1— 圆铸锭表面&#xff1b; 2——切完头尾的圆铸锭尾端(引锭头端)。 图 9 圆铸锭刻痕标识示意图(一) 示 例 2 : 5A06 牌号、铸态、尺寸规格为…

4.4-Spring源码循环依赖终极讲解

回顾上期内容 new 容器 new AnnotateBeanDefinitionReader 的时候创建很多创世纪的类&#xff0c;其中有一个ConfigurationPostProcessor是用来解析配置类的&#xff0c;将其注册起来存到Bean定义的Map中【这个类是基于Bean工厂后置处理器的】 这一步是将配置类注册到Bean定…