node.js中 redis 的安装和基本操作示例

redis-server.exe --service-install redis.windows-service.conf --loglevel verbose

redis-server --service-start

//设置值
set name xiaoxu
//获取值
get name
//获取子字符串，包含开始和结束索引的字符
getrange name 0 -1
getrange name 1 3
//自增加1
set age 1
incr age
//指定增加的数量
incrby age 5
//递减1
decr age
//指定递减的数量
decrby age 3
//删除指定的键
del age
//判断键是否存在
exists name
//设置过期时间，单位秒
expire name 10
//查看剩余生存时间
ttl name
//获取键的值类型
type name

//设置单个值
hset person name xiao
//设置多个值
hmset person age 24 height 172
//获取单个值
hget person name
//获取多个值
hmget person age height
//获取所有值
hgetall person
//删除键
hdel person name
//获取所有的键
hkeys person

//往列表左边插入
lpush list 1
lpush list 2
//往列表右边插入
rpush list 3
rpush list 4
//查看列表元素
lrange list 0 -1
//弹出元素
lpop list
rpop list
//通过索引获取元素
lindex list 1
//获取列表的长度
llen list
//删除列表的元素
//lrem key count value
// count > 0时，从表头开始搜索，删除与value相等的元素，数量为count
// count < 0时，从表尾开始搜索，删除与value相等的元素，数量为count绝对值
// count = 0时，删除列表中所有与value相等的元素
lrem list 1 1
lrem list -1 2

//添加元素
sadd label 1 2 3
//查看集合
smembers label
//获取集合个数
scard label
//删除元素
srem label 2
//交集
sadd a 1 2 3
sadd b 2 3 4
sinter a b
//差集
sdiff a b
//并集
sunion a b

//添加有序成员
zadd xiaoxu 60 math 77 english 80 chinaese
//获取有序成员数量
zcard xiaoxu
//查看有序集合
zrange xiaoxu 0 -1
//查看有序集合，显示分数
zrange xiaoxu 0 -1 withscores
//删除有序集合中的成员
zrem xiaoxu math

npm install redis --save

const redis = require('redis');
//创建一个redis客户端
let client = redis.createClient(6379, '127.0.0.1');
//操作redis基本跟在命令行操作一致
client.set('name', 'xiaoxu', function (err, result) {
  if (err) {
    console.log(err);
  }
  console.log(result);
});
client.hmset('person', 'name', 'xiaoxu', 'age', '25', function (err, result) {
  if (err) {
    console.log(err);
  }
  console.log(result);
});
client.hmget('person', 'name', 'age', function (err, result) {
  if (err) {
    console.log(err);
  }
  console.log(result);
});
client.hkeys('person', function (err, result) {
  if (err) {
    console.log(err);
  }
  result.forEach(function (value) {
    client.hget('person', value, function (err, result) {
      console.log(value, result);
    });
  });
  //退出
  client.quit();
});

const redis = require('redis');
const bluebird = require('bluebird');
//通过bluebird包装
bluebird.promisifyAll(redis.RedisClient.prototype);
bluebird.promisifyAll(redis.Multi.prototype);
//创建一个redis客户端
let client = redis.createClient(6379, '127.0.0.1');
(async function () {
  //方法名后面都加上Async
  let result = await client.setAsync('name', 'hehe');
  console.log(result);
  result = await client.hmsetAsync('person', 'name', 'xiaoxu', 'age', '25');
  console.log(result);
  result = await client.hkeysAsync('person');
  console.log(result);
  result.forEach(async function (value) {
    let v = await client.hgetAsync('person', value);
    console.log(value, v);
  });
  client.quit();
})();

const redis = require('redis');
let clientA = redis.createClient(6379, '127.0.0.1');
let clientB = redis.createClient(6379, '127.0.0.1');
//客户端A订阅频道
clientA.subscribe('news');
clientA.subscribe('sports');
//客户端A监听消息
clientA.on('message', function (channel, message) {
  console.log('客户端A收到', channel, message);
  //客户端A在10秒后取消订阅
  setTimeout(function () {
    clientA.unsubscribe('news');
  }, 10000);
});
setInterval(function () {
  clientB.publish('news', '这是一条新闻' + new Date().toLocaleString());
  clientB.publish('sports', '这是一条体育' + new Date().toLocaleString());
}, 1000);

const redis = require('redis');
let client = redis.createClient(6379, '127.0.0.1');
client.multi()
.hset('person', 'name', 'haohao')
.hset('person', 'age', '34')
.exec(function (err, result) {
  if (err) {
    console.log(err);
  }
  console.log(result);
  client.quit();
});