01.蓝屏STOP错误，急！！！还是重装系统吧你的电脑是Blue Screen of Death（ＢＳＯＤ）蓝屏死机。在这里为了你更好的查出你问题的所在，，我们来分析一年产生的原因及其类型 BSOD可以分成独立的几部分，每部分包含有有价值的错误处理信息。这几...查看完整版&&&02.plug and play+蓝屏错误不要怕,没有什么大事情。取了U盘就没有事情了，操作系统在初始化时间没有识别U盘plug and play detected an error most likely caused by a fault driver的意思是:即插即用检测到一个很可能是由错误驱动器引起的错误...查看完整版&&&03.电脑蓝屏，错误代码显示为：“0X***********内存的问题:把你的机箱打开把内存拿下来用橡皮擦把前面的金属擦一下在放回机箱 记住一定要插紧 不然还会这样的重装系统是显卡驱动安装不正确引起的或者就是因为xp能自举显卡你的机子根本就没有安装过显卡驱动：xp系统...查看完整版&&&04.错误！！错误！！蓝屏！！！这主要原因是你装载了太多不必要的程序所导致的！如果有些程序对你用处不大，我建议你就把它删除了吧！那即占内存有占硬盘空间，这对计算机很不好，要是经常这样！会损坏硬盘的！
另一方面也很有可能是你的配置太...查看完整版&&&05.刚进入系统就出现蓝屏
stop:0x重装参考资料：.首先使用新版杀毒软件检查计算机上是否有病毒。 2.如果Windows 2000/XP可以启动，请检查“事件查看器”中的信息，以确定导致故障的设备或驱动程序。启动“事件查看器”的方法是：“开始”...查看完整版&&&06.我最近关闭电脑时出现蓝屏：stop:0X***********这是一个内存的中断响应，表现为内存站用量太大。用Win优化大师，对您的电脑内存进行优化。请不要在C盘安装大型文件。这是一个比较低的地址，可能是核心部件有问题。这是一个内存的中断响应，表现为内存站用量太大。...查看完整版&&&07.stop:0x***********代表哪种错误啊STOP消息 0x***********、0x***********故障通常原因是严重的驱动器碎片、超载的文件I/O、第三方的驱动器镜像软件或者一些防病毒软件出错。 1）禁用一些防病毒软件或者备份程序，禁用所有碎片整理应用程序。 2）运行chkdsk...查看完整版&&&08.进安全模式死机蓝屏内存错误是怎么回事啊？两条不同牌子的内存存在着不兼容的问题，先用一条内存看看是否还存在这方面的问题，系统中毒、恶意插件、软件冲突造成。见意你先行安装``卡巴斯基``它具有脱壳杀毒功能，恶意插件是不能杀毒的，用超级兔仔删除恶意插...查看完整版&&&09.电脑总是在游戏错误之后。。。突然跳出蓝屏。。。显示的文字如下你的某个硬件出现了错误，建议你升级或重装硬件驱动。实在不行，重装系统。...查看完整版&&&10.我用了look n stop,日志里总不停地出现的是什么啊？记录的一些连接，不影响下载，我这几天也在使用looknstop...查看完整版&&&&&&今日推荐
&&&&&日版宠物情人2017的插曲，很带节奏感，日语的，女生唱的。
最后听见是在第8集的时候女主手割伤了，然后男主用嘴帮她吸了一下，插曲就出来了。
歌手：Def...老钟家的两个儿子很特别，就是跟其他的人不太一样，魔一般的执着。兄弟俩都到了要结婚的年龄了，不管自家老爹怎么磨破嘴皮子，兄弟俩说不娶就不娶，老父母为兄弟两操碎了心...把牛仔裤磨出有线的破洞
1、具体工具就是磨脚石，下面垫一个硬物，然后用磨脚石一直磨一直磨，到把那块磨薄了，用手撕开就好了。出来的洞啊很自然的。需要猫须的话调几...先来看下敬业福和爱国福
今年春节，支付宝再次推出了“五福红包”活动，表示要“把欠大家的敬业福都还给大家”。
今天该活动正式启动，和去年一样，需要收集“五福”...有时候我们打开冰箱就会闻到一股异味，冰箱里的这种异味是因为一些物质发出的气味的混合体，闻起来让人恶心。 产生这些异味的主要原因有以下几点。
1、很多人有这种习...简介
《极品家丁》讲述了现代白领林晚荣无意回到古代金陵，并追随萧二小姐化名“林三”进入萧府，不料却阴差阳错上演了一出低级家丁拼搏上位的“林三升职记”。...你就是我最爱的宝宝 - 李溪芮
(电视剧《极品家丁》片尾曲)
作词：常馨内
作曲：常馨内
你的眉 又鬼马的挑
你的嘴 又坏坏的笑
上一秒吵闹 下...乌梅，又称春梅，中医认为，乌梅味酸，性温，无毒，具有安心、除热、下气、祛痰、止渴调中、杀虫的功效，治肢体痛、肺痨病。乌梅泡水喝能治伤寒烦热、止吐泻，与干姜一起制...什么是脂肪粒
在我们的脸上总会长一个个像脂肪的小颗粒，弄也弄不掉，而且颜色还是白白的。它既不是粉刺也不是其他的任何痘痘，它就是脂肪粒。
脂肪粒虽然也是由油脂...来源：中国青年报
新的攻击方法不断涌现，黑客几乎永远占据网络攻击的上风，我们不可能通过技术手段杜绝网络攻击。国家安全保障的主要方向是打击犯罪，而不是处置和惩罚...夫妻网络直播“造人”爆红
　　1月9日，温岭城北派出所接到南京警方的协查通告，他们近期打掉了一个涉黄直播APP平台。而根据掌握的线索，其中有一对涉案的夫妻主播...如何防止墙纸老化？
（1）选择透气性好的墙纸
市场上墙纸的材质分无纺布的、木纤维的、PVC的、玻璃纤维基材的、布面的等，相对而言，PVC材质的墙纸最不透气...观点一：破日本销售量的“鲜肌之谜” 非日本生产
近一段时间，淘宝上架了一款名为“鲜肌之谜的” 鲑鱼卵巢美容液，号称是最近日本的一款推出的全新护肤品，产品本身所...系腰裙(北宋词人 张先)
惜霜蟾照夜云天，朦胧影、画勾阑。人情纵似长情月，算一年年。又能得、几番圆。
欲寄西江题叶字，流不到、五亭前。东池始有荷新绿，尚小如...关于女人的经典语句1、【做一个独立的女人】
思想独立：有主见、有自己的人生观、价值观。有上进心,永远不放弃自己的理想，做一份自己喜爱的事业，拥有快乐和成就...你想体验机器人性爱吗？你想和性爱机器人结婚吗？如果你想，机器人有拒绝你的权利吗？
近日，第二届“国际人类-机器人性爱研讨会”大会在伦敦金史密斯大学落下帷幕。而...10.土耳其地下洞穴城市
变态指数：★★☆☆☆
这是土耳其卡帕多西亚的一个著名景点，传说是当年基督教徒们为了躲避战争而在此修建。里面曾住着20000人，......据英国《每日快报》报道，一位科学家兼理论家Robert Lanza博士宣称，世界上并不存在人类死亡，死亡的只是身体。他认为我们的意识借助我们体内的能量生存，而且...《我爱狐狸精》 - 刘馨棋
　　(电视剧《屏里狐》主题曲)
　　作词：金十三&李旦
　　作曲：刘嘉
　　狐狸精 狐狸仙
　　千年修...·&·&·&&&01.蓝屏STOP错误，急！！！还是重装系统吧你的电脑是Blue Screen of Death（ＢＳＯＤ）蓝屏死机。在这里为了你更好的查出你问题的所在，，我们来分析一年产生的原因及其类型 BSOD可以分成独立的几部分，每部分包含有有价值的错误处理信息。这几...查看完整版&&&02.plug and play+蓝屏错误不要怕,没有什么大事情。取了U盘就没有事情了，操作系统在初始化时间没有识别U盘plug and play detected an error most likely caused by a fault driver的意思是:即插即用检测到一个很可能是由错误驱动器引起的错误...查看完整版&&&03.电脑蓝屏，错误代码显示为：“0X***********内存的问题:把你的机箱打开把内存拿下来用橡皮擦把前面的金属擦一下在放回机箱 记住一定要插紧 不然还会这样的重装系统是显卡驱动安装不正确引起的或者就是因为xp能自举显卡你的机子根本就没有安装过显卡驱动：xp系统...查看完整版&&&04.错误！！错误！！蓝屏！！！这主要原因是你装载了太多不必要的程序所导致的！如果有些程序对你用处不大，我建议你就把它删除了吧！那即占内存有占硬盘空间，这对计算机很不好，要是经常这样！会损坏硬盘的！
另一方面也很有可能是你的配置太...查看完整版&&&05.刚进入系统就出现蓝屏
stop:0x重装参考资料：.首先使用新版杀毒软件检查计算机上是否有病毒。 2.如果Windows 2000/XP可以启动，请检查“事件查看器”中的信息，以确定导致故障的设备或驱动程序。启动“事件查看器”的方法是：“开始”...查看完整版&&&06.我最近关闭电脑时出现蓝屏：stop:0X***********这是一个内存的中断响应，表现为内存站用量太大。用Win优化大师，对您的电脑内存进行优化。请不要在C盘安装大型文件。这是一个比较低的地址，可能是核心部件有问题。这是一个内存的中断响应，表现为内存站用量太大。...查看完整版&&&07.stop:0x***********代表哪种错误啊STOP消息 0x***********、0x***********故障通常原因是严重的驱动器碎片、超载的文件I/O、第三方的驱动器镜像软件或者一些防病毒软件出错。 1）禁用一些防病毒软件或者备份程序，禁用所有碎片整理应用程序。 2）运行chkdsk...查看完整版&&&08.进安全模式死机蓝屏内存错误是怎么回事啊？两条不同牌子的内存存在着不兼容的问题，先用一条内存看看是否还存在这方面的问题，系统中毒、恶意插件、软件冲突造成。见意你先行安装``卡巴斯基``它具有脱壳杀毒功能，恶意插件是不能杀毒的，用超级兔仔删除恶意插...查看完整版&&&09.电脑总是在游戏错误之后。。。突然跳出蓝屏。。。显示的文字如下你的某个硬件出现了错误，建议你升级或重装硬件驱动。实在不行，重装系统。...查看完整版&&&10.我用了look n stop,日志里总不停地出现的是什么啊？记录的一些连接，不影响下载，我这几天也在使用looknstop...查看完整版&&&　　免责声明：本文仅代表作者个人观点，与王朝网络无关。王朝网络登载此文出于传递更多信息之目的，并不意味着赞同其观点或证实其描述，其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。&&&&&&为你推荐&&&&&&转载本文&UBB代码&HTML代码复制到剪贴板...&更多内容··········&&&&&&&&&频道精选&&&王朝女性&&|&&|&&|&&|&&|&&|&&|&&|&&|&&|&&|&&|&王朝分栏&&|&&|&&|&&|&&|&&|&&|&&|&&|&&|&王朝编程&&|&&|&&|&&|&&|&&|&&|&&|&&|&&|&王朝导购&&|&&|&&|&&|&&|&&|&&|&&|&&|&&|&王朝其他&&|&&|&&|&&|&&|&&|&&&&2005-&&版权所有&这个世界并不是掌握在那些嘲笑者的手中，而恰恰掌握在能够经受得住嘲笑与批评仍不断往前走的人手中。Redis.cs代码类:#define DEBUGusing Susing System.Cusing System.Collections.Gusing System.Dusing System.IO;using System.Lusing System.Net.Susing System.Tpublic class Redis : IDisposable{
private BufferedS
public enum KeyType
public class ResponseException : Exception
public ResponseException(string code) : base("响应错误")
public string Code { get; private set; }
public Redis(string host, int port)
if (host == null)
throw new ArgumentNullException("host");
SendTimeout = -1;
public Redis(string host) : this(host, 6379)
public Redis() : this("localhost", 6379)
public string Host { get; private set; }
public int Port { get; private set; }
public int RetryTimeout { get; set; }
public int RetryCount { get; set; }
public int SendTimeout { get; set; }
public string Password { get; set; }
private int
//SELECT index
//切换到指定的数据库，数据库索引号 index 用数字值指定，以 0 作为起始索引值。
//默认使用 0 号数据库
public int Db
get { return }
db = value;
SendExpectSuccess("SELECT", db);
public string this[string key]
get { return GetString(key); }
set { Set(key, value); }
//SET key value [EX seconds] [PX milliseconds] [NX|XX]
//将字符串值 value 关联到 key 。
//如果 key 已经持有其他值， SET 就覆写旧值，无视类型。
//对于某个原本带有生存时间（TTL）的键来说， 当 SET 命令成功在这个键上执行时， 这个键原有的 TTL 将被清除。
public void Set(string key, string value)
if (key == null)
throw new ArgumentNullException("key");
if (value == null)
throw new ArgumentNullException("value");
Set(key, Encoding.UTF8.GetBytes(value));
public void Set(string key, byte[] value)
if (key == null)
throw new ArgumentNullException("key");
if (value == null)
throw new ArgumentNullException("value");
if (value.Length & )
throw new ArgumentException("value exceeds 1G", "value");
if (!SendDataCommand(value, "SET", key))
throw new Exception("Unable to connect");
ExpectSuccess();
//SETNX key value
//将 key 的值设为value ，当且仅当 key 不存在。
//若给定的 key已经存在，则 SETNX 不做任何动作。
//SETNX 是『SET if Not eXists』(如果不存在，则 SET)的简写。
public bool SetNX(string key, string value)
if (key == null)
throw new ArgumentNullException("key");
if (value == null)
throw new ArgumentNullException("value");
return SetNX(key, Encoding.UTF8.GetBytes(value));
public bool SetNX(string key, byte[] value)
if (key == null)
throw new ArgumentNullException("key");
if (value == null)
throw new ArgumentNullException("value");
if (value.Length & )
throw new ArgumentException("value exceeds 1G", "value");
return SendDataExpectInt(value, "SETNX", key) & 0 ? true : false;
public void Set(IDictionary&string, string& dict)
if (dict == null)
throw new ArgumentNullException("dict");
Set(dict.ToDictionary(k =& k.Key, v =& Encoding.UTF8.GetBytes(v.Value)));
public void Set(IDictionary&string, byte[]& dict)
if (dict == null)
throw new ArgumentNullException("dict");
MSet(dict.Keys.ToArray(), dict.Values.ToArray());
//MSET key value [key value ...]
//同时设置一个或多个 key-value 对。
//如果某个给定 key 已经存在，那么 MSET 会用新值覆盖原来的旧值，如果这不是你所希望的效果，请考虑使用 MSETNX 命令：它只会在所有给定 key 都不存在的情况下进行设置操作。
//MSET 是一个原子性(atomic)操作，所有给定 key 都会在同一时间内被设置，某些给定 key 被更新而另一些给定 key 没有改变的情况，不可能发生。
public void MSet(string[] keys, byte[][] values)
if (keys.Length != values.Length)
throw new ArgumentException("keys and values must have the same size");
byte[] nl = Encoding.UTF8.GetBytes("/r/n");
var ms = new MemoryStream();
for (int i = 0; i & keys.L i++)
byte[] key = Encoding.UTF8.GetBytes(keys[i]);
byte[] val = values[i];
byte[] kLength = Encoding.UTF8.GetBytes("$" + key.Length + "/r/n");
byte[] k = Encoding.UTF8.GetBytes(keys[i] + "/r/n");
byte[] vLength = Encoding.UTF8.GetBytes("$" + val.Length + "/r/n");
ms.Write(kLength, 0, kLength.Length);
ms.Write(k, 0, k.Length);
ms.Write(vLength, 0, vLength.Length);
ms.Write(val, 0, val.Length);
ms.Write(nl, 0, nl.Length);
SendDataRESP(ms.ToArray(), "*" + (keys.Length*2 + 1) + "/r/n$4/r/nMSET/r/n");
ExpectSuccess();
//返回 key 所关联的字符串值。
//如果 key 不存在那么返回特殊值 nil 。
//假如 key 储存的值不是字符串类型，返回一个错误，因为 GET 只能用于处理字符串值。
public byte[] Get(string key)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectData("GET", key);
public string GetString(string key)
if (key == null)
throw new ArgumentNullException("key");
return Encoding.UTF8.GetString(Get(key));
//SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC | DESC] [ALPHA] [STORE destination]
//返回或保存给定列表、集合、有序集合 key 中经过排序的元素。
//排序默认以数字作为对象，值被解释为双精度浮点数，然后进行比较。
//一般 SORT 用法
//最简单的 SORT 使用方法是 SORT key 和 SORT key DESC ：
//SORT key 返回键值从小到大排序的结果。
//SORT key DESC 返回键值从大到小排序的结果。
public byte[][] Sort(SortOptions options)
return Sort(options.Key, options.StoreInKey, options.ToArgs());
public byte[][] Sort(string key, string destination, params object[] options)
if (key == null)
throw new ArgumentNullException("key");
int offset = string.IsNullOrEmpty(destination) ? 1 : 3;
var args = new object[offset + options.Length];
Array.Copy(options, 0, args, offset, options.Length);
if (offset == 1)
return SendExpectDataArray("SORT", args);
args[1] = "STORE";
int n = SendExpectInt("SORT", args);
return new byte[n][];
//GETSET key value
//将给定 key 的值设为 value ，并返回 key 的旧值(old value)。
//当 key 存在但不是字符串类型时，返回一个错误。
public byte[] GetSet(string key, byte[] value)
if (key == null)
throw new ArgumentNullException("key");
if (value == null)
throw new ArgumentNullException("value");
if (value.Length & )
throw new ArgumentException("value exceeds 1G", "value");
if (!SendDataCommand(value, "GETSET", key))
throw new Exception("Unable to connect");
return ReadData();
public string GetSet(string key, string value)
if (key == null)
throw new ArgumentNullException("key");
if (value == null)
throw new ArgumentNullException("value");
return Encoding.UTF8.GetString(GetSet(key, Encoding.UTF8.GetBytes(value)));
private string ReadLine()
var sb = new StringBuilder();
while ((c = bstream.ReadByte()) != -1)
if (c == '/r')
if (c == '/n')
sb.Append((char) c);
return sb.ToString();
private void Connect()
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.NoDelay = true;
socket.SendTimeout = SendT
socket.Connect(Host, Port);
if (!socket.Connected)
socket.Close();
socket = null;
bstream = new BufferedStream(new NetworkStream(socket), 16*1024);
if (Password != null)
//AUTH password
//通过设置配置文件中 requirepass 项的值(使用命令 CONFIG SET requirepass password )，可以使用密码来保护 Redis 服务器。
//如果开启了密码保护的话，在每次连接 Redis 服务器之后，就要使用 AUTH 命令解锁，解锁之后才能使用其他 Redis 命令。
//如果 AUTH 命令给定的密码 password 和配置文件中的密码相符的话，服务器会返回 OK 并开始接受命令输入。
//另一方面，假如密码不匹配的话，服务器将返回一个错误，并要求客户端需重新输入密码。
SendExpectSuccess("AUTH", Password);
private readonly byte[] end_data = {(byte) '/r', (byte) '/n'};
private bool SendDataCommand(byte[] data, string cmd, params object[] args)
string resp = "*" + (1 + args.Length + 1) + "/r/n";
resp += "$" + cmd.Length + "/r/n" + cmd + "/r/n";
foreach (object arg in args)
string argStr = arg.ToString();
int argStrLength = Encoding.UTF8.GetByteCount(argStr);
resp += "$" + argStrLength + "/r/n" + argStr + "/r/n";
resp += "$" + data.Length + "/r/n";
return SendDataRESP(data, resp);
private bool SendDataRESP(byte[] data, string resp)
if (socket == null)
Connect();
if (socket == null)
return false;
byte[] r = Encoding.UTF8.GetBytes(resp);
Log("C", resp);
socket.Send(r);
if (data != null)
socket.Send(data);
socket.Send(end_data);
catch (SocketException)
socket.Close();
socket = null;
return false;
return true;
private bool SendCommand(string cmd, params object[] args)
if (socket == null)
Connect(); //建立连接redis
if (socket == null)
return false;
string resp = "*" + (1 + args.Length) + "/r/n";
resp += "$" + cmd.Length + "/r/n" + cmd + "/r/n";
foreach (object arg in args)
string argStr = arg.ToString();
int argStrLength = Encoding.UTF8.GetByteCount(argStr);
resp += "$" + argStrLength + "/r/n" + argStr + "/r/n";
byte[] r = Encoding.UTF8.GetBytes(resp);
Log("C", resp);
socket.Send(r);
catch (SocketException)
socket.Close();
socket = null;
return false;
return true;
[Conditional("DEBUG")]
private void Log(string id, string message)
Console.WriteLine(id + ": " + message.Trim().Replace("/r/n", " "));
//期待成功
private void ExpectSuccess()
int c = bstream.ReadByte();
if (c == -1)
throw new ResponseException("No more data");
string s = ReadLine();
Log("S", (char) c + s);
if (c == '-')
throw new ResponseException(s.StartsWith("ERR ") ? s.Substring(4) : s);
private void SendExpectSuccess(string cmd, params object[] args)
if (!SendCommand(cmd, args))
throw new Exception("Unable to connect");
ExpectSuccess();
private int SendDataExpectInt(byte[] data, string cmd, params object[] args)
if (!SendDataCommand(data, cmd, args))
throw new Exception("Unable to connect");
int c = bstream.ReadByte();
if (c == -1)
throw new ResponseException("No more data");
string s = ReadLine();
Log("S", (char) c + s);
if (c == '-')
throw new ResponseException(s.StartsWith("ERR ") ? s.Substring(4) : s);
if (c == ':')
if (int.TryParse(s, out i))
throw new ResponseException("Unknown reply on integer request: " + c + s);
private int SendExpectInt(string cmd, params object[] args)
if (!SendCommand(cmd, args))
throw new Exception("Unable to connect");
int c = bstream.ReadByte();
if (c == -1)
throw new ResponseException("No more data");
string s = ReadLine();
Log("S", (char) c + s);
if (c == '-')
throw new ResponseException(s.StartsWith("ERR ") ? s.Substring(4) : s);
if (c == ':')
if (int.TryParse(s, out i))
throw new ResponseException("Unknown reply on integer request: " + c + s);
private string SendExpectString(string cmd, params object[] args)
if (!SendCommand(cmd, args))
throw new Exception("Unable to connect");
int c = bstream.ReadByte();
if (c == -1)
throw new ResponseException("No more data");
string s = ReadLine();
Log("S", (char) c + s);
if (c == '-')
throw new ResponseException(s.StartsWith("ERR ") ? s.Substring(4) : s);
if (c == '+')
throw new ResponseException("Unknown reply on integer request: " + c + s);
// 这一个不抛出错误
private string SendGetString(string cmd, params object[] args)
if (!SendCommand(cmd, args))
throw new Exception("Unable to connect");
return ReadLine();
private byte[] SendExpectData(string cmd, params object[] args)
if (!SendCommand(cmd, args))
throw new Exception("Unable to connect");
return ReadData();
private byte[] ReadData()
string s = ReadLine();
Log("S", s);
if (s.Length == 0)
throw new ResponseException("Zero length respose");
char c = s[0];
if (c == '-')
throw new ResponseException(s.StartsWith("-ERR ") ? s.Substring(5) : s.Substring(1));
if (c == '$')
if (s == "$-1")
return null;
if (Int32.TryParse(s.Substring(1), out n))
var retbuf = new byte[n];
int bytesRead = 0;
int read = bstream.Read(retbuf, bytesRead, n - bytesRead);
if (read & 1)
throw new ResponseException("Invalid termination mid stream");
bytesRead +=
} while (bytesRead & n);
if (bstream.ReadByte() != '/r' || bstream.ReadByte() != '/n')
throw new ResponseException("Invalid termination");
throw new ResponseException("Invalid length");
/* don't treat arrays here because only one element works -- use DataArray!
//returns the number of matches
if (c == '*') {
if (Int32.TryParse(s.Substring(1), out n))
return n &= 0 ? new byte [0] : ReadData();
throw new ResponseException ("Unexpected length parameter" + r);
throw new ResponseException("Unexpected reply: " + s);
//EXISTS key
//检查给定 key 是否存在。
public bool ContainsKey(string key)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("EXISTS", key) == 1;
//DEL key [key ...]
//删除给定的一个或多个 key 。
//不存在的 key 会被忽略。
public bool Remove(string key)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("DEL", key) == 1;
public int Remove(params string[] args)
if (args == null)
throw new ArgumentNullException("args");
return SendExpectInt("DEL", args);
//INCR key
//将 key 中储存的数字值增一。
//如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 INCR 操作。
//如果值包含错误的类型，或字符串类型的值不能表示为数字，那么返回一个错误。
//本操作的值限制在 64 位(bit)有符号数字表示之内。
//这是一个针对字符串的操作，因为 Redis 没有专用的整数类型，所以 key 内储存的字符串被解释为十进制 64 位有符号整数来执行 INCR 操作。
public int Increment(string key)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("INCR", key);
//INCRBY key increment
//将 key 所储存的值加上增量 increment 。
//如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 INCRBY 命令。
//如果值包含错误的类型，或字符串类型的值不能表示为数字，那么返回一个错误。
//本操作的值限制在 64 位(bit)有符号数字表示之内。
public int Increment(string key, int count)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("INCRBY", key, count);
//将 key 中储存的数字值减一。
//如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 DECR 操作。
//如果值包含错误的类型，或字符串类型的值不能表示为数字，那么返回一个错误。
//本操作的值限制在 64 位(bit)有符号数字表示之内。
public int Decrement(string key)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("DECR", key);
//DECRBY key decrement
//将 key 所储存的值减去减量 decrement 。
//如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 DECRBY 操作。
//如果值包含错误的类型，或字符串类型的值不能表示为数字，那么返回一个错误。
//本操作的值限制在 64 位(bit)有符号数字表示之内。
public int Decrement(string key, int count)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("DECRBY", key, count);
//TYPE key
//返回 key 所储存的值的类型。
public KeyType TypeOf(string key)
if (key == null)
throw new ArgumentNullException("key");
switch (SendExpectString("TYPE", key))
case "none":
return KeyType.N
case "string":
return KeyType.S
case "set":
return KeyType.S
case "list":
return KeyType.L
throw new ResponseException("Invalid value");
//RANDOMKEY
//从当前数据库中随机返回(不删除)一个 key 。
public string RandomKey()
return SendExpectString("RANDOMKEY");
//RENAME key newkey
//将 key 改名为 newkey 。
//当 key 和 newkey 相同，或者 key 不存在时，返回一个错误。
//当 newkey 已经存在时， RENAME 命令将覆盖旧值。
public bool Rename(string oldKeyname, string newKeyname)
if (oldKeyname == null)
throw new ArgumentNullException("oldKeyname");
if (newKeyname == null)
throw new ArgumentNullException("newKeyname");
return SendGetString("RENAME", oldKeyname, newKeyname)[0] == '+';
// EXPIRE key seconds
//为给定 key 设置生存时间，当 key 过期时(生存时间为 0 )，它会被自动删除。
//在 Redis 中，带有生存时间的 key 被称为『易失的』(volatile)。
//生存时间可以通过使用 DEL 命令来删除整个 key 来移除，或者被 SET 和 GETSET 命令覆写(overwrite)，这意味着，如果一个命令只是修改(alter)一个带生存时间的 key 的值而不是用一个新的 key 值来代替(replace)它的话，那么生存时间不会被改变。
//比如说，对一个 key 执行 INCR 命令，对一个列表进行 LPUSH 命令，或者对一个哈希表执行 HSET 命令，这类操作都不会修改 key 本身的生存时间。
//另一方面，如果使用 RENAME 对一个 key 进行改名，那么改名后的 key 的生存时间和改名前一样。
//RENAME 命令的另一种可能是，尝试将一个带生存时间的 key 改名成另一个带生存时间的 another_key ，这时旧的 another_key (以及它的生存时间)会被删除，然后旧的 key 会改名为 another_key ，因此，新的 another_key 的生存时间也和原本的 key 一样。
//使用 PERSIST 命令可以在不删除 key 的情况下，移除 key 的生存时间，让 key 重新成为一个『持久的』(persistent) key 。
//更新生存时间
//可以对一个已经带有生存时间的 key 执行 EXPIRE 命令，新指定的生存时间会取代旧的生存时间。
//过期时间的精确度
//在 Redis 2.4 版本中，过期时间的延迟在 1 秒钟之内 —— 也即是，就算 key 已经过期，但它还是可能在过期之后一秒钟之内被访问到，而在新的 Redis 2.6 版本中，延迟被降低到 1 毫秒之内。
//Redis 2.1.3 之前的不同之处
//在 Redis 2.1.3 之前的版本中，修改一个带有生存时间的 key 会导致整个 key 被删除，这一行为是受当时复制(replication)层的限制而作出的，现在这一限制已经被修复。
public bool Expire(string key, int seconds)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("EXPIRE", key, seconds) == 1;
//EXPIREAT key timestamp
//EXPIREAT 的作用和 EXPIRE 类似，都用于为 key 设置生存时间。
//不同在于 EXPIREAT 命令接受的时间参数是 UNIX 时间戳(unix timestamp)。
public bool ExpireAt(string key, int time)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("EXPIREAT", key, time) == 1;
//以秒为单位，返回给定 key 的剩余生存时间(TTL, time to live)。
public int TimeToLive(string key)
if (key == null)
throw new ArgumentNullException("key");
return SendExpectInt("TTL", key);
//返回当前数据库的 key 的数量。
public int DbSize
get { return SendExpectInt("DBSIZE"); }
//SAVE 命令执行一个同步保存操作，将当前 Redis 实例的所有数据快照(snapshot)以 RDB 文件的形式保存到硬盘。
//一般来说，在生产环境很少执行 SAVE 操作，因为它会阻塞所有客户端，保存数据库的任务通常由 BGSAVE 命令异步地执行。
//然而，如果负责保存数据的后台子进程不幸出现问题时， SAVE 可以作为保存数据的最后手段来使用。
public void Save()
SendExpectSuccess("SAVE");
// 在后台异步(Asynchronously)保存当前数据库的数据到磁盘。
//BGSAVE 命令执行之后立即返回 OK ，然后 Redis fork 出一个新子进程，原来的 Redis 进程(父进程)继续处理客户端请求，而子进程则负责将数据保存到磁盘，然后退出。
//客户端可以通过 LASTSAVE 命令查看相关信息，判断 BGSAVE 命令是否执行成功。
public void BackgroundSave()
SendExpectSuccess("BGSAVE");
//SHUTDOWN 命令执行以下操作：
//停止所有客户端
//如果有至少一个保存点在等待，执行 SAVE 命令
//如果 AOF 选项被打开，更新 AOF 文件
//关闭 redis 服务器(server)
//如果持久化被打开的话， SHUTDOWN 命令会保证服务器正常关闭而不丢失任何数据。
//另一方面，假如只是单纯地执行 SAVE 命令，然后再执行 QUIT 命令，则没有这一保证 —— 因为在执行 SAVE 之后、执行 QUIT 之前的这段时间中间，
//其他客户端可能正在和服务器进行通讯，这时如果执行 QUIT 就会造成数据丢失。
//SAVE 和 NOSAVE 修饰符
//通过使用可选的修饰符，可以修改 SHUTDOWN 命令的表现。比如说：
//执行 SHUTDOWN SAVE 会强制让数据库执行保存操作，即使没有设定(configure)保存点
//执行 SHUTDOWN NOSAVE 会阻止数据库执行保存操作，即使已经设定有一个或多个保存点(你可以将这一用法看作是强制停止服务器的一个假想的 ABORT 命令)
public void Shutdown()
SendCommand("SHUTDOWN");
// the server may return an error
string s = ReadLine();
Log("S", s);
if (s.Length == 0)
throw new ResponseException("Zero length respose");
throw new ResponseException(s.StartsWith("-ERR ") ? s.Substring(5) : s.Substring(1));
catch (IOException)
//这是预期的正确的结果
socket.Close();
socket = null;
//FLUSHALL
//清空整个 Redis 服务器的数据(删除所有数据库的所有 key )。
//此命令从不失败。
public void FlushAll()
SendExpectSuccess("FLUSHALL");
//清空当前数据库中的所有 key。
//此命令从不失败。
public void FlushDb()
SendExpectSuccess("FLUSHDB");
private const long UnixEpoch = 000000L;
//返回最近一次 Redis 成功将数据保存到磁盘上的时间，以 UNIX 时间戳格式表示。
public DateTime LastSave
int t = SendExpectInt("LASTSAVE");
return new DateTime(UnixEpoch) + TimeSpan.FromSeconds(t);
//INFO [section]
//以一种易于解释（parse）且易于阅读的格式，返回关于 Redis 服务器的各种信息和统计数值。
public Dictionary&string, string& GetInfo()
byte[] r = SendExpectData("INFO");
var dict = new Dictionary&string, string&();
foreach (string line in Encoding.UTF8.GetString(r).Split('/n'))
int p = line.IndexOf(':');
if (p == -1)
dict.Add(line.Substring(0, p), line.Substring(p + 1));
//KEYS pattern
//查找所有符合给定模式 pattern 的 key 。
//KEYS * 匹配数据库中所有 key 。
//KEYS h?llo 匹配 hello ， hallo 和 hxllo 等。
//KEYS h*llo 匹配 hllo 和 heeeeello 等。
//KEYS h[ae]llo 匹配 hello 和 hallo ，但不匹配 hillo 。
//特殊符号用 / 隔开
//KEYS 的速度非常快，但在一个大的数据库中使用它仍然可能造成性能问题，如果你需要从一个数据集中查找特定的 key ，你最好还是用 Redis 的集合结构(set)来代替。
public string[] Keys
get { return GetKeys("*"); }
public string[] GetKeys(string pattern)
if (pattern == null)
throw new ArgumentNullException("pattern");
return SendExpectStringArray("KEYS", pattern);
//MGET key [key ...]
//返回所有(一个或多个)给定 key 的值。
//如果给定的 key 里面，有某个 key 不存在，那么这个 key 返回特殊值 nil 。因此，该命令永不失败。
public byte[][] MGet(params string[] keys)
if (keys == null)
throw new ArgumentNullException("keys");
if (keys.Length == 0)
throw new ArgumentException("keys");
return SendExpectDataArray("MGET", keys);
public string[] SendExpectStringArray(string cmd, params object[] args)
byte[][] reply = SendExpectDataArray(cmd, args);
var keys = new string[reply.Length];
for (int i = 0; i & reply.L i++)
keys[i] = Encoding.UTF8.GetString(reply[i]);
public byte[][] SendExpectDataArray(string cmd, params object[] args)
if (!SendCommand(cmd, args))
throw new Exception("Unable to connect");
int c = bstream.ReadByte();
if (c == -1)
throw new ResponseException("No more data");
string s = ReadLine();
Log("S", (char) c + s);
if (c == '-')
throw new ResponseException(s.StartsWith("ERR ") ? s.Substring(4) : s);
if (c == '*')
if (int.TryParse(s, out count))
var result = new byte[count][];
for (int i = 0; i & i++)
result[i] = ReadData();
throw new ResponseException("Unknown reply on multi-request: " + c + s);
#region 列表 操作 命令
//LRANGE key start stop
//返回列表 key 中指定区间内的元素，区间以偏移量 start 和 stop 指定。
//下标(index)参数 start 和 stop 都以 0 为底，也就是说，以 0 表示列表的第一个元素，以 1 表示列表的第二个元素，以此类推。
//你也可以使用负数下标，以 -1 表示列表的最后一个元素， -2 表示列表的倒数第二个元素，以此类推。
//注意LRANGE命令和编程语言区间函数的区别
//假如你有一个包含一百个元素的列表，对该列表执行 LRANGE list 0 10 ，结果是一个包含11个元素的列表，这表明 stop 下标也在 LRANGE 命令的取值范围之内(闭区间)，这和某些语言的区间函数可能不一致，比如Ruby的 Range.new 、 Array#slice 和Python的 range() 函数。
//超出范围的下标
//超出范围的下标值不会引起错误。
//如果 start 下标比列表的最大下标 end ( LLEN list 减去 1 )还要大，那么 LRANGE 返回一个空列表。
//如果 stop 下标比 end 下标还要大，Redis将 stop 的值设置为 end 。
public byte[][] ListRange(string key, int start, int end)
return SendExpectDataArray("LRANGE", key, start, end);
public void LeftPush(string key, string value)
LeftPush(key, Encoding.UTF8.GetBytes(value));
//LPUSH key value [value ...]
//将一个或多个值 value 插入到列表 key 的表头
//如果有多个 value 值，那么各个 value 值按从左到右的顺序依次插入到表头： 比如说，对空列表 mylist 执行命令 LPUSH mylist a b c ，列表的值将是 c b a ，这等同于原子性地执行 LPUSH mylist a 、 LPUSH mylist b 和 LPUSH mylist c 三个命令。
//如果 key 不存在，一个空列表会被创建并执行 LPUSH 操作。
//当 key 存在但不是列表类型时，返回一个错误。
//在Redis 2.4版本以前的 LPUSH 命令，都只接受单个 value 值。
public void LeftPush(string key, byte[] value)
SendDataCommand(value, "LPUSH", key);
ExpectSuccess();
public void RightPush(string key, string value)
RightPush(key, Encoding.UTF8.GetBytes(value));
//RPUSH key value [value ...]
//将一个或多个值 value 插入到列表 key 的表尾(最右边)。
//如果有多个 value 值，那么各个 value 值按从左到右的顺序依次插入到表尾：比如对一个空列表 mylist 执行 RPUSH mylist a b c ，得出的结果列表为 a b c ，等同于执行命令 RPUSH mylist a 、 RPUSH mylist b 、 RPUSH mylist c 。
//如果 key 不存在，一个空列表会被创建并执行 RPUSH 操作。
//当 key 存在但不是列表类型时，返回一个错误。
//在 Redis 2.4 版本以前的 RPUSH 命令，都只接受单个 value 值。
public void RightPush(string key, byte[] value)
SendDataCommand(value, "RPUSH", key);
ExpectSuccess();
//LLEN key
//返回列表 key 的长度。
//如果 key 不存在，则 key 被解释为一个空列表，返回 0 .
//如果 key 不是列表类型，返回一个错误。
public int ListLength(string key)
return SendExpectInt("LLEN", key);
//LINDEX key index
//返回列表 key 中，下标为 index 的元素。
//下标(index)参数 start 和 stop 都以 0 为底，也就是说，以 0 表示列表的第一个元素，以 1 表示列表的第二个元素，以此类推。
//你也可以使用负数下标，以 -1 表示列表的最后一个元素， -2 表示列表的倒数第二个元素，以此类推。
//如果 key 不是列表类型，返回一个错误。
public byte[] ListIndex(string key, int index)
SendCommand("LINDEX", key, index);
return ReadData();
//LPOP key
//移除并返回列表 key 的头元素。
public byte[] LeftPop(string key)
SendCommand("LPOP", key);
return ReadData();
//RPOP key
//移除并返回列表 key 的尾元素。
public byte[] RightPop(string key)
SendCommand("RPOP", key);
return ReadData();
#endregion
#region Set commands
//SADD key member [member ...]
//将一个或多个 member 元素加入到集合 key 当中，已经存在于集合的 member 元素将被忽略。
//假如 key 不存在，则创建一个只包含 member 元素作成员的集合。
//当 key 不是集合类型时，返回一个错误。
//在Redis2.4版本以前， SADD 只接受单个 member 值。
public bool AddToSet(string key, byte[] member)
return SendDataExpectInt(member, "SADD", key) & 0;
public bool AddToSet(string key, string member)
return AddToSet(key, Encoding.UTF8.GetBytes(member));
//SCARD key
//返回集合 key 的基数(集合中元素的数量)。
public int CardinalityOfSet(string key)
return SendExpectInt("SCARD", key);
//SISMEMBER key member
//判断 member 元素是否集合 key 的成员。
public bool IsMemberOfSet(string key, byte[] member)
return SendDataExpectInt(member, "SISMEMBER", key) & 0;
public bool IsMemberOfSet(string key, string member)
return IsMemberOfSet(key, Encoding.UTF8.GetBytes(member));
//SMEMBERS key
//返回集合 key 中的所有成员。
//不存在的 key 被视为空集合。
public byte[][] GetMembersOfSet(string key)
return SendExpectDataArray("SMEMBERS", key);
//SRANDMEMBER key [count]
//如果命令执行时，只提供了 key 参数，那么返回集合中的一个随机元素。
//从 Redis 2.6 版本开始， SRANDMEMBER 命令接受可选的 count 参数：
//如果 count 为正数，且小于集合基数，那么命令返回一个包含 count 个元素的数组，数组中的元素各不相同。如果 count 大于等于集合基数，那么返回整个集合。
//如果 count 为负数，那么命令返回一个数组，数组中的元素可能会重复出现多次，而数组的长度为 count 的绝对值。
//该操作和 SPOP 相似，但 SPOP 将随机元素从集合中移除并返回，而 SRANDMEMBER 则仅仅返回随机元素，而不对集合进行任何改动。
public byte[] GetRandomMemberOfSet(string key)
return SendExpectData("SRANDMEMBER", key);
//移除并返回集合中的一个随机元素。
//如果只想获取一个随机元素，但不想该元素从集合中被移除的话，可以使用 SRANDMEMBER 命令。
public byte[] PopRandomMemberOfSet(string key)
return SendExpectData("SPOP", key);
//SREM key member [member ...]
//移除集合 key 中的一个或多个 member 元素，不存在的 member 元素会被忽略。
//当 key 不是集合类型，返回一个错误。
//在 Redis 2.4 版本以前， SREM 只接受单个 member 值。
public bool RemoveFromSet(string key, byte[] member)
return SendDataExpectInt(member, "SREM", key) & 0;
public bool RemoveFromSet(string key, string member)
return RemoveFromSet(key, Encoding.UTF8.GetBytes(member));
//SUNION key [key ...]
//返回一个集合的全部成员，该集合是所有给定集合的并集。
//不存在的 key 被视为空集。
public byte[][] GetUnionOfSets(params string[] keys)
if (keys == null)
throw new ArgumentNullException();
return SendExpectDataArray("SUNION", keys);
private void StoreSetCommands(string cmd, params string[] keys)
if (String.IsNullOrEmpty(cmd))
throw new ArgumentNullException("cmd");
if (keys == null)
throw new ArgumentNullException("keys");
SendExpectSuccess(cmd, keys);
//SUNIONSTORE destination key [key ...]
//这个命令类似于 SUNION 命令，但它将结果保存到 destination 集合，而不是简单地返回结果集。
//如果 destination 已经存在，则将其覆盖。
//destination 可以是 key 本身。
public void StoreUnionOfSets(params string[] keys)
StoreSetCommands("SUNIONSTORE", keys);
//SINTER key [key ...]
//返回一个集合的全部成员，该集合是所有给定集合的交集。
//不存在的 key 被视为空集。
//当给定集合当中有一个空集时，结果也为空集(根据集合运算定律)。
public byte[][] GetIntersectionOfSets(params string[] keys)
if (keys == null)
throw new ArgumentNullException();
return SendExpectDataArray("SINTER", keys);
public void StoreIntersectionOfSets(params string[] keys)
StoreSetCommands("SINTERSTORE", keys);
//SDIFF key [key ...]
//返回一个集合的全部成员，该集合是所有给定集合之间的差集。
//不存在的 key 被视为空集。
public byte[][] GetDifferenceOfSets(params string[] keys)
if (keys == null)
throw new ArgumentNullException();
return SendExpectDataArray("SDIFF", keys);
//SDIFFSTORE destination key [key ...]
//这个命令的作用和 SDIFF 类似，但它将结果保存到 destination 集合，而不是简单地返回结果集。
//如果 destination 集合已经存在，则将其覆盖。
//destination 可以是 key 本身。
public void StoreDifferenceOfSets(params string[] keys)
StoreSetCommands("SDIFFSTORE", keys);
//SMOVE source destination member
//将 member 元素从 source 集合移动到 destination 集合。
//SMOVE 是原子性操作。
//如果 source 集合不存在或不包含指定的 member 元素，则 SMOVE 命令不执行任何操作，仅返回 0 。否则， member 元素从 source 集合中被移除，并添加到 destination 集合中去。
//当 destination 集合已经包含 member 元素时， SMOVE 命令只是简单地将 source 集合中的 member 元素删除。
//当 source 或 destination 不是集合类型时，返回一个错误。
public bool MoveMemberToSet(string srcKey, string destKey, byte[] member)
return SendDataExpectInt(member, "SMOVE", srcKey, destKey) & 0;
#endregion
public void Dispose()
Dispose(true);
GC.SuppressFinalize(this);
Dispose(false);
protected virtual void Dispose(bool disposing)
if (disposing)
//请求服务器关闭与当前客户端的连接。
//一旦所有等待中的回复(如果有的话)顺利写入到客户端，连接就会被关闭。
SendCommand("QUIT");
ExpectSuccess();
socket.Close();
socket = null;
}}public class SortOptions{
public string Key { get; set; }
public bool Descending { get; set; }
public bool Lexographically { get; set; }
public Int32 LowerLimit { get; set; }
public Int32 UpperLimit { get; set; }
public string By { get; set; }
public string StoreInKey { get; set; }
public string Get { get; set; }
public object[] ToArgs()
var args = new ArrayList();
if (LowerLimit != 0 || UpperLimit != 0)
args.Add("LIMIT");
args.Add(LowerLimit);
args.Add(UpperLimit);
if (Lexographically)
args.Add("ALPHA");
if (!string.IsNullOrEmpty(By))
args.Add("BY");
args.Add(By);
if (!string.IsNullOrEmpty(Get))
args.Add("GET");
args.Add(Get);
return args.ToArray();
}}Test.cs测试类:internal class Test{
private static int nPassed;
private static int nFailed;
private static void Main(string[] args)
if (args.Length &= 2)
r = new Redis(args[0], Convert.ToInt16(args[1]));
else if (args.Length &= 1)
r = new Redis(args[0]);
r = new Redis();
r.Set("foo", "bar");
r.FlushAll();
assert((i = r.Keys.Length) == 0, "应该没有键，但有 {0}", i);
r.Set("foo", "bar");
assert((i = r.Keys.Length) == 1, "应该有一个键，但有{0}", i);
r.Set("foo bar", "bar foo");
assert((i = r.Keys.Length) == 2, "应该有两个键，但有{0}", i);
assert(r.TypeOf("foo") == Redis.KeyType.String, "type is not string");
r.Set("bar", "foo");
byte[][] arr = r.MGet("foo", "bar", "foo bar");
assert(arr.Length == 3, "expected 3 values");
assert((s = Encoding.UTF8.GetString(arr[0])) == "bar", "expected /"foo/" to be /"bar/", got /"{0}/"", s);
assert((s = Encoding.UTF8.GetString(arr[1])) == "foo", "expected /"bar/" to be /"foo/", got /"{0}/"", s);
assert((s = Encoding.UTF8.GetString(arr[2])) == "bar foo", "expected /"foo bar/" to be /"b?r foo/", got /"{0}/"",
r["{one}"] = "world";
assert(r.GetSet("{one}", "newvalue") == "world", "获取设置失败");
assert(r.Rename("{one}", "two"), "未能重命名!");
assert(!r.Rename("{one}", "{one}"), "应该已发送错误或重命名!");
r.Set("binary", new byte[] {0x00, 0x8F});
assert((i = r.Get("binary").Length) == 2, "预计2个字节，得到 {0}", i);
r.Db = 10;
r.Set("foo", "diez");
assert((s = r.GetString("foo")) == "diez", "got {0}", s);
assert(r.Remove("foo"), "无法删除foo");
assert(r.GetString("foo") == "bar", "foo不是bar");
assert(r.ContainsKey("foo"), "没有foo");
assert(r.Remove("foo", "bar") == 2, "没有删除两个键");
assert(!r.ContainsKey("foo"), "foo应不存在了。");
r.BackgroundSave();
Console.WriteLine("最后保存: {0}", r.LastSave);
//r.Shutdown ();
Dictionary&string, string& info = r.GetInfo();
foreach (string k in info.Keys)
Console.WriteLine("{0} -& {1}", k, info[k]);
var dict = new Dictionary&string, string&();
dict["hello"] = "world";
dict["goodbye"] = "my dear";
dict["beautiful"] = "green";
r.Set(dict);
assert((s = r.GetString("hello")) == "world", "got /"{0}/"", s);
assert((s = r.GetString("goodbye")) == "my dear", "got /"{0}/"", s);
assert((s = r.GetString("beautiful")) == "green", "got /"{0}/"", s);
r.RightPush("alist", "avalue");
r.RightPush("alist", "another value");
assert(r.ListLength("alist") == 2, "列表的长度应该是2");
string value = Encoding.UTF8.GetString(r.ListIndex("alist", 1));
if (!value.Equals("another value"))
Console.WriteLine("错误：收到{0}，本来应该是'another value'", value);
value = Encoding.UTF8.GetString(r.LeftPop("alist"));
if (!value.Equals("avalue"))
Console.WriteLine("错误：收到{0}，本来应该是'avalue'", value);
if (r.ListLength("alist") != 1)
Console.WriteLine("错误：列表弹出后应该有一个元素");
r.LeftPush("alist", "yet another value");
var so = new SortOptions();
so.Key = "alist";
so.Lexographically = true;
assert((s = Encoding.UTF8.GetString(r.Sort(so)[0])) == "another value",
"预期排序结果 /"another value/", got /"" + s + "/"");
assert((i = r.Sort("alist", "alist", new object[] {"ALPHA"}).Length) == 2, "预期排序结果 2, got {0}", i);
byte[][] values = r.ListRange("alist", 0, 1);
assert(Encoding.UTF8.GetString(values[0]).Equals("another value"), "范围内没有返回正确的值");
assert(r.AddToSet("FOO", Encoding.UTF8.GetBytes("BAR")), "problem adding to set");
assert(r.AddToSet("FOO", Encoding.UTF8.GetBytes("BAZ")), "problem adding to set");
assert(r.AddToSet("FOO", "Hoge"), "problem adding string to set");
assert(r.CardinalityOfSet("FOO") == 3, "基数应加入3项设置后，应该已经是3");
assert(r.IsMemberOfSet("FOO", Encoding.UTF8.GetBytes("BAR")), "BAR应该已经在集合");
assert(r.IsMemberOfSet("FOO", "BAR"), "BAR应该已经在集合");
byte[][] members = r.GetMembersOfSet("FOO");
assert(members.Length == 3, "集合应该有3个成员");
assert(r.RemoveFromSet("FOO", "Hoge"), "应当从集合已删除Hoge");
assert(!r.RemoveFromSet("FOO", "Hoge"), "Hoge不应该存在要删除");
assert(2 == r.GetMembersOfSet("FOO").Length, "取出Hoge后，集合应该有2个成员");
assert(r.AddToSet("BAR", Encoding.UTF8.GetBytes("BAR")), "problem adding to set");
assert(r.AddToSet("BAR", Encoding.UTF8.GetBytes("ITEM1")), "problem adding to set");
assert(r.AddToSet("BAR", Encoding.UTF8.GetBytes("ITEM2")), "problem adding string to set");
assert(r.GetUnionOfSets("FOO", "BAR").Length == 4, "结果合并后应该有4个成员");
assert(1 == r.GetIntersectionOfSets("FOO", "BAR").Length, "结果取交集应该有1项");
assert(1 == r.GetDifferenceOfSets("FOO", "BAR").Length, "结果差异应该有1项");
assert(2 == r.GetDifferenceOfSets("BAR", "FOO").Length, "结果差异应该有2项");
byte[] itm = r.GetRandomMemberOfSet("FOO");
assert(null != itm, "GetRandomMemberOfSet应返回一个项目");
assert(r.MoveMemberToSet("FOO", "BAR", itm), "在其内的数据应已经被转移到设置BAR");
r.FlushDb();
assert((i = r.Keys.Length) == 0, "应该没有键，但有 {0}", i);
r.Dispose();
Console.WriteLine("/n通过测试: {0}", nPassed);
if (nFailed & 0)
Console.WriteLine("测试失败: {0}", nFailed);
Console.ReadKey();
private static void assert(bool condition, string message, params object[] args)
if (condition)
nPassed ++;
nFailed ++;
Console.Error.WriteLine("失败: " + message, args);
}}运行结果:说明全部执行成功
最新教程周点击榜
微信扫一扫