• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

自己动手写Redis客户端(C#实现)4-整数回复

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

整数回复

 

整数回复就是一个以 ":" 开头, CRLF 结尾的字符串表示的整数。

比如说, ":0\r\n" 和 ":1000\r\n" 都是整数回复。

返回整数回复的其中两个命令是 INCR 和 LASTSAVE 。 被返回的整数没有什么特殊的含义, INCR 返回键的一个自增后的整数值, 而 LASTSAVE 则返回一个 UNIX 时间戳, 返回值的唯一限制是这些数必须能够用 64 位有符号整数表示。

整数回复也被广泛地用于表示逻辑真和逻辑假: 比如 EXISTS 和 SISMEMBER 都用返回值 1 表示真, 0 表示假。 其他一些命令, 比如 SADD 、 SREM 和 SETNX , 只在操作真正被执行了的时候, 才返回 1 , 否则返回 0 。 以下命令都返回整数回复: SETNX 、 DEL 、 EXISTS 、 INCR 、 INCRBY 、 DECR 、 DECRBY 、 DBSIZE 、 LASTSAVE 、 RENAMENX 、 MOVE 、 LLEN 、 SADD 、 SREM 、 SISMEMBER 、 SCARD 。

 

整数回复的代码实现:

/// <summary>
/// 整数回复
/// </summary>
/// <param name="client"></param>
/// <returns></returns>
public static Int64 ReplyLong(Socket client) {
    BufferedStream s = new BufferedStream(new NetworkStream(client));
    int b = s.ReadByte(); // 读取第一个字节 
    string result;
    switch (b)
    {
        // 整数回复(integer reply)的第一个字节是 ":"
        case ':': 
            return long.Parse(ReadLine(s));
        // 错误回复(error reply)的第一个字节是 "-"
        case '-':
            result = ReadLine(s);
            throw new Exception(result);  // 抛出异常 
               
        default:
            break;
    }
    return 0;
}

 

因此INCR操作的代码实现:

/// <summary>
/// +1操作
/// </summary>
/// <param name="client"></param>
/// <param name="key"></param>
/// <returns></returns>
public static Int64 INCR(this Socket client, string key) {
    SendCmd(client, "INCR", Encoding.UTF8.GetBytes(key));
    return ReplyLong(client);
}

因此LASTSAVE操作的代码实现:

/// <summary>
/// LastSave
/// </summary>
/// <param name="client"></param>
/// <param name="key"></param>
/// <returns></returns>
public static DateTime LASTSAVE(this Socket client) {
    SendCmd(client, "LASTSAVE");
    long l =  ReplyLong(client);
    System.DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new DateTime(1970, 1, 1));
    return startTime.AddSeconds(l);
}

因此EXISTS操作的代码实现:

public static bool EXISTS(this Socket client, string key) {
    SendCmd(client, "EXISTS", Encoding.UTF8.GetBytes(key));
    return ReplyLong(client) == 0;
}

因此SISMEMBER操作的代码实现:

/// <summary>
/// 判断 member 元素是否集合 key 的成员
/// </summary>
/// <returns></returns>
public static bool SISMEMBER(this Socket client, string key, string member) {
    SendCmd(client, "SISMEMBER", Encoding.UTF8.GetBytes(key), Encoding.UTF8.GetBytes(member));
    return ReplyLong(client) == 0;
}

其他  SETNX 、 DEL 、 EXISTS 、 INCR 、 INCRBY 、 DECR 、 DECRBY 、 DBSIZE 、 LASTSAVE 、 RENAMENX 、 MOVE 、 LLEN 、 SADD 、 SREM 、 SISMEMBER 、 SCARD整数操作都可以参照上面的代码进行实现。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C#索引器发布时间:2022-07-14
下一篇:
C#实现Web文件上传的两种方法 (转)发布时间:2022-07-14
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap