Redis中的动态字符串实现(下) redis字符串操作命令

用于处理Strings内容的操作函数

sds sdsgrowzero(sds s, size_t len);

sdsgrowzero内部通过调用sdsMakeRoomFor将sds的缓存区增加sdshdr.len的长度， 同时将新增的缓冲区初始化为0。

sds sdscatlen(sds s, const void *t, size_t len);
sds sdscat(sds s, const char *t);
sds sdscatsds(sds s, const sds t);

上面这三个接口函数都是用来执行sds数据的连接操作。 sdscatlen会向sds数据中扩展一段二进制安全的数据，这个上述三个函数的基础， 其余两个函数都是通过调用sdscatlen来实现的。 其内部会通过调用sdsMakeRoomFor尝试将sds的缓冲区进行扩展。 而函数sdscat会向sds中连接一个C风格字符串数据，sdscatsds函数则会执行两个sds数据的连接操作。 值得注意的是，上面三个函数均未对target数据执行释放操作，调用者需要根据自己的需求对target数据执行响应的操作。

sds sdsjoin(char **argv, int argc, char *sep);
sds sdsjoinsds(sds *argv, int argc, const char *sep, size_t seplen);

上述两个函数与sdscat系列接口类似，是执行一组C风格字符串或者sds数据的连接操作， 同时会以sep作为分隔符。

sds sdscpylen(sds s, const char *t, size_t len);
sds sdscpy(sds s, const chart *t);

实现了向sds数据中复制数据的功能，与memcpy接口类似，会覆盖已有的数据。 上述两个函数分别实现了二进制安全数据的拷贝以及C风格字符串的拷贝。

int sdsll2str(char *s, long long value);
int sdsull2str(char *s, unsigned long long value);

上述两个函数分别用于将有符号和无符号的long long整数转化为字符串，同时返回字符串长度。 注意其内部有一个自己实现的字符串翻转算法。

sds sdsfromlonglong(long long value);

从一个long long整形数构建一个sds数据，类似调用int sprintf(char *str, const char *format, ...) 将一个整形数字写入一个字符串。我们已知，在Redis之中，没有专门的数值类型，整形数字也是需要使用String类型来保存的， 而这个函数主要用于，将一个整形数字转化为Redis自定义的数据类型：

robj *createStringObjectFromLongLongWithOptions(long long value, int valueobj) {
    robj *o;
    ...
    o = createObject(OBJ_STRING,sdsfromlonglong(value));  
    ...
}

上述代码便是用过调用sdsfromlonglong接口将一个整数转化为Redis的字符串对象的。

sds sdscatvprintf(sds s, const char *fmt, va_list ap);
sds sdscatprintf(sds s, const char *fmt, ...);
sds sdscatfmt(sds s, char const* fmt, ...);

类似使用printf的调用的方式，将一个格式化C风格字符串添加到sds的结尾 需要注意的是，作为参数传入的s，在函数执行成功后已不能保证有效性， 应使用s = sdscatprintf(s. "1");这样的方式进行操作。 另外sdscatfmt函数是是一个与sdscatprintf类似的接口，但是其执行的速度要更快 原因在与其没依赖与libc库所提供的sprintf()族函数，而这一组操作通常是很慢的。 但是其只支持特定的几种通配符：

• %sC风格字符串
• %SSDS字符串
• %isigned int 有符号整数
• %I64位有符号整数
• %uunsigned int 无符号整数
• %U64位无符号整数
• %%用于打印%符号

sds sdscatrepr(sds s, const char *p, size_t len);

sdscatrepr这个接口主要用于将给定字符串中的不可打印的字符进行转移，并将结构连接到sds数据之后。 该函数常用的场景是向客户端返回一个转移后的字符串，创建一个空的sds数据，将转移后的数据添加至该sds中， 例如：

static sds cliFormatReplyCSV(redisReply *r)
{
    sds out = sdsempty();
    ...
        out = sdscat(out, "ERROR,");
        out = sdscatrepr(out, r->str. strlen(r->srr));
    ...
}
sds sdstrim(sds s, const char *cset);

接口sdstrim给定一个C风格的字符集合cset，以及一个特定的sds数据，移除这个sds中前后属于这个cset的字符， 并返回更新后的sds数据。需要注意的是：

sp = start = s;
    ep = end = s+sdslen(s)-1;
    while(sp <= end && strchr(cset, *sp)) sp++;
    while(ep > sp && strchr(cset, *ep)) ep--;

通过代码我们可以了解到该接口的移除操作在遇到第一个不属于cset的字符时结束。 其中一些代码示例：

void loadServerConfigFromString(char *config) {
    ...
    lines[i] = sdstrim(lines[i]," \t\r\n");
    ...
}

在Redis中该接口的主要用途是用于移除空格、换行符、制表符等空字符。

void sdsrange(sds s, sszie_t start, ssize_t end);

sdsrange给定一个特定的sds数据，以及一个range的[start, end]，将这个sds数据缩小成符合这个range的子串。 range的范围可以是负值，其含义可以参考Python中对于列表的切片操作。

void sdstolower(sds s);
void sdstoupper(ssd s);

上述两个操作是给定一个sds数据，对于其内部的每一个字符调用tolower或者toupper操作。

sds sdsmapchars(sds s, const char *from, const char *to, size_t setlen);

sdsmapchars接口用于对一个sds数据执行字符替换，from为匹配串，to为替换串，

sds s = sdsnew("hello");
    s = sdsmapchars(s, "ho", "01", 2);
    printf("%c\n", s);
    //output 0ell1
int sdscmp(const sds s1, const sds s2);

sdscmp接口内部通过调用memcmp来比较两个sds数据的大小：

• 如果s1 > s2，返回一个正数。
• 如果s1 < s2，返回一个负数。
• 如果两个sds的二进制数据完全相同，那么这个函数返回0。

sds *sdssplitlen(const char *s, ssize_t len, const char *sep, int seplen, int *count);
void sdsfreesplitres(sds *tokens, int count);
sds *sdssplitargs(const char *line, int *argc);

上面这三个接口主要用于处理sds的split操作， 其中接口sdssplitlen会根据输入的字符串已经分隔符生成一个sds数据的动态数组， 同时使用count数据来返回这个数组的长度。而接口sdsfreesplitres接口则用于释放上述动态生成的数据。 这两个接口常用的应用场景为从配置文件中加载数据：

void loadServerConfigFromString(char *config)
{
    int totlines;
    sds *lines;
    lines = sdssplitlen(config, strlen(config), "\n", 1, & totlines);
    ...
}

而sdssplitargs接口则是将一行字符串拆分成多个sds数据，其主要用于将一行字符串解析成参数列表的形式， 供Redis后续使用。当我们使用完这个sds参数列表之后，我们需要手动调用sdsfreesplitres对其进行释放。 一个应用场景的实例是Redis客户端加载*~/.redisclirc*配置文件时：

void cliLoadPreference(void)
{
    ...
    while(fget(buf, sizeof(buf), fp) != NULL)
    {
        sds* argv;
        int argc;
        argv = sdssplitargs(buf, &argc);
        if (argc > 0)
        {
            //Handle argv
        }
        sdsfreesplitres(argv, argc);
    }
    ...
}

喜欢的同学可以扫描二维码，关注我的微信公众号，马基雅维利incoding