Connecting to a cluster is a bit different. Create the client by specifying some (or all) of the nodes in your cluster and then use it like a regular client instance:
import { createCluster } from 'redis';
const cluster = createCluster({
rootNodes: [
{
url: 'redis://10.0.0.1:30001'
},
{
url: 'redis://10.0.0.2:30002'
}
]
});
cluster.on('error', (err) => console.log('Redis Cluster Error', err));
await cluster.connect();
await cluster.set('key', 'value');
const value = await cluster.get('key');
See the client configuration page for the
rootNodes
anddefaults
configuration schemas.
Property | Default | Description |
---|---|---|
rootNodes | An array of root nodes that are part of the cluster, which will be used to get the cluster topology. Each element in the array is a client configuration object. There is no need to specify every node in the cluster, 3 should be enough to reliably connect and obtain the cluster configuration from the server | |
defaults | The default configuration values for every client in the cluster. Use this for example when specifying an ACL user to connect with | |
useReplicas | false |
When true , distribute load by executing readonly commands (such as GET , GEOSEARCH , etc.) across all cluster nodes. When false , only use master nodes |
maxCommandRedirections | 16 |
The maximum number of times a command will be redirected due to MOVED or ASK errors |
nodeAddressMap | Defines the node address mapping | |
modules | Included Redis Modules | |
scripts | Script definitions (see Lua Scripts) | |
functions | Function definitions (see Functions) |
A node address map is required when a redis cluster is configured with addresses that are inaccessible by the machine running the redis client. This is a mapping of addresses and ports, with the values being the accessible address/port combination. Example:
createCluster({
rootNodes: [{
url: 'external-host-1.io:30001'
}, {
url: 'external-host-2.io:30002'
}],
nodeAddressMap: {
'10.0.0.1:30001': {
host: 'external-host-1.io',
port: 30001
},
'10.0.0.2:30002': {
host: 'external-host-2.io',
port: 30002
}
}
});
This is a common problem when using ElastiCache. See Accessing ElastiCache from outside AWS for more information on that.
Commands such as GET
, SET
, etc. are routed by the first key, for instance MGET 1 2 3
will be routed by the key 1
.
Admin commands such as MEMORY STATS
, FLUSHALL
, etc. are not attached to the cluster, and must be executed on a specific node via .getSlotMaster()
.
Certain commands (e.g. PUBLISH
) are forwarded to other cluster nodes by the Redis server. This client sends these commands to a random node in order to spread the load across the cluster.