IdTCPClient中memorystream 的接收问题！急+郁闷！一晚上没折腾出来！

Question

ms: Tmemorystream;
Server端：
AThread.Connection.WriteStream(ms,true,true);Client端：
IdTCPClient1.ReadStream(ms, -1, True);为什么Client端停在这行就不动了 ？
我用wpe查看 数据已经过来了！这里是不是必须判断MS的长度？
测试了几种参数都是阻塞到这就完了！搜索了一下也没找到答案！
那位给个例子  郁闷死了。

Answer 1

如果是没有断开的情况你在客户端read的，把第三个参数设置为true的话，第二个参数设置为你传输stream的大小。可以这样修改：
Server端：
AThread.Connection.WriteInteger(ms.size);  //先发送大小；
AThread.Connection.WriteStream(ms,true,true);Client端：
size := IdTCPClient1.ReadInteger; //先读取大小。
IdTCPClient1.ReadStream(ms, size , True);

Answer 2

还有一个方法是，不发送大小，客户端读取buffer的大小，但是我没有试验成功。楼主可以试试。Server端：
AThread.Connection.WriteStream(ms,true,true);Client端：
size := IdTCPClient1.InputBuffer.Size; //先读取大小。
IdTCPClient1.ReadStream(ms, size , True);

Answer 3

在服务端发送完毕后，关掉连接，客户端的ReadStream就会返回(不然就会停在那里，一直等待读取，当然指定流的长度也是一样的道理)。

Answer 4

Server端：
AThread.Connection.OpenWriteBuffer;
AThread.Connection.WriteStream(ms,true,true);
AThread.FlushBuffer;
AThread.Connection.CloseWriteBuffer;Client端：
IdTCPClient1.ReadStream(ms, -1, False);酱紫……

Answer 5

如果是断开的情况，用 WGYKING(修罗是谁？！) 的方法可以，不断开还是要先接收大小。

Answer 6

Dlwxn(流云) 的第一种方法还是在那不动了：（
     
size := IdTCPClient1.InputBuffer.Size; //先读取大小。  读出的值一直是0！ 还是不行！修罗是谁？！的里面的 AThread.FlushBuffer; 我的怎么没有：（只有：AThread.Connection.FlushWriteBuffer;  试试先！不行再问

Answer 7

