小程序socket 全局代码

在微信小程序中，为了实现在整个应用范围内共享一个WebSocket连接，通常会将WebSocket的创建、打开、关闭以及消息收发等功能封装在一个全局模块中，然后在各个需要使用WebSocket功能的页面中引入并调用这个模块的方法。以下是一个简化的全局WebSocket管理模块的代码示例：

// global/socket.js
const SocketTask = wx.connectSocket({url: 'wss://your-websocket-server-url', // 替换为实际的WebSocket服务器地址
});let socketClientTimer; // 心跳定时器// 开启WebSocket连接
function openSocketConnection() {wx.onSocketOpen(function (res) {console.log('WebSocket连接已打开！');startHeartbeat(); // 连接建立后开始心跳检测});wx.onSocketError(function (err) {console.error('WebSocket连接发生错误：', err);});wx.onSocketMessage(function (res) {// 处理服务器返回的消息console.log('收到服务器内容：', res.data);handleServerMessage(res.data);});
}// 发送心跳
function startHeartbeat() {socketClientTimer = setInterval(() => {if (wx.getSocketState().readyState === 1) { // 只有在连接已建立时才发送心跳wx.sendSocketMessage({ data: 'ping' }); // 发送心跳数据} else {clearInterval(socketClientTimer); // 如果连接非活动状态，则停止心跳计时器}}, 30000); // 每30秒发送一次心跳（这里的时间可以根据实际情况调整）
}// 关闭WebSocket连接
function closeSocketConnection() {wx.closeSocket();clearInterval(socketClientTimer); // 当关闭连接时也同时停止心跳计时器
}// 发送消息到服务器
function sendMessage(msg) {if (wx.getSocketState().readyState === 1) {wx.sendSocketMessage({ data: msg });} else {console.warn('WebSocket连接未建立，无法发送消息');}
}// 在小程序onHide生命周期内关闭连接或做相应处理
function onHide() {closeSocketConnection();
}// 将上述方法暴露出去
module.exports = {openSocketConnection,closeSocketConnection,sendMessage,onHide,
};

// 在app.js中初始化
// ...
App({onLaunch: function () {if (条件判断是否需要一开始就连接) {openSocketConnection();}},onHide: function () {globalSocket.onHide();},// ...其他配置项
});

在具体页面中使用：

// 页面引用全局socket模块
const globalSocket = require('./global/socket.js');Page({onLoad: function () {globalSocket.openSocketConnection();},onUnload: function () {globalSocket.closeSocketConnection();},sendChat: function (message) {globalSocket.sendMessage(JSON.stringify(message));},// ...其他页面逻辑
});

以上代码仅作示意，实际应用中请根据微信小程序官方文档进行适当调整与优化。记得在小程序进入后台时，调用相应的关闭方法来释放资源。