C++与JS实现WebSocket通信（C++服务端JS客户端）

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

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

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

文章目录

一、简介
二、环境
三、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);