聽說讀寫

string fullPath = @"c:\log\1.log";
            int extentSize = 20 * 1024 * 1024;
            int logCount = 1 * 1000 * 100;
            LogStore _store = new LogStore(fullPath, FileMode.OpenOrCreate, FileAccess.ReadWrite, FileShare.ReadWrite);

            LogRecordSequence _sequence = new LogRecordSequence(_store, 1 * 1024 * 1024, 1024);

            _sequence.RetryAppend = true;

            if (_store.Extents.Count == 0)
            {
                _store.Extents.Add(fullPath, extentSize);
            }
            string logContent = @"
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
123123123FKLSDFJKLEJLJWER:KJRL:EJRL:KJEL:KRJL:KJL:WEUROPJFLKDJFKLSDKLFJSDFL:JFLJJKUHKKL*T^N12345KLHK
1
".Substring(0, 512);


            byte[] bytes = Encoding.UTF8.GetBytes(logContent);
            Console.WriteLine("Start CLFS Test");
            Console.WriteLine("Log Content Bytes:" + bytes.Length + " Byte");
            Console.WriteLine("Log Count:" + logCount);
            Console.WriteLine("Log File Size:" + logCount * bytes.Length + " Byte");
            _sequence.Append(new ArraySegment<byte>(bytes), SequenceNumber.Invalid, SequenceNumber.Invalid, RecordAppendOptions.ForceAppend);


            Stopwatch sw = Stopwatch.StartNew();
            for (int i = 0; i < logCount; i++)
            {
                //   _sequence.BeginAppend(new ArraySegment<byte>(bytes), SequenceNumber.Invalid,SequenceNumber.Invalid,,
                _sequence.Append(new ArraySegment<byte>(bytes), SequenceNumber.Invalid, SequenceNumber.Invalid, RecordAppendOptions.None);

            }

            sw.Stop();
            Console.WriteLine("Cost " + sw.ElapsedMilliseconds + " ms");
            Console.WriteLine("Log Write Speed " + logCount * 1000 / sw.ElapsedMilliseconds + " Records / per second");
            Console.WriteLine("Data Write Speed " + logCount * bytes.Length * 1000 / sw.ElapsedMilliseconds + " MB / per second");
            return;