【微信小程序】使用 WebSocket 进行订阅操作、连接监听、接收到服务器的消息事件




在微信小程序中使用 WebSocket 进行订阅操作，可以通过 wx.connectSocket 方法创建 WebSocket 连接，并通过相关事件处理函数进行订阅和数据处理。
以下是一个示例代码，演示了在微信小程序中使用 WebSocket 进行订阅：
创建 WebSocket 连接

wx.connectSocket({
url: 'wss://your-websocket-url',
success: function() {
console.log('WebSocket 连接创建成功');
},
fail: function(err) {
console.error('WebSocket 连接创建失败', err);
}
});

监听 WebSocket 连接打开事件

wx.onSocketOpen(function() {
console.log('WebSocket 连接已打开');

// 发送订阅消息
wx.sendSocketMessage({
data: 'subscribe',
success: function() {
console.log('订阅消息发送成功');
},
fail: function(err) {
console.error('订阅消息发送失败', err);
}
});
});

监听 WebSocket 接收到服务器的消息事件


wx.onSocketMessage(function(res) {
console.log('收到服务器的消息', res.data);

// 处理接收到的消息
var message = JSON.parse(res.data);
// 在这里可以进行相应的数据处理和展示
});

监听 WebSocket 错误事件
wx.onSocketError(function(err) {
console.error('WebSocket 连接发生错误', err);
});

监听 WebSocket 连接关闭事件
wx.onSocketClose(function() {
console.log('WebSocket 连接已关闭');
});

在上述代码中，我们首先使用 wx.connectSocket 方法创建 WebSocket 连接，并在成功和失败的回调函数中进行相应的处理。然后，通过 wx.onSocketOpen 监听 WebSocket 连接打开事件，在连接成功后发送订阅消息。接着，通过 wx.onSocketMessage 监听 WebSocket 接收到服务器的消息事件，并在回调函数中处理接收到的消息。最后，通过 wx.onSocketError 和 wx.onSocketClose 监听错误和连接关闭事件。
请注意，您需要将 'wss://your-websocket-url' 替换为您实际的 WebSocket 服务器地址。同时，根据实际需求，您还可以根据接收到的消息进行相应的数据处理和展示。
封装为WebSocketClient
如果您希望将 WebSocket 使用封装成一个 JavaScript 类，以便在多个地方重复使用和管理，可以参考以下示例代码：
class WebSocketClient {
constructor(url) {
this.url = url;
}

connect() {
wx.connectSocket({
url: this.url,
success: () => {
console.log('WebSocket 连接创建成功');
},
fail: (err) => {
console.error('WebSocket 连接创建失败', err);
}
});

wx.onSocketOpen(() => {
console.log('WebSocket 连接已打开');
this.subscribe();
});

wx.onSocketMessage((res) => {
console.log('收到服务器的消息', res.data);
this.handleMessage(res.data);
});

wx.onSocketError((err) => {
console.error('WebSocket 连接发生错误', err);
});

wx.onSocketClose(() => {
console.log('WebSocket 连接已关闭');
});
}

subscribe() {
wx.sendSocketMessage({
data: 'subscribe',
success: () => {
console.log('订阅消息发送成功');
},
fail: (err) => {
console.error('订阅消息发送失败', err);
}
});
}

handleMessage(data) {
// 处理接收到的消息
var message = JSON.parse(data);
// 在这里可以进行相应的数据处理和展示
}
}

// 使用示例
var websocket = new WebSocketClient('wss://your-websocket-url');
websocket.connect();

在上述代码中，我们创建了一个名为 WebSocketClient 的 JavaScript 类，通过 constructor 方法接收 WebSocket 服务器地址作为参数并存储为实例属性。然后，定义了 connect 方法来创建 WebSocket 连接，并在相应的事件处理函数中进行订阅和消息处理。同时，我们还添加了 subscribe 方法用于发送订阅消息，以及 handleMessage 方法用于处理接收到的消息。