redis.client.js 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. /**
  2. * Redis客户端封装。
  3. *
  4. * 注意Redis使用Promises保证调用流程。
  5. *
  6. * https://github.com/NodeRedis/node_redis
  7. *
  8. * author: linzhuo
  9. * since: 2016/12/09
  10. */
  11. "use strict";
  12. let redis = require('redis');
  13. let Promise = require('bluebird');
  14. let configFile = require('../../include/commons').CONFIG_FILE;
  15. let config = require('../../resources/config/' + configFile);
  16. let log = require("../../util/log.js");
  17. let redisClient = null;
  18. // 启用promises
  19. Promise.promisifyAll(redis.RedisClient.prototype);
  20. Promise.promisifyAll(redis.Multi.prototype);
  21. class RedisClient {
  22. constructor() {
  23. this._connection = redis.createClient(
  24. config.redisConfig
  25. );
  26. this._connection.on('connect', function (res) {
  27. log.info('Redis is connected.');
  28. });
  29. this._connection.on('error', function (res) {
  30. log.error("Redis connect failed.");
  31. process.exit(2);
  32. })
  33. }
  34. get connection() {
  35. return this._connection;
  36. }
  37. static redisClient() {
  38. if (redisClient == null) {
  39. redisClient = new RedisClient();
  40. }
  41. return redisClient;
  42. }
  43. }
  44. module.exports = RedisClient;