|
| 1 | +# Redis Sentinel |
| 2 | + |
| 3 | +The [Redis Sentinel](https://redis.io/docs/management/sentinel/) object of node-redis provides a high level object that provides access to a high availability redis installation managed by Redis Sentinel to provide enumeration of master and replica nodes belonging to an installation as well as reconfigure itself on demand for failover and topology changes. |
| 4 | + |
| 5 | +## Basic Example |
| 6 | + |
| 7 | +```javascript |
| 8 | +import { createSentinel } from 'redis'; |
| 9 | + |
| 10 | +const sentinel = await createSentinel({ |
| 11 | + name: 'sentinel-db', |
| 12 | + sentinelRootNodes: [{ |
| 13 | + host: 'example', |
| 14 | + port: 1234 |
| 15 | + }] |
| 16 | + }) |
| 17 | + .on('error', err => console.error('Redis Sentinel Error', err)); |
| 18 | + .connect(); |
| 19 | + |
| 20 | +await sentinel.set('key', 'value'); |
| 21 | +const value = await sentinel.get('key'); |
| 22 | +await sentinel.close(); |
| 23 | +``` |
| 24 | + |
| 25 | +In the above example, we configure the sentinel object to fetch the configuration for the database Redis Sentinel is monitoring as "sentinel-db" with one of the sentinels being located at `example:1234`, then using it like a regular Redis client. |
| 26 | + |
| 27 | +## `createSentinel` configuration |
| 28 | + |
| 29 | +| Property | Default | Description | |
| 30 | +|-----------------------|---------|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| |
| 31 | +| name | | The sentinel identifier for a particular database cluster | |
| 32 | +| sentinelRootNodes | | An array of root nodes that are part of the sentinel cluster, which will be used to get the 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 sentinel configuration from the server | |
| 33 | +| maxCommandRediscovers | `16` | The maximum number of times a command will retry due to topology changes. | |
| 34 | +| nodeClientOptions | | The configuration values for every node in the cluster. Use this for example when specifying an ACL user to connect with | |
| 35 | +| sentinelClientOptions | | The configuration values for every sentinel in the cluster. Use this for example when specifying an ACL user to connect with | |
| 36 | +| masterPoolSize | `1` | The number of clients connected to the master node | |
| 37 | +| replicaPoolSize | `0` | The number of clients connected to each replica node. When greater than 0, the client will distribute the load by executing read-only commands (such as `GET`, `GEOSEARCH`, etc.) across all the cluster nodes. | |
| 38 | +| reserveClient | `false` | When `true`, one client will be reserved for the sentinel object. When `false`, the sentinel object will wait for the first available client from the pool. | |
| 39 | +## PubSub |
| 40 | + |
| 41 | +It supports PubSub via the normal mechanisms, including migrating the listeners if the node they are connected to goes down. |
| 42 | + |
| 43 | +```javascript |
| 44 | +await sentinel.subscribe('channel', message => { |
| 45 | + // ... |
| 46 | +}); |
| 47 | +await sentinel.unsubscribe('channel'); |
| 48 | +``` |
| 49 | + |
| 50 | +see [the PubSub guide](./pub-sub.md) for more details. |
| 51 | + |
| 52 | +## Sentinel as a pool |
| 53 | + |
| 54 | +The sentinel object provides the ability to manage a pool of clients for the master node: |
| 55 | + |
| 56 | +```javascript |
| 57 | +createSentinel({ |
| 58 | + // ... |
| 59 | + masterPoolSize: 10 |
| 60 | +}); |
| 61 | +``` |
| 62 | + |
| 63 | +In addition, it also provides the ability have a pool of clients connected to the replica nodes, and to direct all read-only commands to them: |
| 64 | + |
| 65 | +```javascript |
| 66 | +createSentinel({ |
| 67 | + // ... |
| 68 | + replicaPoolSize: 10 |
| 69 | +}); |
| 70 | +``` |
| 71 | + |
| 72 | +## Master client lease |
| 73 | + |
| 74 | +Sometimes multiple commands needs to run on an exclusive client (for example, using `WATCH/MULTI/EXEC`). |
| 75 | + |
| 76 | +There are 2 ways to get a client lease: |
| 77 | + |
| 78 | +`.use()` |
| 79 | +```javascript |
| 80 | +const result = await sentinel.use(async client => { |
| 81 | + await client.watch('key'); |
| 82 | + return client.multi() |
| 83 | + .get('key') |
| 84 | + .exec(); |
| 85 | +}); |
| 86 | +``` |
| 87 | + |
| 88 | +`.getMasterClientLease()` |
| 89 | +```javascript |
| 90 | +const clientLease = await sentinel.getMasterClientLease(); |
| 91 | + |
| 92 | +try { |
| 93 | + await clientLease.watch('key'); |
| 94 | + const resp = await clientLease.multi() |
| 95 | + .get('key') |
| 96 | + .exec(); |
| 97 | +} finally { |
| 98 | + clientLease.release(); |
| 99 | +} |
| 100 | +``` |
0 commit comments