-
Notifications
You must be signed in to change notification settings - Fork 13
Description
exports.handleWebSocket = async (socket, connect) => {
// 与服务器建立连接
const svrSocket = await connect();
// 客户端 pong 服务端
socket.on('pong', (data) => {
svrSocket.pong(data);
});
// 客户端 ping 服务pong 端
socket.on('ping', (data) => {
svrSocket.ping(data);
});
// 服务端 ping 客户端
svrSocket.on('ping', (data) => {
socket.ping(data);
});
// 服务端 pong 客户端
svrSocket.on('pong', (data) => {
socket.pong(data);
});
// 正常断开 WebSocket 连接
socket.on('disconnect', (code, message, opts) => {
console.log(code, 'client disconnect');
svrSocket.disconnect(code, opts);
});
// 正常断开 WebSocket 连接
svrSocket.on('disconnect', (code, message, opts) => {
console.log(code, 'server disconnect');
socket.disconnect(code, opts);
});
// 获取客户端解析后的帧数据
socket.on('message', (data, opts) => {
console.log(data, 'client data');
比如这里判断有些数据包需要人为丢弃,怎么写代码
svrSocket.send(data, opts);
});
// 获取服务端解析后的帧数据
svrSocket.on('message', (data, opts) => {
console.log(data, 'server data');
socket.send(data, opts);
});
};