C++与JS实现WebSocket通信（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   
#include   
 
#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 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;  
} 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158

四、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);
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

五、通信测试

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

g++ server.cpp -o server -lwsock32
1

运行服务端代码

server
1

运行js客户端代码

node client.js
1

可以看到客户端持续发送消息

再看服务端窗口，也在持续收到消息

以上即C++与JS的websocket通信实现内容

---

感谢阅读，祝君暴富！