我写了一些代码,它接受一个连接,但不接受数据.

服务器

这个类是服务器;应该接受连接并输出正在发送的缓冲区的大小.但是它正在输出0

#include "comms.h"Comms::Comms(QString hostIP,quint16 hostPort){    server = new QTcpserver(this);    hostAddress.setAddress(hostIP);    this->hostPort = hostPort;}void Comms::attemptConnection(){    connect(server,SIGNAL(newConnection()),this,SLOT(connectionAccepted()));    //socket = server->nextPendingConnection();    server->listen(hostAddress,hostPort);    //receivedData = socket->readAll();}void Comms::connectionAccepted(){    qDebug()<<"Connected";    socket = new QTcpsocket(server->nextPendingConnection());    char* rec = new char[socket->readBufferSize()];    qDebug()<<socket->readBufferSize();}

客户

这个类是客户端.它应该是发送字符串“你好”.它成功发送(据我所知)

#include "toplevelcomms.h"#include "stdio.h"TopLevelComms::TopLevelComms(QString hostIP,quint16 hostPort){    tcpsocket = new QTcpsocket();    hostAddress.setAddress(hostIP);    this->hostPort = hostPort;}void TopLevelComms::connect(){    tcpsocket->connectToHost(hostAddress,hostPort,qiodevice::ReadWrite);    //tcpsocket->waitForConnected(1);    QString string = "Hello";    QByteArray array;    array.append(string);    qDebug()<<tcpsocket->write(array);}

请告诉我我在做错什么,或告诉我在Qt中建立我想要的一般逻辑.

void TopLevelComms::connect(){    tcpsocket->connectToHost(hostAddress,qiodevice::ReadWrite);    if(tcpsocket->waitForConnected()) // putting 1 as parameter isn't reasonable,using default 3000ms value    {        QString string = "Hello";        QByteArray array;        array.append(string);        qDebug()<<tcpsocket->write(array);    }    else    {        qDebug() << "Couldn't connect";    }}

注意：您也没有检查是否能够听

void Comms::attemptConnection(){    connect(server,SLOT(connectionAccepted()));    //socket = server->nextPendingConnection();    if(server->listen(hostAddress,hostPort))    {        qDebug() << "Server listening";    }    else    {        qDebug() << "Couldn't listen to port" << server->serverPort() << ":" << server->errorString();    }    //receivedData = socket->readAll();}

最后一件事.请注意,QTcpserver :: nextPendingConnection()返回QTcpsocket,因此,不要采用新的连接,您可以使用nextPendingConnection创建新的QTcpsocket作为父

void Comms::connectionAccepted(){    qDebug()<<"Connected";    // WRONG! it will use QTcpsocket::QTcpsocket(QObject * parent)    //socket = new QTcpsocket(server->nextPendingConnection());    // use simple asign    socket = server->nextPendingConnection();    // move reading to slot    connect(socket,SIGNAL(readyRead()),SLOT(readSocket()));}

现在我们将把阅读移到单独的插槽

void Comms::readSocket(){    // note that dynamic size array is incompatible with some compilers    // we will use Qt data structure for that    //char* rec = new char[socket->readBufferSize()];    qDebug()<<socket->readBufferSize();    // note that QByteArray can be casted to char * and const char *    QByteArray data = socket->readAll();}

我必须承认,这样的小代码示例是很多错误.您需要了解有关TCP / IP连接的一些知识.那些是流,并且没有一个保证,整个数据块将一次给你

procedure TFormMain.IdTcpserverExecute(AContext: TIdContext);
var
  RxBufStr: UTF8String;
  RxBufSize: Integer;
begin

  if AContext.Connection.IOHandler.Readable then
  begin
    RxBufSize := AContext.Connection.IOHandler.InputBuffer.Size;
    if RxBufSize > 0 then
    begin
      SetLength(RxBufStr,RxBufSize);
      AContext.Connection.IOHandler.ReadBytes(TBytes(RxBufStr),RxBufSize,False);
    end;
  end;

end;

AContext.Connection.IOHandler.InputBuffer.Size似乎不可靠并经常返回0,但是在下次运行时,OnExecute它将获取正确的字节数,但为时已晚.

基本上我希望能够只获取所有数据,将其填充到UTF8String(不是Unicode字符串),然后解析一个特殊的标记.所以我没有标题,消息长度可变.似乎Indy 10 IOHandlers没有为此设置,或者我只是错误地使用它.

做一些像传递一定大小的缓冲区,尽可能多地填充它并返回实际填充的字节数然后继续运行(如果还有更多)会很好.

除了TIdSchedulerOfFiber的状态之外,这看起来非常有趣,它有用吗？有人用吗？我注意到它不在Delphi 2009的标准安装中.

更新：我发现Msg：= AContext.Connection.IOHandler.ReadLn(#0,enUTF8);哪个有效,但我仍然想知道上述问题的答案,是因为它是基于阻止IO吗？这使得TIdSchedulerOfFiber更加热衷于此.

procedure TFormMain.IdTcpserverExecute(AContext: TIdContext);
var
  RxBuf: TIdBytes;
begin
  RxBuf := nil;
  with AContext.Connection.IOHandler do
  begin
    CheckForDataOnSource(10);
    if not InputBufferIsEmpty then
    begin
      InputBuffer.ExtractToBytes(RxBuf);
      // process RxBuf as needed...
    end;
  end;
end;

或者：

procedure TFormMain.IdTcpserverExecute(AContext: TIdContext);
var
  RxBufStr: String; // not UTF8String
begin
  with AContext.Connection.IOHandler do
  begin
    CheckForDataOnSource(10);
    if not InputBufferIsEmpty then
    begin
      RxBufStr := InputBuffer.Extract(-1,enUtf8);

      // Alternatively to above,you can set the
      // InputBuffer.Encoding property to enUtf8
      // beforehand,and then call TIdBuffer.Extract()
      // without any parameters.
      //
      // Or,set the IOHandler.DefStringEncoding
      // property to enUtf8 beforehand,and then
      // call TIdioHandler.InputBufferAsstring()

      // process RxBufStr as needed...
    end;
  end;
end;

至于TIdSchedulerOfFiber – 此时SuperCore包实际上已经死了.它还没有在很长一段时间内完成,也没有与最新的Indy 10架构保持同步.我们可能会在以后尝试复活它,但它不在我们不久的将来的计划中.