重新定义Redis模块封装实践（redis 模块封装）

重新定义Redis：模块封装实践

Redis 是一款高性能的 NoSQL 数据库，被广泛应用于各种互联网服务中。它使用内存存储数据，具有非常高的读写速度，并支持多种数据结构。不过，由于 Redis 提供的命令非常基础，不能满足所有业务场景的需求，很多开发者需要编写复杂的 Lua 脚本来扩展功能，这对于开发效率和代码可维护性都是一种挑战。

为了解决这个问题，我在项目中尝试了一种新的思路：模块封装。通过将常用的功能封装为模块，不仅能够简化代码，还能够提高代码的可读性和可维护性。下面我将详细介绍这个实践的过程。

1. 定义模块接口

我们需要确定每个模块需要提供哪些接口。在这个过程中，我们需要综合考虑这个模块的功能、使用场景以及使用频率等因素。比如，在我的项目中，我们需要使用的 Redis 功能包括：set、get、hset、hget、sadd、smembers、zadd、zrevrange、del 等，因此我们可以将这些功能分别封装为不同的模块。

例如，我们将 set 和 get 封装为 String 模块：

class RedisString {
  constructor(client) {
    this.client = client;
  }

  async set(key, value) {
    return awt this.client.set(key, value);
  }

  async get(key) {
    return awt this.client.get(key);
  }
}

同样地，我们将 hset 和 hget 封装为 Hash 模块：

class RedisHash {
  constructor(client) {
    this.client = client;
  }

  async hset(key, field, value) {
    return awt this.client.hset(key, field, value);
  }

  async hget(key, field) {
    return awt this.client.hget(key, field);
  }
}

以此类推。

2. 模块组合

在确定了每个模块的接口后，我们需要将它们组合起来，形成真正可用的 Redis 类。这个类可以包含一个 Redis 客户端对象，以及所有的模块对象。在这个类中，我们将每个模块的方法都作为类方法来暴露，例如：

class Redis {
  constructor(options) {
    this.client = new RedisClient(options);
    this.string = new RedisString(this.client);
    this.hash = new RedisHash(this.client);
  }

  static async set(key, value) {
    return awt this.string.set(key, value);
  }

  static async get(key) {
    return awt this.string.get(key);
  }

  static async hset(key, field, value) {
    return awt this.hash.hset(key, field, value);
  }

  static async hget(key, field) {
    return awt this.hash.hget(key, field);
  }

  // ...
}

这样，在使用 Redis 时，我们只需要调用类方法即可完成相应的操作，例如：

awt Redis.set('my:key', 'value');
const value = awt Redis.get('my:key');
awt Redis.hset('my:hash', 'field', 'value');
const fieldValue = awt Redis.hget('my:hash', 'field');

3. 模块扩展

封装好了基础模块后，我们可以根据需要进行模块扩展。例如，我们在项目中需要使用带有过期时间的 string 类型数据，我们可以扩展 String 模块来支持这个功能：

class RedisStringWithExpire extends RedisString {
  async setex(key, ttl, value) {
    return awt this.client.setex(key, ttl, value);
  }
}

同样地，我们可以扩展 Hash 模块来支持批量 set 和 get 操作：

class RedisHashWithBatch extends RedisHash {
  async mset(obj) {
    return awt this.client.hmset(obj);
  }

  async mget(key, fields) {
    const values = awt this.client.hmget(key, fields);
    return _.zipObject(fields, values);
  }
}

这样，我们就能够根据实际需求来扩展 Redis 的功能，而不需要再编写冗长的 Lua 脚本。

总结

通过模块封装的方法，我们成功地简化了 Redis 的使用，提高了代码可读性和可维护性。这种思路也可以应用于其他项目中，以达到降低代码复杂度和提高开发效率的目的。

附：完整代码

const RedisClient = require('redis');
const _ = require('lodash');

class RedisString {
  constructor(client) {
    this.client = client;
  }
  async set(key, value) {
    return awt this.client.set(key, value);
  }

  async get(key) {
    return awt this.client.get(key);
  }
}
class RedisHash {
  constructor(client) {
    this.client = client;
  }
  async hset(key, field, value) {
    return awt this.client.hset(key, field, value);
  }

  async hget(key, field) {
    return awt this.client.hget(key, field);
  }
}
class Redis {
  constructor(options) {
    this.client = new RedisClient(options);
    this.string = new RedisString(this.client);
    this.hash = new RedisHash(this.client);
  }
  static async set(key, value) {
    return awt this.string.set(key, value);
  }

  static async get(key) {
    return awt this.string.get(key);
  }

  static async hset(key, field, value) {
    return awt this.hash.hset(key, field, value);
  }

  static async hget(key, field) {
    return awt this.hash.hget(key, field);
  }

  static async mset(obj) {
    return awt this.client.hmset(obj);
  }

  static async mget(key, fields) {
    const values = awt this.client.hmget(key, fields);
    return _.zipObject(fields, values);
  }
}

class RedisStringWithExpire extends RedisString {
  async setex(key, ttl, value) {
    return awt this.client.setex(key, ttl, value);
  }
}

class RedisHashWithBatch extends RedisHash {
  async mset(obj) {
    return awt this.client.hmset(obj);
  }
  async mget(key, fields) {
    const values = awt this.client.hmget(key, fields);
    return _.zipObject(fields, values);
  }
}

module.exports = {
  Redis,
  RedisStringWithExpire,
  RedisHashWithBatch,
};