云函数处理 WebSocket 长连接

laf.js 于 v0.6.11 新增支持了 WebSocket 能力。

WebSocket 触发器

当应用收到 WebSocket 消息时，会触发以下云函数事件，开发者为任一云函数配置以下触发器，即可处理 WebSocket 消息

WebSocket:connection 有新 WebSocket 连接建立时触发，通过 ctx.socket 获取连接
WebSocket:message 接收 WebSocket 消息时触发，通过 ctx.params 获取消息数据
WebSocket:close 有 WebSocket 连接关闭时触发
WebSocket:error 有 WebSocket 连接出错时触发

以下是云函数中处理 WebSocket 示例：

exports.main = async function (ctx) {
  if (ctx.method === "WebSocket:connection") {
    ctx.socket.send("hi connection succeed");
  }

  if (ctx.method === "WebSocket:message") {
    const { data } = ctx.params;
    console.log(data.toString());
    ctx.socket.send("I have received your message");
  }
};

1
2
3
4
5
6
7
8
9
10
11

以下是通过云函数向所有 WebSocket 连接发送消息示例：

import cloud from "@/cloud-sdk";

exports.main = async function (ctx) {
  const sockets: Set<WebSocket> = cloud.sockets;
  sockets.forEach((socket) => {
    socket.send("Everyone will receive this message");
  });
  return "ok";
};

1
2
3
4
5
6
7
8
9

更多用法请参考： https://github.com/websockets/ws

客户端 WebSocket 连接

const wss = new WebSocket("wss://your-own-appid.lafyun.com");
wss.onopen = (socket) => {
  console.log("connected");
  wss.send("hi");
};

wss.onmessage = (res) => {
  console.log("收到了新的信息......")
  console.log(res.data);
};

wss.onclose = () => {
  console.log("closed");
};

1
2
3
4
5
6
7
8
9
10
11
12
13
14

云函数处理 WebSocket 长连接 #

WebSocket 触发器 #

客户端 WebSocket 连接 #

云函数处理 WebSocket 长连接

WebSocket 触发器

客户端 WebSocket 连接