项目迭代开发手记--文件分割存储用例的实现过程（3）

项目迭代开发手记--文件分割存储用例的实现过程（3）

上午的迭代2完成后，我们获得了一个有完整压缩流功能的实现代码，这次迭代完成的代码是可用的，我们在迭代2中完成了我们既定的任务。在下午的小组讨论中，我们继续考虑下一阶段的迭代目标，由于没有决定图档文件的格式，我们决定先不考虑图片格式的问题，先实现文件的分割功能。文件的分割主要是考虑当图档文件太大的时，数据库提交性能会变得非常慢，分割的目的就是改进提交的性能。

迭代3：

对向数据库提交的二进制流进行分割压缩；那么从数据库提取的时候要进行解压和拼接操作，以获得原始图档数据。

在分割功能的设计和编码前，我们重新审视了上午的代码——那个压缩类TLoadBinaryDataToDB，发觉该类似乎职责太多，它要负责把文件装载成流，然后才对流进行压缩和解压缩，我们发现UnCompressStream函数有更好的通用性，只要是压缩的流就可以对其进行解压。而压缩功能在这个类里似乎只能对通过文件装载的流进行压缩，如果流是以另一种形式获得的，不是以文件装载的形式，那么我们不知道该如何对该流进行压缩。这里似乎违背了功能单一的职责，类既负责了流的装载，又负责流的压缩；于是我们对该类进行了重构已获得结构更好的的类，以增加类的重用性。

重构后的类只有两个公用的方法 CompressStream 和 UnCompressStream 它们都已流为参数，通过对传入流的处理来实现压缩和解压缩功能。

procedure TCompressStream.CompressStream(var stream: TMemoryStream);

var

  iSize: Integer;

  lDestStream: TMemoryStream;

  lCompressionStream: TCompressionStream;

begin

  lDestStream := TMemoryStream.Create;

  lCompressionStream := TCompressionStream.Create(clMax, lDestStream);

  try

    iSize := stream.Size; //获得图像流的原始尺寸

stream.SaveToStream(lCompressionStream); //将原始图像流进行压缩，

// lDestStream中保存着压缩后的图像流

    lCompressionStream.Free;

    stream.Clear;

    stream.WriteBuffer(iSize, SizeOf(iSize)); //写入原始图像的尺寸

    stream.CopyFrom(lDestStream, 0); //写入经过压缩的图像流

  finally

    lDestStream.Free

  end;

end;

解压缩函数

procedure TCompressStream.UnCompressStream(var stream: TMemoryStream);

var

  DecompressionStream: TDecompressionStream;

  Buffer: PChar;

  Count: Integer;

begin

  stream.ReadBuffer(Count, SizeOf(Count));

  GetMem(Buffer, Count); //根据图像尺寸大小为将要读入的原始图像流分配内存块

  DecompressionStream := TDecompressionStream.Create(stream);

  try

DecompressionStream.ReadBuffer(Buffer^, Count); //将被压缩的图像流解压缩，

//然后存入 Buffer内存块中

    stream.Clear;

    stream.WriteBuffer(Buffer^, Count); //将原始图像流保存至 stream流中

    stream.Position := 0;

  finally

    FreeMem(Buffer); // 释放内存

  end;

end;

经过重构后，类TCompressStream无疑提高了重用性，同时有更好的结构。除去了把文件装载成流的功能后，TCompressStream职责变得更单一了。它对已任何形式获得得的流都可以进行压缩和解压缩。完成TLoadBinaryDataToDB重构我们开始考虑对流进行分割功能的实现。

在假定一个流被分割成5份，那么拼接时就要有一个顺序我们考虑在数据库增加一个顺序的字段来保存流各个块之间的分割顺序。

同样我们考虑把这个功能封装在一个类里面。我们实现了一个叫TStreamIncise的类，在设计这个类时，我们为了更好的增加对这类要设计成什么样子进行了很好的讨论，首先我们模拟了如何使用该类。

  for I := 0 to IncisedCount - 1 do

    begin

      StreamIncise.GetInciseStream(lStream); //获得分割流

      ClientDataSet2.Append;

      ClientDataSet2.FieldByName('F_ID').Value := I; //取序列号

      ClientDataSet2.FieldByName('F_NAME').Value := FFileFullName;

      ClientDataSet2.FieldByName('F_SERIAL').Value := I; // 取每次分割的序列号

      lCompressionStream.CompressStream(lStream);

      (ClientDataSet2.FieldByName('F_BINARY_DATA')

 as TBlobField).LoadFromStream(lStream);

      ClientDataSet2.Post;

end;

我们用代码估计了类的调用方式，通过这样的模拟代码我们获得了以下信息

1）               要获得文件的被分割数，就是说如果使用上面的模拟代码，我们必须先获得流的分割数。

2）               TStreamIncise流在执行前先获得要处理流，同时设定分割块的大小。

如图：

我们用FInciseSize 来保存分割快的大小值，FStreamSize 保存流的大小值，FRemainSize保存每次分割后的剩余值。FInciseSize 在初始化函数 Create 中初始化。

FInciseSize := 50000; //设置分割的大小

LoadFromStream 把原始的流装载过来。

procedure TStreamIncise.LoadFromStream(stream: TMemoryStream);

begin

  FMemoryStream := stream; // 保存一个流的引用

  FStreamSize := stream.Size;

  FRemainSize := FStreamSize;

end;

GetIncisedCount 获得装载的原始流要被分割的数量。

function TStreamIncise.GetIncisedCount: Integer;

begin

  Result := FStreamSize div FInciseSize + 1;

end;

SetStreamDefault 用来把获得流设置到初始位置。

procedure TStreamIncise.SetStreamDefault;

begin

  if Assigned(FMemoryStream) then  FMemoryStream.Position :=0;

end;

核心的函数是GetInciseStream 通过调用它用户获得分割好后的流。

procedure TStreamIncise.GetInciseStream(inciseStream: TMemoryStream);

var

  iMaxError: Integer;

  Count: Integer;

  Buffer: PChar;

begin

  Count := GetBufferCount;

  GetMem(Buffer, Count);

  try

    FMemoryStream.ReadBuffer(Buffer^, Count);

    InciseStream.Clear;

    inciseStream.WriteBuffer(Buffer^, Count);

    InciseStream.Position := 0;

    FRemainSize := FRemainSize - Count;

  finally

    FreeMem(Buffer);

  end;

end;

这里GetBufferCount 每次返回分割块的大小，当剩余的流大小不够5000 时它返回剩下流的长度。

function TStreamIncise.GetBufferCount: Integer;

begin

  Result := FInciseSize;

  if FRemainSize