在indy的DEMO里有个ImageServer是这样的！
服务端：
if sCommand = 'PIC' then
    begin
    if FileExists(ExtractFileDir(ParamStr(0)) + '\images\' + sAction) then
        Begin
        lstRequests.items.add('Serving up: ' + sAction);
        // open file stream to image requested
        fStream := TFileStream.Create(ExtractFileDir(ParamStr(0)) + '\images\' + sAction,fmOpenRead + fmShareDenyNone);
        // copy file stream to write stream
        AThread.Connection.OpenWriteBuffer;
        AThread.Connection.WriteStream(fStream);
        AThread.Connection.CloseWriteBuffer;
        // free the file stream
        FreeAndNil(fStream);
        lstRequests.items.add('File transfer completed');
        End
    else
    AThread.Connection.WriteLn('ERR - Requested file does not exist');
    AThread.Connection.Disconnect;
    End；客户端：
with IdTCPClient do
    begin
    if connected then DisConnect;
    Host := edtServerHost.text;
    Port := StrToInt(edtServerPort.text);
    Connect;
    WriteLn('PIC:' + lstAvailableImages.Items[lstAvailableImages.itemindex]);
    // delete if exists
    // in production situation you might store binary downloads like this in a cache folder
    if FileExists(ExtractFileDir(ParamStr(0)) + '\' + lstAvailableImages.Items[lstAvailableImages.itemindex]) then
        DeleteFile(ExtractFileDir(ParamStr(0)) + '\' + lstAvailableImages.Items[lstAvailableImages.itemindex]);
    ftmpStream := TFileStream.Create(ExtractFileDir(ParamStr(0)) + '\' + lstAvailableImages.Items[lstAvailableImages.itemindex],fmCreate);
    while connected do
        ReadStream(fTmpStream,-1,true);
    FreeAndNil(fTmpStream);
    Disconnect;
    imgMain.Picture.LoadFromFile(ExtractFileDir(ParamStr(0)) + '\' + lstAvailableImages.Items[lstAvailableImages.itemindex]);
end;
但他处理数据后就断开连接 如果不断开的话是不是没有办法？

Answer 8

如果不断开，你要保证两端都没有writeln和readln，也就是你要发送任何的东西都用流的方式，这样没有问题的，我就这么用的，运行的没有问题。

Answer 9

第一种方式
Client端： 要判断的。
size := IdTCPClient1.ReadInteger; //先读取大小。
if size = 0 then
begin
  //释放资源.
  Exit;
end;
IdTCPClient1.ReadStream(ms, size , True);

Answer 10

CommBlock为记录服务端：
      MsSize := ms.Size;
      CommBlock.Command := 4003;
      CommBlock.RcSize := MsSize;
      AThread.Connection.WriteBuffer(CommBlock, SizeOf(CommBlock), true);
      AThread.Connection.WriteStream(ms, true, true);
接收端：      IdTCPClient1.ReadBuffer(CommBlock, sizeof(CommBlock));
      //size:=IdTCPClient1.ReadInteger; //注意这句
      size:=CommBlock.RcSize;
      if size = 0 then
      begin
        //释放资源.
       Exit;
      end;
      IdTCPClient1.ReadStream(ms, size , true);
这样写应该可以吧？我用的是indy9.0.14 我用WPE跟踪发现
AThread.Connection.WriteStream(ms, true, true); 这句已经发送了流的长度
于是我加了“size:=IdTCPClient1.ReadInteger; ”这句来配合他发送的长度！依旧不能结束等待：（是不是必须按 Dlwxn(流云) 的写法先
AThread.Connection.WriteInteger(ms.size);
然后接收配合
size := IdTCPClient1.ReadInteger;流云能给我个例子吗？谢谢先。

Answer 11

定义如下：
type
  ARecord = packed record
    Command : Integer;
    Content : String[30];
  end;var
  CommBlock : ARecord;服务端：
procedure TForm1.IdTCPServer1Exception(AThread: TIdPeerThread;
  AException: Exception);
var
  ms : TMemoryStream;
begin
  ms := TMemoryStream.Create;
  try
    CommBlock.Command := 4003;
    CommBlock.Content := 'Test ReadStream';
    ms.WriteBuffer(CommBlock, sizeof(CommBlock));    AThread.Connection.WriteInteger(ms.Size);   //先发送大小
    AThread.Connection.OpenWriteBuffer;
    try
      AThread.Connection.WriteStream(ms);
      AThread.Connection.CloseWriteBuffer;
    except
      AThread.Connection.CancelWriteBuffer;
    end;
  finally
    FreeAndNil(ms);
  end;
end;客户端：用timer控件读取，Interval=500,也可以用线程。
procedure TForm1.Timer1Timer(Sender: TObject);
var
  ms : TMemoryStream;
  size : Integer;
begin
  if not IdTCPClient1.Connected then Exit;
  ms := TMemoryStream.Create;
  try
    size := IdTCPClient1.ReadInteger;    //先读取大小。
    if size = 0 then
    begin
      FreeAndNil(ms);
      Exit;
    end;
    IdTCPClient1.ReadStream(ms, size, True);
    ms.Position := 0;
    ms.ReadBuffer(CommBlock, sizeof(CommBlock));
    RichEdit1.Lines.Add(IntToStr(CommBlock.Command));
    RichEdit1.Lines.Add(CommBlock.Content);
  finally
    FreeAndNil(ms);
  end;
end;其它的设置你自己应该能够搞定，如果还不可以，留下mail我把这个例子发给你。

Answer 12

注意：服务端：    ms.WriteBuffer(CommBlock, sizeof(CommBlock));    //AThread.Connection.WriteInteger(ms.Size);   //先发送大小
    AThread.Connection.OpenWriteBuffer;
    try
      AThread.Connection.WriteStream(ms, True, True);  //和上面的区别,如果这样，上面发送大小就不要了。
      AThread.Connection.CloseWriteBuffer;
    except
      AThread.Connection.CancelWriteBuffer;
    end;
  finally
    FreeAndNil(ms);

Answer 13

indy的控件毛病又多，效率又低，真不知道Borland怎么瞎了眼睛看上这套控件。
难道就是看他控件类型多还是所谓的设计模式用的多？

Answer 14

对于楼主这个问题，最简单的办法是用两个TIndyUDPServer,因为这个控件有OnRead事件
其实UDP是没有Client和Server的区别的，Indy非要搞个Client出来太书呆子了一些！

Answer 15

搞成这才正常接收为什么？ IdTCPClient1.ReadStream(ms, Size, False);