Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

ioredis

Package Overview
Dependencies
Maintainers
1
Versions
228
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

ioredis - npm Package Compare versions

Comparing version 1.1.0 to 1.1.1

lib/transaction.js

780

API.md

@@ -1,190 +0,676 @@

## Classes
<dl>
<dt><a href="#Redis">Redis</a> ⇐ <code>[EventEmitter](http://nodejs.org/api/events.html#events_class_events_eventemitter)</code></dt>
<dd></dd>
<dt><a href="#Commander">Commander</a></dt>
<dd></dd>
</dl>
## Members
<dl>
<dt><a href="#defaultOptions">defaultOptions</a></dt>
<dd><p>Default options</p>
</dd>
</dl>
<a name="Redis"></a>
## Redis ⇐ <code>[EventEmitter](http://nodejs.org/api/events.html#events_class_events_eventemitter)</code>
**Kind**: global class
**Extends:** <code>[EventEmitter](http://nodejs.org/api/events.html#events_class_events_eventemitter)</code>, <code>[Commander](#Commander)</code>
# ioredis
* [Redis](#Redis) ⇐ <code>[EventEmitter](http://nodejs.org/api/events.html#events_class_events_eventemitter)</code>
* [new Redis([port], [host], [options])](#new_Redis_new)
* _instance_
* [.connect()](#Redis#connect)
* [.disconnect()](#Redis#disconnect)
* ~~[.end()](#Redis#end)~~
* [.duplicate()](#Redis#duplicate)
* [.monitor([callback])](#Redis#monitor)
* [.defineCommand(name, definition)](#Commander#defineCommand)
* _static_
* ~~[.createClient()](#Redis.createClient)~~
[![Build Status](https://travis-ci.org/luin/ioredis.svg?branch=master)](https://travis-ci.org/luin/ioredis)
[![Test Coverage](https://codeclimate.com/github/luin/ioredis/badges/coverage.svg)](https://codeclimate.com/github/luin/ioredis)
[![Code Climate](https://codeclimate.com/github/luin/ioredis/badges/gpa.svg)](https://codeclimate.com/github/luin/ioredis)
[![Dependency Status](https://david-dm.org/luin/ioredis.svg)](https://david-dm.org/luin/ioredis)
[![Join the chat at https://gitter.im/luin/ioredis](https://badges.gitter.im/Join%20Chat.svg)](https://gitter.im/luin/ioredis?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge&utm_content=badge)
<a name="new_Redis_new"></a>
### new Redis([port], [host], [options])
Creates a Redis instance
A delightful, performance-focused Redis client for Node and io.js
Support Redis >= 2.6.12 and (Node.js >= 0.11.16 or io.js).
| Param | Type | Default | Description |
| --- | --- | --- | --- |
| [port] | <code>number</code> &#124; <code>string</code> &#124; <code>Object</code> | <code>6379</code> | Port of the Redis server, or a URL string(see the examples below), or the `options` object(see the third argument). |
| [host] | <code>string</code> &#124; <code>Object</code> | <code>&quot;localhost&quot;</code> | Host of the Redis server, when the first argument is a URL string, this argument is an object represents the options. |
| [options] | <code>Object</code> | | Other options. |
| [options.port] | <code>number</code> | <code>6379</code> | Port of the Redis server. |
| [options.host] | <code>string</code> | <code>&quot;localhost&quot;</code> | Host of the Redis server. |
| [options.family] | <code>string</code> | <code>4</code> | Version of IP stack. Defaults to 4. |
| [options.path] | <code>string</code> | <code>null</code> | Local domain socket path. If set the `port`, `host` and `family` will be ignored. |
| [options.auth] | <code>string</code> | <code>null</code> | If set, client will send AUTH command with the value of this option when connected. |
| [options.enableReadyCheck] | <code>boolean</code> | <code>true</code> | When a connection is established to the Redis server, the server might still be loading the database from disk. While loading, the server not respond to any commands. To work around this, when this option is `true`, ioredis will check the status of the Redis server, and when the Redis server is able to process commands, a `ready` event will be emitted. |
| [options.enableOfflineQueue] | <code>boolean</code> | <code>true</code> | By default, if there is no active connection to the Redis server, commands are added to a queue and are executed once the connection is "ready" (when `enableReadyCheck` is `true`, "ready" means the Redis server has loaded the database from disk, otherwise means the connection to the Redis server has been established). If this option is false, when execute the command when the connection isn't ready, an error will be returned. |
| [options.connectTimeout] | <code>number</code> | <code>10000</code> | The milliseconds before a timeout occurs during the initial connection to the Redis server. |
| [options.autoResubscribe] | <code>boolean</code> | <code>true</code> | After reconnected, if the previous connection was in the subscriber mode, client will auto re-subscribe these channels. |
| [options.lazyConnect] | <code>boolean</code> | <code>false</code> | By default, When a new `Redis` instance is created, it will connect to Redis server automatically. If you want to keep disconnected util a command is called, you can pass the `lazyConnect` option to the constructor: ```javascript var redis = new Redis({ lazyConnect: true }); // No attempting to connect to the Redis server here. // Now let's connect to the Redis server redis.get('foo', function () { }); ``` |
| [options.retryStrategy] | <code>function</code> | | See "Quick Start" section |
# Feature
ioredis is a robust, full-featured Redis client
used in the world's biggest online commerce company [Alibaba](http://www.alibaba.com/).
**Example**
```js
0. Full-featured. It supports [Cluster](http://redis.io/topics/cluster-tutorial), [Sentinel](redis.io/topics/sentinel), [Pipelining](http://redis.io/topics/pipelining) and of course [Lua scripting](http://redis.io/commands/eval) & [Pub/Sub](http://redis.io/topics/pubsub)(with the support of binary messages).
0. High performance.
0. Delightful API. Supports both Node-style callbacks and promises.
0. Supports command arguments and replies transform.
0. Abstraction for Lua scripting, allowing you to define custom commands.
0. Support for binary data.
0. Support for both TCP/IP and UNIX domain sockets.
0. Supports offline queue and ready checking.
0. Supports ES6 types such as `Map` and `Set`.
0. Sophisticated error handling strategy.
<hr>
# Links
* [API Documentation](API.md)
* [Changelog](Changelog.md)
* [Migrating from node_redis](https://github.com/luin/ioredis/wiki/Migrating-from-node_redis)
* [Error Handling](#error-handling)
* [Benchmark](#benchmark)
# Quick Start
## Install
```shell
$ npm install ioredis
```
## Basic Usage
```javascript
var Redis = require('ioredis');
var redis = new Redis();
redis.set('foo', 'bar');
redis.get('foo', function (err, result) {
console.log(result);
});
// or using promise if the last argument isn't a function
redis.get('foo').then(function (result) {
console.log(result);
});
// Arguments to commands are flatten, so the following are same:
redis.sadd('set', 1, 3, 5, 7);
redis.sadd('set', [1, 3, 5, 7]);
```
## Connect to Redis
When a new `Redis` instance is created,
a connection to Redis will be created at the same time.
You can specify which Redis to connect to by:
```javascript
new Redis() // Connect to 127.0.0.1:6379
new Redis(6380) // 127.0.0.1:6380
new Redis(6379, '192.168.1.1') // 192.168.1.1:6379
new Redis('redis://:authpassword@127.0.0.1:6380/4') // 127.0.0.1:6380, db 4
new Redis('/tmp/redis.sock')
new Redis({
port: 6379, // Redis port
host: '127.0.0.1', // Redis host
family: 4, // 4(IPv4) or 6(IPv6)
password: 'auth'
db: 0
})
```
See [API Documentation](API.md#new_Redis) for all available options.
## Pub/Sub
Here is a simple example of the API for publish / subscribe.
The following program opens two client connections.
It subscribes to a channel with one connection,
and publishes to that channel with the other:
```javascript
var Redis = require('ioredis');
var redis = new Redis();
// or: var redis = Redis();
var pub = new Redis();
redis.subscribe('news', 'music', function (err, count) {
// Now both channel 'news' and 'music' are subscribed successfully.
// `count` represents the number of channels we are currently subscribed to.
var redisOnPort6380 = new Redis(6380);
var anotherRedis = new Redis(6380, '192.168.100.1');
var unixSocketRedis = new Redis({ path: '/tmp/echo.sock' });
var unixSocketRedis2 = new Redis('/tmp/echo.sock');
var urlRedis = new Redis('redis://user:password@redis-service.com:6379/');
var urlRedis2 = new Redis('//localhost:6379');
var authedRedis = new Redis(6380, '192.168.100.1', { auth: 'password' });
pub.publish('news', 'Hello world!');
pub.publish('music', 'Hello again!');
});
redis.on('message', function (channel, message) {
// Receive message Hello world! from channel news
// Receive message Hello again! from channel music
console.log('Receive message %s from channel %s', message, channel);
});
// There's also a event called 'messageBuffer', which is same to 'message' except
// it returns buffers instead of strings.
redis.on('messageBuffer', function (channel, message) {
// Both `channel` and `message` are buffers.
});
```
<a name="Redis#connect"></a>
### redis.connect()
Create a connection to Redis.
This method will be invoked automatically when creating a new Redis instance.
**Kind**: instance method of <code>[Redis](#Redis)</code>
**Access:** public
<a name="Redis#disconnect"></a>
### redis.disconnect()
Disconnect from Redis.
`PSUBSCRIBE` is also supported in a similar way:
This method closes the connection immediately,
and may lose some pending replies that haven't written to client.
If you want to wait for the pending replies, use Redis#quit instead.
```javascript
redis.psubscribe('pat?ern', function (err, count) {});
redis.on('pmessage', function (pattern, channel, message) {});
redis.on('pmessageBuffer', function (pattern, channel, message) {});
```
**Kind**: instance method of <code>[Redis](#Redis)</code>
**Access:** public
<a name="Redis#end"></a>
### ~~redis.end()~~
***Deprecated***
When a client issues a SUBSCRIBE or PSUBSCRIBE, that connection is put into a "subscriber" mode.
At that point, only commands that modify the subscription set are valid.
When the subscription set is empty, the connection is put back into regular mode.
Disconnect from Redis.
If you need to send regular commands to Redis while in subscriber mode, just open another connection.
**Kind**: instance method of <code>[Redis](#Redis)</code>
<a name="Redis#duplicate"></a>
### redis.duplicate()
Create a new instance, using the same options.
## Handle Binary Data
Arguments can be buffers:
```javascript
redis.set('foo', new Buffer('bar'));
```
**Kind**: instance method of <code>[Redis](#Redis)</code>
**Access:** public
**Example**
```js
var redis = new Redis(6380);
var anotherRedis = redis.duplicate();
And every command has a method that returns a Buffer (by adding a suffix of "Buffer" to the command name).
To get a buffer instead of a utf8 string:
```javascript
redis.getBuffer('foo', function (err, result) {
// result is a buffer.
});
```
<a name="Redis#monitor"></a>
### redis.monitor([callback])
Listen for all requests received by the server in real time.
This command will create a new connection to Redis and send a
MONITOR command via the new connection in order to avoid disturbing
the current connection.
## Pipelining
If you want to send a batch of commands(e.g. > 5), you can use pipelining to queue
the commands in the memory, then send them to Redis all at once. This way the performance improves by 50%~300%(See [benchmark section](#benchmark)).
**Kind**: instance method of <code>[Redis](#Redis)</code>
**Access:** public
`redis.pipeline()` creates a `Pipeline` instance. You can call any Redis
commands on it just like the `Redis` instance. The commands are queued in the memory
and flushed to Redis by calling `exec` method:
| Param | Type | Description |
| --- | --- | --- |
| [callback] | <code>function</code> | The callback function. If omit, a promise will be returned. |
```javascript
var pipeline = redis.pipeline();
pipeline.set('foo', 'bar');
pipeline.del('cc');
pipeline.exec(function (err, results) {
// `err` is always null, and `results` is an array of responses
// corresponding the sequence the commands where queued.
// Each response follows the format `[err, result]`.
});
**Example**
```js
// You can even chain the commands:
redis.pipeline().set('foo', 'bar').del('cc').exec(function (err, results) {
});
// `exec` also returns a Promise:
var promise = redis.pipeline().set('foo', 'bar').get('foo').exec();
promise.then(function (result) {
// result === [[null, 'OK'], [null, 'bar']]
});
```
Each chained command can also have a callback, which will be invoked when the command
get a reply:
```javascript
redis.pipeline().set('foo', 'bar').get('foo', function (err, result) {
// result === 'bar'
}).exec(function (err, result) {
// result[1][1] === 'bar'
});
```
## Transaction
Most of the time the transaction commands `multi` & `exec` are used together with pipeline.
Therefore by default when `multi` is called, a `Pipeline` instance is created automatically,
so that you can use `multi` just like `pipeline`:
```javascript
redis.multi().set('foo', 'bar').get('foo').exec(function (err, results) {
// results === [[null, 'OK'], [null, 'bar']]
});
```
If there's a syntax error in the transaction's command chain (e.g. wrong number of arguments, wrong command name, etc),
then none of the commands would be executed, and an error is returned:
```javascript
redis.multi().set('foo').set('foo', 'new value').exec(function (err, results) {
// err:
// { [ReplyError: EXECABORT Transaction discarded because of previous errors.]
// name: 'ReplyError',
// message: 'EXECABORT Transaction discarded because of previous errors.',
// command: { name: 'exec', args: [] },
// previousErrors:
// [ { [ReplyError: ERR wrong number of arguments for 'set' command]
// name: 'ReplyError',
// message: 'ERR wrong number of arguments for \'set\' command',
// command: [Object] } ] }
});
```
In terms of the interface, `multi` differs from `pipeline` in that when specifying a callback
to each chained command, the queueing state is passed to the callback instead of the result of the command:
```javascript
redis.multi().set('foo', 'bar', function (err, result) {
// result === 'QUEUED'
}).exec(/* ... */);
```
If you want to use transaction without pipeline, pass { pipeline: false } to `multi`,
and every command would be sent to Redis immediately without waiting for an `exec` invokation:
```javascript
redis.multi({ pipeline: false });
redis.set('foo', 'bar');
redis.get('foo');
redis.exec(function (err, result) {
// result === [[null, 'OK'], [null, 'bar']]
});
```
Inline transaction is supported by pipeline, that means you can group a subset commands
in the pipeline into a transaction:
```javascript
redis.pipeline().get('foo').multi().set('foo', 'bar').get('foo').exec().get('foo').exec();
```
## Arguments & Replies Transform
Most Redis commands take one or more Strings as arguments,
and replies are sent back as a single String or an Array of Strings. However sometimes
you may want something different: For instance it would be more convenient if HGETALL
command returns a hash (e.g. `{key: val1, key2: v2}`) rather than an array of key values (e.g. `[key1,val1,key2,val2]`).
ioredis has a flexible system for transforming arguments and replies. There are two types
of transformers, argument transform and reply transformer:
```javascript
var Redis = require('ioredis');
// define a argument transformer that convert
// hmset('key', { k1: 'v1', k2: 'v2' })
// or
// hmset('key', new Map([['k1', 'v1'], ['k2', 'v2']]))
// into
// hmset('key', 'k1', 'v1', 'k2', 'v2')
Redis.Command.setArgumentTransformer('hmset', function (args) {
if (args.length === 2) {
if (typeof Map !== 'undefined' && args[1] instanceof Map) {
return [args[0]].concat(utils.convertMapToArray(args[1]));
}
if ( typeof args[1] === 'object' && args[1] !== null) {
return [args[0]].concat(utils.convertObjectToArray(args[1]));
}
}
return args;
});
// define a reply transformer that convert the reply
// ['k1', 'v1', 'k2', 'v2']
// into
// { k1: 'v1', 'k2': 'v2' }
Redis.Command.setReplyTransformer('hgetall', function (result) {
if (Array.isArray(result)) {
var obj = {};
for (var i = 0; i < result.length; i += 2) {
obj[result[i]] = result[i + 1];
}
return obj;
}
return result;
});
```
There are three built-in transformers, two argument transformers for `hmset` & `mset` and
a reply transformer for `hgetall`. Transformers for `hmset` and `hgetall` has been mentioned
above, and the transformer for `mset` is similar to the one for `hmset`:
```javascript
redis.mset({ k1: 'v1', k2: 'v2' });
redis.get('k1', function (err, result) {
// result === 'v1';
});
redis.mset(new Map([['k3', 'v3'], ['k4', 'v4']]));
redis.get('k3', function (err, result) {
// result === 'v3';
});
```
## Lua Scripting
ioredis supports all of the scripting commands such as `EVAL`, `EVALSHA` and `SCRIPT`.
However it's tedious to use in real world scenarios since developers have to take
care of script caching and to detect when to use `EVAL` and when to use `EVALSHA`.
ioredis expose a `defineCommand` method to make scripting much easier to use:
```javascript
var redis = new Redis();
// This will define a command echo:
redis.defineCommand('echo', {
numberOfKeys: 2,
lua: 'return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}'
});
// Now `echo` can be used just like any other ordinary commands,
// and ioredis will try to use `EVALSHA` internally when possible for better performance.
redis.echo('k1', 'k2', 'a1', 'a2', function (err, result) {
// result === ['k1', 'k2', 'a1', 'a2']
});
// `echoBuffer` is also defined automatically to return buffers instead of strings:
redis.echoBuffer('k1', 'k2', 'a1', 'a2', function (err, result) {
// result[0] === new Buffer('k1');
});
// And of course it works with pipeline:
redis.pipeline().set('foo', 'bar').echo('k1', 'k2', 'a1', 'a2').exec();
```
If the number of keys can't be determined when defining a command, you can
omit the `numberOfKeys` property, and pass the number of keys as the first argument
when you call the command:
```javascript
redis.defineCommand('echoDynamicKeyNumber', {
lua: 'return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}'
});
// Now you have to pass the number of keys as the first argument every time
// you invoke the `echoDynamicKeyNumber` command:
redis.echoDynamicKeyNumber(2, 'k1', 'k2', 'a1', 'a2', function (err, result) {
// result === ['k1', 'k2', 'a1', 'a2']
});
```
## Monitor
Redis supports the MONITOR command,
which lets you see all commands received by the Redis server across all client connections,
including from other client libraries and other computers.
The `monitor` method returns a monitor instance.
After you send the MONITOR command, no other commands are valid on that connection. ioredis would emit a monitor event for every new monitor message that comes across.
The callback for the monitor event takes a timestamp from the Redis server and an array of command arguments.
Here is a simple example:
```javascript
redis.monitor(function (err, monitor) {
// Entering monitoring mode.
monitor.on('monitor', function (time, args) {
console.log(time + ": " + util.inspect(args));
});
});
```
// supports promise as well as other commands
redis.monitor().then(function (monitor) {
monitor.on('monitor', function (time, args) {
console.log(time + ": " + util.inspect(args));
});
## Auto-reconnect
By default, ioredis will try to reconnect when the connection to Redis is lost
except when the connection is closed manually by `redis.disconnect()` or `redis.quit()`.
It's very flexible to control how long to wait to reconnect after disconnected
using the `retryStrategy` option:
```javascript
var redis = new Redis({
// This is the default value of `retryStrategy`
retryStrategy: function (times) {
var delay = Math.min(times * 2, 2000);
return delay;
}
});
```
<a name="Commander#defineCommand"></a>
### redis.defineCommand(name, definition)
Define a custom command using lua script
**Kind**: instance method of <code>[Redis](#Redis)</code>
`retryStrategy` is a function that will be called when the connection is lost.
The argument `times` represents this is the nth reconnection being made and
the return value represents how long(ms) to wait to reconnect. When the
return value isn't a number, ioredis will stop trying reconnecting and the connection
will be lost forever if user don't call `redis.connect()` manually.
| Param | Type | Default | Description |
| --- | --- | --- | --- |
| name | <code>string</code> | | the command name |
| definition | <code>object</code> | | |
| definition.lua | <code>string</code> | | the lua code |
| [definition.numberOfKeys] | <code>number</code> | <code></code> | the number of keys. If omit, you have to pass the number of keys as the first argument every time you invoke the command |
## Connection Events
Redis instance will emit some events about the state of the connection to the Redis server.
<a name="Redis.createClient"></a>
### ~~Redis.createClient()~~
***Deprecated***
### "connect"
client will emit `connect` once a connection is established to the Redis server.
Create a Redis instance
### "ready"
If `enableReadyCheck` is `true`, client will emit `ready` when the server reports that it is ready to receive commands.
Otherwise `ready` will be emitted immediately right after the `connect` event.
**Kind**: static method of <code>[Redis](#Redis)</code>
<a name="Commander"></a>
## Commander
**Kind**: global class
### "end"
client will emit `end` when an established Redis server connection has closed.
* [Commander](#Commander)
* [new Commander()](#new_Commander_new)
* [.defineCommand(name, definition)](#Commander#defineCommand)
## Offline Queue
When a command can't be processed by Redis(e.g. the connection hasn't been established or
Redis is loading data from disk), by default it's added to the offline queue and will be
executed when it can be processed. You can disable this feature by set `enableOfflineQueue`
option to `false`:
<a name="new_Commander_new"></a>
### new Commander()
Commander
```javascript
var redis = new Redis({ enableOfflineQueue: false });
```
## Sentinel
ioredis supports Sentinel out of the box. It works transparently as all features that work when
you connect to a single node also work when you connect to a sentinel group. Make sure to run Redis 2.8+ if you want to use this feature.
| Param | Type | Default | Description |
| --- | --- | --- | --- |
| [options.showFriendlyErrorStack] | <code>boolean</code> | <code>false</code> | Whether to show a friendly error stack. Will decrease the performance significantly. |
To connect using Sentinel, use:
<a name="Commander#defineCommand"></a>
### commander.defineCommand(name, definition)
Define a custom command using lua script
```javascript
var redis = new Redis({
sentinels: [{ host: 'localhost', port: 26379 }, { host: 'localhost', port: 26380 }],
name: 'mymaster'
});
**Kind**: instance method of <code>[Commander](#Commander)</code>
redis.set('foo', 'bar');
```
| Param | Type | Default | Description |
| --- | --- | --- | --- |
| name | <code>string</code> | | the command name |
| definition | <code>object</code> | | |
| definition.lua | <code>string</code> | | the lua code |
| [definition.numberOfKeys] | <code>number</code> | <code></code> | the number of keys. If omit, you have to pass the number of keys as the first argument every time you invoke the command |
The arguments passed to the constructor are different from ones you used to connect to a single node, where:
<a name="defaultOptions"></a>
## defaultOptions
Default options
* `name` identifies a group of Redis instances composed of a master and one or more slaves (`mymaster` in the example);
* `sentinels` are a list of sentinels to connect to. The list does not need to enumerate all your sentinel instances, but a few so that if one is down the client will try the next one.
**Kind**: global variable
**Access:** protected
ioredis **guarantees** that the node you connected with is always a master even after a failover. When a failover happens, instead of trying to reconnect with the failed node(which will be demoted to slave when it's available again), ioredis will ask sentinels for the new master node and connect to it. All commands sent during the failover are queued and will be executed when the new connection is established so that none of the commands will be lost.
It's possible to connect to a slave instead of a master by specifying the option `role` with the value of `slave`, and ioredis will try to connect to a random slave of the specified master, with the guarantee that the connected node is always a slave. If the current node is promoted to master owing to a failover, ioredis will disconnect with it and ask sentinels for another slave node to connect to.
Besides `retryStrategy` option, there's also a `sentinelRetryStrategy` in Sentinel mode which will be invoked when all the sentinel nodes are unreachable during connecting. If `sentinelRetryStrategy` returns a valid delay time, ioredis will try to reconnect from scratch. The default value of `sentinelRetryStrategy` is:
```javascript
function (times) {
var delay = Math.min(times * 10, 1000);
return delay;
}
```
## Cluster
Redis Cluster provides a way to run a Redis installation where data is automatically sharded across multiple Redis nodes.
You can connect to a Redis Cluster like this:
```javascript
var Redis = require('ioredis');
var cluster = new Redis.Cluster([{
port: 6380,
host: '127.0.0.1'
}, {
port: 6381,
host: '127.0.0.1'
}]);
cluster.set('foo', 'bar');
cluster.get('foo', function (err, res) {
// res === 'bar'
});
```
`Cluster` constructor accepts two arguments, where:
0. The first argument is a list of nodes of the cluster you want to connect to.
Just like Sentinel, the list does not need to enumerate all your cluster nodes,
but a few so that if one is unreachable the client will try the next one, and the client will discover other nodes automatically when at least one node is connnected.
0. The second argument is the option that will be passed to the `Redis` constructor when creating connections to Redis nodes internally. There are some additional options for the Cluster:
* `clusterRetryStrategy`: When none of the startup nodes are reachable, `clusterRetryStrategy` will be invoked. When a number is returned,
ioredis will try to reconnect the startup nodes from scratch after the specified delay(ms). Otherwise an error of "None of startup nodes is available" will returned.
The default value of this option is:
```javascript
function (times) {
var delay = Math.min(100 + times * 2, 2000);
return delay;
}
```
* `refreshAfterFails`: When `MOVED` errors are received more times than `refreshAfterFails`, client will call CLUSTER SLOTS
command to refresh the slot cache. The default value is `4`.
* `maxRedirections`: When a `MOVED` or `ASK` error is received, client will redirect the
command to another node. This option limits the max redirections allowed when sending a command. The default value is `16`.
* `retryDelayOnFailover`: When the error of "Connection is closed." is received when sending a command,
ioredis will retry after the specified delay. The default value is `2000`. You should make sure to let `retryDelayOnFailover * maxRedirections > cluster-node-timeout`
in order to insure that no command will fails during a failover.
### Transaction and pipeline in Cluster mode
Almost all features that are supported by `Redis` also works in Cluster mode, e.g. custom commands, transaction and pipeline.
However there are something different when use transaction and pipeline in Cluster mode:
0. You can't use `multi` without pipeline(aka `cluster.multi({ pipeline: false })`). This is because when you call `cluster.multi({ pipeline: false })`, ioredis doesn't know which node should the `multi` command to be sent to.
0. With pipeline, cluster uses the first key in the pipeline queue as the sample key to calculate the slot, and all commands in the pipeline will be sent to the node that the slot belongs to.
## hiredis
If [hiredis](https://github.com/redis/hiredis-node) is installed(by `npm install hiredis`),
ioredis will use it by default. Otherwise, a pure JavaScript parser will be used.
Typically there's not much differences between them in terms of performance.
<hr>
# Error Handling
All the errors returned by the Redis server are instances of `ReplyError`, which can be accessed via `Redis`:
```javascript
var Redis = require('ioredis');
var redis = new Redis();
// This command causes an reply error since SET command requires two arguments.
redis.set('foo', function (err) {
// err instanceof Redis.ReplyError
});
```
When a reply error is not handled(no callback is specified and no `catch` method is chained),
the error will be logged to the stderr. For instance:
```javascript
var Redis = require('ioredis');
var redis = new Redis();
redis.set('foo');
```
The following error will be printed:
```
Unhandled rejection ReplyError: ERR wrong number of arguments for 'set' command
at ReplyParser._parseResult (/app/node_modules/ioredis/lib/parsers/javascript.js:60:14)
at ReplyParser.execute (/app/node_modules/ioredis/lib/parsers/javascript.js:178:20)
at Socket.<anonymous> (/app/node_modules/ioredis/lib/redis/event_handler.js:99:22)
at Socket.emit (events.js:97:17)
at readableAddChunk (_stream_readable.js:143:16)
at Socket.Readable.push (_stream_readable.js:106:10)
at TCP.onread (net.js:509:20)
```
But the error stack doesn't make any sense because the whole stack happens in the ioreids
module itself, not in your code. So it's not easy to find out where the error happens in your code.
ioredis provides an option `showFriendlyErrorStack` to solve the problem. When you enable
`showFriendlyErrorStack`, ioredis will optimize the error stack for you:
```javascript
var Redis = require('ioredis');
var redis = new Redis({ showFriendlyErrorStack: true });
redis.set('foo');
```
And the output will be:
```
Unhandled rejection ReplyError: ERR wrong number of arguments for 'set' command
at Object.<anonymous> (/app/index.js:3:7)
at Module._compile (module.js:446:26)
at Object.Module._extensions..js (module.js:464:10)
at Module.load (module.js:341:32)
at Function.Module._load (module.js:296:12)
at Function.Module.runMain (module.js:487:10)
at startup (node.js:111:16)
at node.js:799:3
```
This time the stack tells you that the error happens on the third line in your code, pretty sweet!
However, it would decrease the performance significantly to optimize the error stack. So by
default this option is disabled and can be only used for debug purpose. You **shouldn't** use this feature in production environment.
If you want to catch all unhandled errors without decrease performance, there's another way:
```javascript
var Redis = require('ioredis');
Redis.Promise.onPossiblyUnhandledRejection(function (error) {
// you can log the error here.
// error.command.name is the command name, here is 'set'
// error.command.args is the command arguments, here is ['foo']
});
var redis = new Redis();
redis.set('foo');
```
# Benchmark
Compares with [node_redis](https://github.com/mranney/node_redis):
```shell
> npm run bench
simple set
81,026 op/s » ioredis
43,487 op/s » node_redis
simple get
79,565 op/s » ioredis
41,808 op/s » node_redis
simple get with pipeline
12,711 op/s » ioredis
4,714 op/s » node_redis
lrange 100
61,149 op/s » ioredis
48,827 op/s » node_redis
Suites: 4
Benches: 8
Elapsed: 57,882.94 ms
```
You can find the code at `benchmarks/*.js` and run it yourself using `npm run bench`.
# Running tests
Start a Redis server on 127.0.0.1:6379, and then:
```shell
$ npm test
```
`FLUSH ALL` will be invoked after each test, so make sure there's no valuable data in it before running tests.
# Debug
You can set the `DEBUG` env to `ioredis:*` to print debug info:
```shell
$ DEBUG=ioredis:* node app.js
```
# Motivation
Originally we used the Redis client [node_redis](https://github.com/mranney/node_redis),
but over a period of time we found that it's not robust enough for us to use
in our production environment. The library has some non-trivial bugs and many unresolved
issues on the GitHub(165 so far). For instance:
```javascript
var redis = require('redis');
var client = redis.createClient();
client.set('foo', 'message');
client.set('bar', 'Hello world');
client.mget('foo', 'bar');
client.subscribe('channel');
client.on('message', function (msg) {
// Will print "Hello world", although no `publish` is invoked.
console.log('received ', msg);
});
```
I submitted some pull requests but sadly none of them has been merged, so here's ioredis.
# Join in!
I'm happy to receive bug reports, fixes, documentation enhancements, and any other improvements.
And since I'm not an English native speaker so if you find any grammar mistake in the documentation, please also let me know. :)
# Roadmap
* Transparent Key Prefixing
* [Distributed Lock](http://redis.io/topics/distlock)
* Connection Pooling & Read-Write Splitting
# Acknowledge
The JavaScript and hiredis parsers are modified from [node_redis](https://github.com/mranney/node_redis) (MIT License, Copyright (c) 2010 Matthew Ranney, http://ranney.com/).
# License
MIT

4

Changelog.md

@@ -5,2 +5,6 @@ ## Changelog

### v1.1.1 - May 2, 2015
* Support Transaction and pipelining in cluster mode.
### v1.1.0 - May 1, 2015

@@ -7,0 +11,0 @@

34

lib/cluster.js

@@ -12,3 +12,3 @@ 'use strict';

/**
* Creates a Redis instance
* Creates a Redis Cluster instance
*

@@ -177,6 +177,6 @@ * @constructor

Cluster.prototype.flushQueue = function (error) {
var command;
var item;
while (this.offlineQueue.length > 0) {
command = this.offlineQueue.shift();
command.reject(error);
item = this.offlineQueue.shift();
item.command.reject(error);
}

@@ -191,4 +191,4 @@ };

while (offlineQueue.length > 0) {
var command = offlineQueue.shift();
this.sendCommand(command);
var item = offlineQueue.shift();
this.sendCommand(item.command, item.stream, item.slot);
}

@@ -198,7 +198,7 @@ }

Cluster.prototype.sendCommand = function (command) {
var _this = this;
Cluster.prototype.sendCommand = function (command, stream, slot) {
var targetSlot = slot || command.getSlot();
var ttl = this.options.maxRedirections;
var reject = command.reject;
var _this = this;
command.reject = function (err) {

@@ -211,3 +211,3 @@ ttl -= 1;

var errv = err.message.split(' ');
if (errv[0] === 'MOVED' || errv[0] === 'ASK') {
if (!slot && (errv[0] === 'MOVED' || errv[0] === 'ASK')) {
var hostPort = errv[2].split(':');

@@ -246,3 +246,3 @@ var node = _this.createNode(hostPort[1], hostPort[0]);

var redis;
if (random || typeof command.getSlot() !== 'number') {
if (random || typeof targetSlot !== 'number') {
redis = _this.nodes[_.sample(Object.keys(_this.nodes))];

@@ -253,8 +253,12 @@ } else if (asking) {

} else {
redis = _this.slots[command.getSlot()];
redis = _this.slots[targetSlot];
}
if (redis) {
redis.sendCommand(command);
redis.sendCommand(command, stream);
} else if (_this.options.enableOfflineQueue) {
_this.offlineQueue.push(command);
_this.offlineQueue.push({
command: command,
stream: stream,
slot: slot
});
} else {

@@ -301,2 +305,4 @@ command.reject(new Error('Cluster isn\'t connected and enableOfflineQueue options is false'));

require('./transaction').addTransactionSupport(Cluster.prototype);
module.exports = Cluster;

24

lib/pipeline.js

@@ -7,2 +7,3 @@ 'use strict';

var Promise = require('bluebird');
var utils = require('./utils');

@@ -68,7 +69,12 @@ function Pipeline(redis) {

}
var isCluster = this.redis.constructor.name === 'Cluster';
// Check whether scripts exists.
var sampleKey;
// Check whether scripts exists and get a sampleKey.
var scripts = [];
for (var i = 0; i < this._queue.length; ++i) {
var item = this._queue[i];
if (isCluster && !sampleKey) {
sampleKey = item.getKeys()[0];
}
if (item.name !== 'evalsha') {

@@ -83,2 +89,10 @@ continue;

}
var sampleSlot;
if (isCluster) {
if (sampleKey) {
sampleSlot = utils.calcSlot(sampleKey);
} else {
sampleSlot = Math.random() * 16384 | 0;
}
}

@@ -113,3 +127,7 @@ var promise;

if (!--writePending) {
_this.redis.stream.write(data);
if (isCluster) {
_this.redis.slots[sampleSlot].stream.write(data);
} else {
_this.redis.stream.write(data);
}
}

@@ -121,3 +139,3 @@ }

if (_this._queue[i] instanceof Command) {
_this.redis.sendCommand(_this._queue[i], stream);
_this.redis.sendCommand(_this._queue[i], stream, sampleSlot);
}

@@ -124,0 +142,0 @@ }

40

lib/redis.js

@@ -7,3 +7,2 @@ 'use strict';

var Promise = require('bluebird');
var Pipeline = require('./pipeline');
var Command = require('./command');

@@ -404,41 +403,4 @@ var Commander = require('./commander');

Redis.prototype.pipeline = function () {
var pipeline = new Pipeline(this);
return pipeline;
};
require('./transaction').addTransactionSupport(Redis.prototype);
var multi = Redis.prototype.multi;
Redis.prototype.multi = function (options) {
if (options && options.pipeline === false) {
multi.call(this);
} else {
var pipeline = new Pipeline(this);
pipeline.multi();
var exec = pipeline.exec;
pipeline.exec = function (callback) {
exec.call(pipeline);
var promise = exec.call(pipeline);
return promise.then(function (result) {
var execResult = result[result.length - 1];
if (execResult[0]) {
throw execResult[0];
}
return utils.wrapMultiResult(execResult[1]);
}).nodeify(callback);
};
return pipeline;
}
};
var exec = Redis.prototype.exec;
Redis.prototype.exec = function (callback) {
var wrapper = function (err, results) {
if (Array.isArray(results)) {
results = utils.wrapMultiResult(results);
}
callback(err, results);
};
exec.call(this, wrapper);
};
/**

@@ -445,0 +407,0 @@ * Send a command to Redis

2

package.json
{
"name": "ioredis",
"version": "1.1.0",
"version": "1.1.1",
"description": "A delightful, performance-focused Redis client for Node and io.js",

@@ -5,0 +5,0 @@ "main": "index.js",

58

README.md

@@ -203,3 +203,12 @@ # ioredis

redis.multi().set('foo').set('foo', 'new value').exec(function (err, results) {
// err === new Error('...Transaction discarded because of previous errors.');
// err:
// { [ReplyError: EXECABORT Transaction discarded because of previous errors.]
// name: 'ReplyError',
// message: 'EXECABORT Transaction discarded because of previous errors.',
// command: { name: 'exec', args: [] },
// previousErrors:
// [ { [ReplyError: ERR wrong number of arguments for 'set' command]
// name: 'ReplyError',
// message: 'ERR wrong number of arguments for \'set\' command',
// command: [Object] } ] }
});

@@ -467,23 +476,30 @@ ```

but a few so that if one is unreachable the client will try the next one, and the client will discover other nodes automatically when at least one node is connnected.
0. The second argument is the option that will be passed to the `Redis` constructor when creating connections to Redis nodes internally. There are some additional options:
0. The second argument is the option that will be passed to the `Redis` constructor when creating connections to Redis nodes internally. There are some additional options for the Cluster:
0. `clusterRetryStrategy`: When none of the startup nodes are reachable, `clusterRetryStrategy` will be invoked. When a number is returned,
ioredis will try to reconnect the startup nodes from scratch after the specified delay(ms). Otherwise an error of "None of startup nodes is available" will returned.
The default value of this option is:
```javascript
function (times) {
var delay = Math.min(100 + times * 2, 2000);
return delay;
}
```
0. `refreshAfterFails`: When `MOVED` errors are received more times than `refreshAfterFails`, client will call CLUSTER SLOTS
command to refresh the slot cache. The default value is `4`.
0. `maxRedirections`: When a `MOVED` or `ASK` error is received, client will redirect the
command to another node. This option limits the max redirections allowed when sending a command. The default value is `16`.
0. `retryDelayOnFailover`: When the error of "Connection is closed." is received when sending a command,
ioredis will retry after the specified delay. The default value is `2000`. You should make sure to let `retryDelayOnFailover * maxRedirections > cluster-node-timeout`
in order to insure that no command will fails during a failover.
* `clusterRetryStrategy`: When none of the startup nodes are reachable, `clusterRetryStrategy` will be invoked. When a number is returned,
ioredis will try to reconnect the startup nodes from scratch after the specified delay(ms). Otherwise an error of "None of startup nodes is available" will returned.
The default value of this option is:
Currently pipeline isn't supported in the Cluster mode.
```javascript
function (times) {
var delay = Math.min(100 + times * 2, 2000);
return delay;
}
```
* `refreshAfterFails`: When `MOVED` errors are received more times than `refreshAfterFails`, client will call CLUSTER SLOTS
command to refresh the slot cache. The default value is `4`.
* `maxRedirections`: When a `MOVED` or `ASK` error is received, client will redirect the
command to another node. This option limits the max redirections allowed when sending a command. The default value is `16`.
* `retryDelayOnFailover`: When the error of "Connection is closed." is received when sending a command,
ioredis will retry after the specified delay. The default value is `2000`. You should make sure to let `retryDelayOnFailover * maxRedirections > cluster-node-timeout`
in order to insure that no command will fails during a failover.
### Transaction and pipeline in Cluster mode
Almost all features that are supported by `Redis` also works in Cluster mode, e.g. custom commands, transaction and pipeline.
However there are something different when use transaction and pipeline in Cluster mode:
0. You can't use `multi` without pipeline(aka `cluster.multi({ pipeline: false })`). This is because when you call `cluster.multi({ pipeline: false })`, ioredis doesn't know which node should the `multi` command to be sent to.
0. With pipeline, cluster uses the first key in the pipeline queue as the sample key to calculate the slot, and all commands in the pipeline will be sent to the node that the slot belongs to.
## hiredis

@@ -646,4 +662,6 @@ If [hiredis](https://github.com/redis/hiredis-node) is installed(by `npm install hiredis`),

We are happy to receive bug reports, fixes, documentation enhancements, and any other improvements.
I'm happy to receive bug reports, fixes, documentation enhancements, and any other improvements.
And since I'm not an English native speaker so if you find any grammar mistake in the documentation, please also let me know. :)
# Roadmap

@@ -650,0 +668,0 @@

45

test.js

@@ -8,2 +8,10 @@ 'use strict';

var Redis = require('./');
var redis = new Redis();
redis.multi().set('foo').set('foo', 'new value').exec(function (err, results) {
console.log('=', err);
// err === new Error('...Transaction discarded because of previous errors.');
/* err is: { [ReplyError: EXECABORT Transaction discarded because of previous errors.] }
res is undefined
*/
});
// var redis = new Redis();

@@ -37,13 +45,13 @@

// var redis = new Redis();
var redis = new Redis({
sentinels: [
{ host: 'localhost', port: 26379 }
],
name: 'master1'
});
// var redis = new Redis({
// sentinels: [
// { host: 'localhost', port: 26379 }
// ],
// name: 'master1'
// });
redis.set('foo', 'bar');
setInterval(function () {
redis.get('foo', console.log);
}, 1000);
// redis.set('foo', 'bar');
// setInterval(function () {
// redis.get('foo', console.log);
// }, 1000);

@@ -125,11 +133,14 @@ // setTimeout(function () {

// var cluster = new Redis.Cluster([{
// port: 6380,
// host: '127.0.0.1'
// }, {
// port: 6381,
// host: '127.0.0.1'
// }], { showFriendlyErrorStack: true });
var cluster = new Redis.Cluster([{
port: 6380,
host: '127.0.0.1'
}, {
port: 6381,
host: '127.0.0.1'
}], { showFriendlyErrorStack: true });
cluster.multi().set('foo', 'bar').get('foo2').exec(console.log);
cluster.pipeline().set('foo', 'bar').get('foo2').exec(console.log);
// setTimeout(function () {

@@ -136,0 +147,0 @@ // // cluster.disconnect();

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc