The @socket.io/gcp-pubsub-adapter package allows broadcasting packets between multiple Socket.IO servers.
Table of contents
| Feature |
socket.io version |
Support |
|---|---|---|
| Socket management | 4.0.0 |
✅ YES (since version 0.1.0) |
| Inter-server communication | 4.1.0 |
✅ YES (since version 0.1.0) |
| Broadcast with acknowledgements | 4.5.0 |
✅ YES (since version 0.1.0) |
| Connection state recovery | 4.6.0 |
❌ NO |
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);| Name | Description | Default value |
|---|---|---|
subscriptionPrefix |
The prefix for the new subscription to create. | socket.io |
subscriptionOptions |
The options used to create the subscription. | - |
heartbeatInterval |
The number of ms between two heartbeats. | 5_000 |
heartbeatTimeout |
The number of ms without heartbeat before we consider a node down. | 10_000 |