Google Cloud Pub/Sub 适配器

工作原理

此适配器使用 Google Cloud Pub/Sub 服务 在 Socket.IO 集群的节点之间转发消息。

此适配器的源代码可以在 此处 找到。

支持的功能

功能	socket.io 版本	支持
套接字管理	4.0.0	✅ 是（自版本 0.1.0 起）
服务器间通信	4.1.0	✅ 是（自版本 0.1.0 起）
带有确认的广播	4.5.0	✅ 是（自版本 0.1.0 起）
连接状态恢复	4.6.0	❌ 否

安装

npm install @socket.io/gcp-pubsub-adapter

用法

import { PubSub } from "@google-cloud/pubsub";
import { Server } from "socket.io";
import { createAdapter } from "@socket.io/gcp-pubsub-adapter";

const pubsub = new PubSub({
  projectId: "your-project-id"
});

const topic = pubsub.topic(topicNameOrId);

const io = new Server({
  adapter: createAdapter(topic)
});

// wait for the creation of the pub/sub subscription
await io.of("/").adapter.init();

io.listen(3000);

选项

名称	描述	默认值
subscriptionPrefix	要创建的新订阅的前缀。	socket.io
subscriptionOptions	用于创建订阅的选项。	-
heartbeatInterval	两次心跳之间的毫秒数。	5_000
heartbeatTimeout	没有心跳之前我们认为节点已关闭的毫秒数。	10_000

最新版本

版本	发布日期	发布说明	差异
0.1.0	2024 年 3 月	链接	-

完整变更日志