C#获取Redis数据一般通过get方法,即通过get(Key)来获取值,如果数据量比较大,可以通过MGet方法来获取,一次性将所需要的数据提取到客户端。
实际代码:
- string SMsg = "";
- //读取设备的基础数据表
- string SSql2 = "Select语句";
- //将基础数据表中的数据读入内存中
- GlobalVar.DT_SBInfo = OracleHelper.SelectSql(SSql2, ref SMsg);
- //添加数据列
- DataColumn DC = new DataColumn("DataValue", typeof(float));
- GlobalVar.DT_SBInfo.Columns.Add(DC);
-
- int ArrCount = 0;//最大的获取记录数
- ArrCount = GlobalVar.DT_SBInfo.Rows.Count;
- string[] Keys = new string[ArrCount];//Key的数组
- string[] Values = new string[ArrCount];//Value的数组
- Dictionary<string,string> Dict=new Dictionary<string,string>();
-
- for (int i = 0; i < GlobalVar.DT_SBInfo.Rows.Count; i++)
- {
- Keys[i] = GlobalVar.DT_SBInfo.Rows[i]["TAG_NAME1"].ToString();
- }
- //连接Redis数据库
- var redis = new CSRedis.CSRedisClient("IP地址:端口号,password=密码,defaultDatabase=0,poolsize=500,ssl=false,writeBuffer=10240");
- //通过MGet获取数据,传入的是Key的数组,返回的是Value的数组
- Values = redis.MGet(Keys);
- for (int i = 0; i < Values.Length; i++)
- {
- if ( string.IsNullOrEmpty(Values[i]))
- {
- Values[i] = "0";
- }
- if (!Dict.ContainsKey(Keys[i]))
- {
- //先转换为字典,方便后面的数据检索
- Dict.Add(Keys[i], Values[i]);
- }
- }
-
- //更新DataValue值
- for (int i = 0; i < GlobalVar.DT_SBInfo.Rows.Count; i++)
- {
- GlobalVar.DT_SBInfo.Rows[i]["DataValue"] =float.Parse(Dict[GlobalVar.DT_SBInfo.Rows[i]["TAG_NAME1"].ToString()]);
- }
具体过程:
1、设定键和值的两个数组;
2、连接Redis数据库,通过Values = redis.MGet(Keys)得到Values数组的值;
3、将两个数组合成一个字典;
4、通过字典更新数据。
因为redis是内存数据库,速度实在快,4000条的记录对比差异并不明显,通过MGet略微比Get快一点,大约在1秒~4秒之间。