String s = br.readLine();

lstring * RecvBuf(SOCKET so, struct MemPool * pool)
{char buf[1024+1];int r = 0;lstring * s = NewString("", pool);memset(&buf, 0, sizeof(buf));r = _recv(so, buf, sizeof(buf)-1, 0); //留下一个 #0 结尾if (r > 0){LString_AppendCString(s, buf, r);}if (r == 0) //一般都是断开了
  {MessageBox(0, "recv error.[socket close]", "", 0);return s;}return s;}//

int recv(SOCKET s, char *buf, int len, int flags);

//收取一行,可再优化
lstring * RecvLine(SOCKET so, struct MemPool * pool, lstring ** _buf)
{int i = 0;int index = -1;lstring * r = NULL;lstring * s = NULL;lstring * buf = *_buf;for (i=0;i<10;i++) //安全起见,不用 while ,用 for 一定次数就可以了
    {//index = pos("\n", buf);index = pos(NewString("\r\n", pool), buf);if (index>-1) break;s = RecvBuf(so, pool);buf->Append(buf, s);}if (index <0 ) return NewString("", pool);r = substring(buf, 0, index);buf = substring(buf, index + 2, Length(buf));*_buf = buf;return r;
}

function TIdTCPConnection.ReadLn(ATerminator: string = LF;const ATimeout: Integer = IdTimeoutDefault; AMaxLineLength: Integer = -1): string;
varLInputBufferSize: Integer;LSize: Integer;LTermPos: Integer;
beginif AMaxLineLength = -1 then beginAMaxLineLength := MaxLineLength;end;// User may pass '' if they need to pass arguments beyond the first.if Length(ATerminator) = 0 then beginATerminator := LF;end;FReadLnSplit := False;FReadLnTimedOut := False;LTermPos := 0;LSize := 0;repeatLInputBufferSize := InputBuffer.Size;if LInputBufferSize > 0 then beginLTermPos :=MemoryPos(ATerminator, PChar(InputBuffer.Memory) + LSize, LInputBufferSize - LSize);if LTermPos > 0 then beginLTermPos := LTermPos + LSize;end;LSize := LInputBufferSize;end;//ifif (LTermPos - 1 > AMaxLineLength) and (AMaxLineLength <> 0) then beginif MaxLineAction = maException then beginraise EIdReadLnMaxLineLengthExceeded.Create(RSReadLnMaxLineLengthExceeded);end else beginFReadLnSplit := True;Result := InputBuffer.Extract(AMaxLineLength);Exit;end;// ReadFromStack blocks - do not call unless we need toend else if LTermPos = 0 then beginif (LSize > AMaxLineLength) and (AMaxLineLength <> 0) then beginif MaxLineAction = maException then beginraise EIdReadLnMaxLineLengthExceeded.Create(RSReadLnMaxLineLengthExceeded);end else beginFReadLnSplit := True;Result := InputBuffer.Extract(AMaxLineLength);Exit;end;end;// ReadLn needs to call this as data may exist in the buffer, but no EOL yet disconnected
      CheckForDisconnect(True, True);// Can only return 0 if error or timeoutFReadLnTimedOut := ReadFromStack(True, ATimeout, ATimeout = IdTimeoutDefault) = 0;if ReadLnTimedout then beginResult := '';Exit;end;end;until LTermPos > 0;// Extract actual dataResult := InputBuffer.Extract(LTermPos + Length(ATerminator) - 1);// Strip terminatorsLTermPos := Length(Result) - Length(ATerminator);if (ATerminator = LF) and (LTermPos > 0) and (Result[LTermPos] = CR) then beginSetLength(Result, LTermPos - 1);end else beginSetLength(Result, LTermPos);end;
end;//ReadLn

#include <stdio.h>
#include <windows.h>
#include <time.h>
#include <winsock.h>#include "lstring.c"
#include "socketplus.c"
#include "lstring_functions.c"//vc 下要有可能要加 lib
//#pragma comment (lib,"*.lib")
//#pragma comment (lib,"libwsock32.a")
//#pragma comment (lib,"libwsock32.a")//SOCKET gSo = 0;
SOCKET gSo = -1;//收取一行,可再优化
lstring * RecvLine(SOCKET so, struct MemPool * pool, lstring ** _buf)
{int i = 0;int index = -1;lstring * r = NULL;lstring * s = NULL;lstring * buf = *_buf;for (i=0;i<10;i++) //安全起见,不用 while ,用 for 一定次数就可以了
    {//index = pos("\n", buf);index = pos(NewString("\r\n", pool), buf);if (index>-1) break;s = RecvBuf(so, pool);buf->Append(buf, s);}if (index <0 ) return NewString("", pool);r = substring(buf, 0, index);buf = substring(buf, index + 2, Length(buf));*_buf = buf;return r;
}void main()
{int r;mempool mem, * m;lstring * s;lstring * rs;lstring * buf;//--------------------------------------------------
mem = makemem(); m = &mem; //内存池,重要
    buf = NewString("", m);//--------------------------------------------------//直接装载各个 dll 函数
    LoadFunctions_Socket();InitWinSocket(); //初始化 socket, windows 下一定要有
gSo = CreateTcpClient();r = ConnectHost(gSo, "newbt.net", 25);if (r == 1) printf("连接成功!\r\n");s = NewString("EHLO\r\n", m);SendBuf(gSo, s->str, s->len);printf(s->str);s->Append(s, s);printf(s->str);s->AppendConst(s, "中文\r\n");printf(s->str);//--------------------------------------------------rs = RecvLine(gSo, m, &buf); //只收取一行
printf("\r\nRecvLine:");printf(rs->str); printf("\r\n");rs = RecvLine(gSo, m, &buf); //只收取一行
printf("\r\nRecvLine:");printf(rs->str); printf("\r\n");rs = RecvLine(gSo, m, &buf); //只收取一行
printf("\r\nRecvLine:");printf(rs->str); printf("\r\n");//--------------------------------------------------//    rs = RecvBuf(gSo, m); //注意这个并不只是收取一行
//
//    printf("\r\nRecvBuf:\r\n");
//    printf(rs->str);
//
//    rs = RecvBuf(gSo, m); //注意这个并不只是收取一行
//    printf("\r\nRecvBuf:\r\n");
//    printf(rs->str);//--------------------------------------------------
    Pool_Free(&mem); //释放内存池
    printf("gMallocCount:%d \r\n", gMallocCount); //看看有没有内存泄漏//简单的检测而已  //--------------------------------------------------
getch(); //getch().不过在VC中好象要用getch()，必须在头文件中加上<conio.h>

}