Socket.IO Redis adapter

The @socket.io/redis-adapter package allows broadcasting packets between multiple Socket.IO servers.

Table of contents

• Supported features
• Installation
• Compatibility table
• Usage
  • With the redis package
  • With the redis package and a Redis cluster
  • With the ioredis package
  • With the ioredis package and a Redis cluster
  • With Redis sharded Pub/Sub
• Options
  • Default adapter
  • Sharded adapter
• License

Supported features

Feature	socket.io version	Support
Socket management	4.0.0	:white_check_mark: YES (since version 6.1.0)
Inter-server communication	4.1.0	:white_check_mark: YES (since version 7.0.0)
Broadcast with acknowledgements	4.5.0	:white_check_mark: YES (since version 7.2.0)
Connection state recovery	4.6.0	:x: NO

Installation

npm install @socket.io/redis-adapter

Compatibility table

Redis Adapter version	Socket.IO server version
4.x	1.x
5.x	2.x
6.0.x	3.x
6.1.x	4.x
7.x and above	4.3.1 and above

Usage

With the redis package

1import { createClient } from "redis";
2import { Server } from "socket.io";
3import { createAdapter } from "@socket.io/redis-adapter";
4
5const pubClient = createClient({ url: "redis://localhost:6379" });
6const subClient = pubClient.duplicate();
7
8await Promise.all([
9  pubClient.connect(),
10  subClient.connect()
11]);
12
13const io = new Server({
14  adapter: createAdapter(pubClient, subClient)
15});
16
17io.listen(3000);

With the redis package and a Redis cluster

1import { createCluster } from "redis";
2import { Server } from "socket.io";
3import { createAdapter } from "@socket.io/redis-adapter";
4
5const pubClient = createCluster({
6  rootNodes: [
7    {
8      url: "redis://localhost:7000",
9    },
10    {
11      url: "redis://localhost:7001",
12    },
13    {
14      url: "redis://localhost:7002",
15    },
16  ],
17});
18const subClient = pubClient.duplicate();
19
20await Promise.all([
21  pubClient.connect(),
22  subClient.connect()
23]);
24
25const io = new Server({
26  adapter: createAdapter(pubClient, subClient)
27});
28
29io.listen(3000);

With the ioredis package

1import { Redis } from "ioredis";
2import { Server } from "socket.io";
3import { createAdapter } from "@socket.io/redis-adapter";
4
5const pubClient = new Redis();
6const subClient = pubClient.duplicate();
7
8const io = new Server({
9  adapter: createAdapter(pubClient, subClient)
10});
11
12io.listen(3000);

With the ioredis package and a Redis cluster

1import { Cluster } from "ioredis";
2import { Server } from "socket.io";
3import { createAdapter } from "@socket.io/redis-adapter";
4
5const pubClient = new Cluster([
6  {
7    host: "localhost",
8    port: 7000,
9  },
10  {
11    host: "localhost",
12    port: 7001,
13  },
14  {
15    host: "localhost",
16    port: 7002,
17  },
18]);
19const subClient = pubClient.duplicate();
20
21const io = new Server({
22  adapter: createAdapter(pubClient, subClient)
23});
24
25io.listen(3000);

With Redis sharded Pub/Sub

Sharded Pub/Sub was introduced in Redis 7.0 in order to help scaling the usage of Pub/Sub in cluster mode.

Reference: https://redis.io/docs/interact/pubsub/#sharded-pubsub

A dedicated adapter can be created with the createShardedAdapter() method:

1import { Server } from "socket.io";
2import { createClient } from "redis";
3import { createShardedAdapter } from "@socket.io/redis-adapter";
4
5const pubClient = createClient({ host: "localhost", port: 6379 });
6const subClient = pubClient.duplicate();
7
8await Promise.all([
9  pubClient.connect(),
10  subClient.connect()
11]);
12
13const io = new Server({
14  adapter: createShardedAdapter(pubClient, subClient)
15});
16
17io.listen(3000);

Minimum requirements:

• Redis 7.0
• redis@4.6.0

Note: it is not currently possible to use the sharded adapter with the ioredis package and a Redis cluster (reference).

Options

Default adapter

Name	Description	Default value
key	The prefix for the Redis Pub/Sub channels.	socket.io
requestsTimeout	After this timeout the adapter will stop waiting from responses to request.	5_000
publishOnSpecificResponseChannel	Whether to publish a response to the channel specific to the requesting node.	false
parser	The parser to use for encoding and decoding messages sent to Redis.	-

Sharded adapter

Name	Description	Default value
channelPrefix	The prefix for the Redis Pub/Sub channels.	socket.io
subscriptionMode	The subscription mode impacts the number of Redis Pub/Sub channels used by the adapter.	dynamic

License

MIT