85 lines
1.5 KiB
JavaScript
85 lines
1.5 KiB
JavaScript
|
let socket = null;
|
|||
|
|
const HEARTBEAT_INTERVAL = 5000;
|
|||
|
|
let heartbeatTimer = null;
|
|||
|
|
|
|||
|
|
// // 连接到后端 WebSocket，并开始心跳
|
|||
|
|
// function connect() {
|
|||
|
|
// WebSocket.connect('ws://your-backend-url');
|
|||
|
|
// startHeartbeat();
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
// 开始发送心跳消息
|
|||
|
|
function startHeartbeat() {
|
|||
|
|
heartbeatTimer = setInterval(() => {
|
|||
|
|
WebSocket.send('heartbeat');
|
|||
|
|
}, HEARTBEAT_INTERVAL);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 停止发送心跳消息
|
|||
|
|
function stopHeartbeat() {
|
|||
|
|
clearInterval(heartbeatTimer);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 监听收到的消息
|
|||
|
|
WebSocket.onMessage((event) => {
|
|||
|
|
if (event.data === 'heartbeat') {
|
|||
|
|
// 收到心跳响应，重置定时器
|
|||
|
|
resetHeartbeatTimer();
|
|||
|
|
} else {
|
|||
|
|
// 处理其他消息
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
// 重置心跳定时器
|
|||
|
|
function resetHeartbeatTimer() {
|
|||
|
|
clearInterval(heartbeatTimer);
|
|||
|
|
startHeartbeat();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 在页面关闭或组件销毁时，关闭 WebSocket 连接并停止心跳
|
|||
|
|
uni.onUnload(() => {
|
|||
|
|
WebSocket.close();
|
|||
|
|
stopHeartbeat();
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
|
|||
|
|
function connect(url) {
|
|||
|
|
socket = uni.connectSocket({
|
|||
|
|
url: url
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
socket.onOpen(() => {
|
|||
|
|
console.log('WebSocket 连接已打开');
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
socket.onError((error) => {
|
|||
|
|
console.error('WebSocket 连接发生错误', error);
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
socket.onClose((e) => {
|
|||
|
|
console.log('WebSocket 连接已关闭', e);
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
socket.onMessage((event) => {
|
|||
|
|
console.log('收到服务器消息', event.data);
|
|||
|
|
// 处理收到的消息
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function send(message) {
|
|||
|
|
socket.send({
|
|||
|
|
data: message
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function close() {
|
|||
|
|
if (socket) {
|
|||
|
|
socket.close();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
export default {
|
|||
|
|
connect,
|
|||
|
|
send,
|
|||
|
|
close
|
|||
|
|
};
|