天行健,君子以自强不息;地势坤,君子以厚德载物。
每个人都有惰性,但不断学习是好好生活的根本,共勉!
文章均为学习整理笔记,分享记录为主,如有错误请指正,共同学习进步。
文章目录
- 一、简介
- 二、环境
- 三、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通信实现内容
感谢阅读,祝君暴富!