Google Cloud Pub/Sub adapter
How it works
This adapter uses Google Cloud Pub/Sub service to forward messages between the nodes of a Socket.IO cluster.
The source code of this adapter can be found here.
Supported features
| 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 |
Installation
npm install @socket.io/gcp-pubsub-adapter
Usage
import{PubSub}from"@google-cloud/pubsub";
import{Server}from"socket.io";
import{ createAdapter }from"@socket.io/gcp-pubsub-adapter";
const pubsub =newPubSub({
projectId:"your-project-id"
});
const topic = pubsub.topic(topicNameOrId);
const io =newServer({
adapter:createAdapter(topic)
});
// wait for the creation of the pub/sub subscription
await io.of("/").adapter.init();
io.listen(3000);
Options
| 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 |
Latest releases
| Version | Release date | Release notes | Diff |
|---|
0.1.0 | March 2024 | link | - |
Complete changelog