let socketTask = null; // WebSocket 实例
let connectCount = 0; // WebSocket 连接次数
const MAX_CONNECT_COUNT = 5; // 最大重连次数
// 创建 WebSocket 连接
function createSocket() {
socketTask = uni.connectSocket({
url: 'ws://localhost:8080', // WebSocket 服务器地址
success() {
console.log('WebSocket 连接成功');
},
fail() {
console.log('WebSocket 连接失败');
reconnect();
}
});
// 监听 WebSocket 打开事件
socketTask.onOpen(() => {
console.log('WebSocket 已打开');
connectCount = 0; // 连接成功后重置连接次数
});
// 监听 WebSocket 关闭事件
socketTask.onClose(() => {
console.log('WebSocket 已关闭');
reconnect();
});
// 监听 WebSocket 错误事件
socketTask.onError(() => {
console.log('WebSocket 发生错误');
reconnect();
});
// 监听 WebSocket 消息事件
socketTask.onMessage((res) => {
console.log('WebSocket 收到消息', res.data);
});
}
// WebSocket 重连
function reconnect() {
connectCount++;
if (connectCount > MAX_CONNECT_COUNT) {
console.log('WebSocket 重连次数已达上限');
return;
}
console.log('WebSocket 3 秒后进行第', connectCount, '次重连');
setTimeout(() => {
createSocket();
}, 3000);
}
// 初始化 WebSocket 连接
createSocket();
网友回复