Redis 数据总结(1 数据导入)

Posted leolzi

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Redis 数据总结(1 数据导入)相关的知识,希望对你有一定的参考价值。

1.windows 下数据导入命令:

type output.data | C:\\Redis\\redis-cli.exe -h "127.0.0.1" -p 6379 -a password --pipe

 

注意 : --help 可以查看相关的命令,  -n [db] 是转到相关的数据库  如: -n 3

2.生成文件相关的代码  C#

 FileStream fs = null;
                if (!Directory.Exists(mroot))//如果不存在就创建文件夹
                    Directory.CreateDirectory(mroot);
                if (!File.Exists(filepath))
                    fs = File.Create(filepath);//创建该文件
                if (fs == null)
                    fs = new FileStream(filepath, FileMode.Append);

                StreamWriter sw = new StreamWriter(fs);
                foreach (var ms in msg)
                {
                    //开始写入
                    var addstr = "*"+  (ms.Vals.Count +1) + "\\r\\n" +
                                        "$"+ GetStrByte(ms.Command)+"\\r\\n"+ms.Command+"\\r\\n";
                    foreach (var vv in ms.Vals)
                    {
                        addstr += "$" + GetStrByte(vv) + "\\r\\n" + vv+"\\r\\n";
                    }

                    sw.Write(addstr);
                }

                //清空缓冲区
                sw.Flush();
                //关闭流
                sw.Close();
                fs.Close();

语句初始化:

            List<RedisProtol> addCom = new List<RedisProtol>();

            foreach (var kv in keyValues)
            {
                //addCom.Add($"HSET {kv.Key}  {kv.Value.Name}  {kv.Value.Value}");
                var pro = new RedisProtol();

                pro.Command = "HSET";
                pro.Vals.Add(kv.Key);
                pro.Vals.Add(kv.Value.Name);
                pro.Vals.Add(kv.Value.Value);
                addCom.Add(pro);
            }
            FileSupport.Instance.RedisProWrite(addCom, filename);

 注意几点:

1)计算长度时用的是字节长度,不是字符长度,如果导入的数据中有中文特别要注意,并且要注意字符的编码问题:

技术图片

 

 2)生成的文件格式如下(注意回车和换行):

技术图片

 

以上是关于Redis 数据总结(1 数据导入)的主要内容,如果未能解决你的问题,请参考以下文章

redis客户端的几个问题总结

redis客户端的几个问题总结

Oracle 数据库 - 使用UEStudio修改dmp文件版本号,解决imp命令恢复的数据库与dmp本地文件版本号不匹配导致的导入失败问题,“ORACLE error 12547”问题处理(代码片段

大数据之使用Flink处理Kafka中的数据到Redis

Redis批量导入数据的方法

redis三种redis数据导出导入方式