【原创】Node + Redis简单入门手册

Redis

安装依赖包

npm install -save redis

创建redis连接

const redis = require('redis');
const client = redis.createClient(6379, '127.0.0.1');

client.info(function(error, response){
    console.log(error, response);
})

其中 createClient(port, host, options) 函数可接受三个参数，第一个参数是连接端口,第二个参数是主机IP/名称,第三个参数则是配置项,KEY=>VALUE形式，如：

const client = redis.createClient(63719, '127.0.0.1', {connect_timeout:1}); //增加超时选项（毫秒）

使用方法示例

SET

client.set(key, value, callback) callback函数有2个回调参数，error和response，error表示操作过程中的错误提示值为null表示没有错误，response为String类型

client.set('name', 'Nemo', function(error, response){
    console.log(error, response); // will print: null 'OK'
});

若传入的对象是json，则需要进行转换，否则会出错
错误示例：

client.set('student', {name: 'Nemo', age: 22}, function(error, response){
    console.log(error, response);
});

client.get('student', function(err,response){
    console.log(err, response); //will print Nemo
});

结果：

Object

正确示例：

// 重写toString方法
Object.prototype.toString = function() {
    return JSON.stringify(this);
}

client.set('student', {name: 'Nemo', age: 22}, function(error, response){
    console.log(error, response);
});

client.get('student', function(err,response){
    console.log(err, response); //will print Nemo
});

结果：

json

GET

client.get(key, callback) callback函数有2个回调参数，error和value，error表示操作过程中的错误提示值为null表示没有错误，value为获取的值：null表示未获取到当前key对应的值，redis中不存在，

client.get('name', function(err, value){
    console.log(err, value); //will print: null 'Nemo'
})

消息中介

redis中支持订阅与发布
订阅方：

const redis = require('redis');
const client = redis.createClient(6379, '127.0.0.1');

client.subscribe('OneTest');

client.on('message', function(channel, msg){
  console.log('client.on message, channel:', channel, ' message:', msg);
});

发布方：

const redis = require('redis');
const client = redis.createClient(6379, '127.0.0.1');

client.publish('OneTest', 'message form subscription');

先后启动订阅方、发布方：

订阅与发布

Promises

当你的Node环境为v8或以上版本，推荐使用promisify来操作redis：

const redis = require('redis');
const { promisify } = require('util');
const client = redis.createClient(6379, '127.0.0.1');
const getAsync = promisify(client.get).bind(client);

// 使用方法①
return getAsync('student').then(function(res) {
    console.log(res); // => '{"name":"Nemo","age":22}'
});

// 使用法法②
async function student() {
    const res = await getAsync('student');
    console.log(res); // => '{"name":"Nemo","age":22}'
};

student();

未完待续~~~

本文参考资源如下：

• https://github.com/NodeRedis/node_redis