一、get&set方法 && 哈希表hset&hgetall && BlueBird

/src/config/index.js
  1. const DB_URL = 'mongodb://test:123456@203.195.161.212:15001/testdb'
  3. const REDIS = {
  4.   host: '203.195.161.212',
  5.   port: 15001,
  6.   password: '123456'
  7. }
  9. export default {
  10.   DB_URL,
  11.   REDIS
  12. }

/src/config/RedisConfig.js
  1. import redis from 'redis'
  2. import { promisifyAll } from 'bluebird'
  3. import config from './index'
  5. const options = {
  6.   host: config.REDIS.host,
  7.   port: config.REDIS.port,
  8.   password: config.REDIS.password,
  9.   detect_buffers: true,
  10.   retry_strategy: function(options) {   // 重试
  11.     if (options.error && options.error.code === "ECONNREFUSED") {
  12.       // End reconnecting on a specific error and flush all commands with
  13.       // a individual error
  14.       return new Error("The server refused the connection");
  15.     }
  16.     if (options.total_retry_time > 1000 * 60 * 60) {
  17.       // End reconnecting after a specific timeout and flush all commands
  18.       // with a individual error
  19.       return new Error("Retry time exhausted");
  20.     }
  21.     if (options.attempt > 10) {
  22.       // End reconnecting with built in error
  23.       return undefined;
  24.     }
  25.     // reconnect after
  26.     return Math.min(options.attempt * 100, 3000);
  27.   }
  28. }
  30. // const client = redis.createClient(options)
  31. const client = promisifyAll(redis.createClient(options))
  33. client.on('error', err => {
  34.   console.log(`Redis Client Error:${err}`)
  35. })
  37. const setValue = (key, value) => {
  38.   if (typeof value === 'undefined' || value === null || value === '') {
  39.     return
  40.   }
  41.   if (typeof value === 'string') {
  42.     client.set(key, value)
  43.   } else if (typeof value === 'object') {
  44.     Object.keys(value).forEach(item => {
  45.       client.hset(key, item, value[item], redis.print) //redis.print返回日志信息
  46.     })
  47.   }
  48. }
  50. // const { promisify } = require("util");
  51. // const getAsync = promisify(client.get).bind(client);
  53. const getValue = (key) => {
  54.   return client.getAsync(key)
  55. }
  57. const getHValue = (key) => {
  58.   // v8 Promisify method use util, must node > 8
  59.   // return promisify(client.hgetall).bind(client)(key) // hgetall转成promise方法 @return function
  61.   // bluebird async
  62.   return client.hgetallAsync(key)
  63. }
  65. const delValue = (key) => {
  66.   client.del(key, (err, res) => {
  67.     if (res === 1) {
  68.       console.log('delete successfully')
  69.     } else {
  70.       console.log(`delete redis key error:${err}`)
  71.     }
  72.   })
  73. }
  75. export {
  76.   client,
  77.   getValue,
  78.   setValue,
  79.   getHValue,
  80.   delValue
  81. }

/src/config/test.js
  1. import {getHValue, getValue, setValue, delValue} from "./RedisConfig"
  3. setValue('sampson', 'sampson message from redis client')
  5. getValue('sampson').then(res => {
  6.   console.log(`getValue:${res}`)
  7. })
  9. delValue('sampson')
  11. setValue('sampsonobj', {name: 'sampson', age: 30, email: '419582275@qq.com'})
  13. getHValue('sampsonobj').then((res) => {
  14.   console.log(`getHValue:${JSON.stringify(res, null, 2)}`)
  15. })

redis资料参考