#include "stdafx.h"

#include <winsock.h>

#include <stdio.h>

#include <iostream.h>

 

 

    WSADATA wsa;        

    SOCKET sock, sock2;

    

    struct sockaddr_in peer;

    struct sockaddr_in accp;

 

    unsigned accp_len =sizeof(accp);

    

    int k,net,size,len;

    int headlen,bodylen;

    int port = 80 ;

 

    char * pbuf,* pbuf2;

    char sbuf[204800]="{text}";

    char Buf[200480]="{text}";

    char sbuf1[256]="{text}";

    char sbuf2[256]="{text}";

    char answ[512]="{text}";

 

    FILE *hd;

    BOOL HEADER=FALSE;

 

 

int main(int argc, char* argv[])

{

 

    printf("\n $$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$\n");

    printf(" $\t\t\t\t\t\t\t\t        $\n");

    printf(" $\t\t\t\t\t\t\t\t        $\n");    

    printf(" $\t      Simple Web Server by Elektrik (ICQ:262102)  \t        $\n");  

    printf(" $\t\t\t\t\t\t\t\t        $\n");

    printf(" $\t\t\t\t\t\t\t\t        $\n");        

    printf(" $$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$\n\n");

 

    printf("\n port: ");

    memset(sbuf,'{text}',sizeof(sbuf));

    gets(sbuf);

    for(int i=0;i<strlen(sbuf);i++)

    {

        if (!isdigit(sbuf[i]))

        {

            printf("\n  port: not correct\n");

            return 1;

        }

    }

    port=atoi(sbuf);

    if(port==0) port=80;

 

 

while(1)

{

    

    WSAStartup(MAKEWORD(1,1),&wsa);

 

    sock = socket(AF_INET,SOCK_STREAM,0);

 

    if ( sock == INVALID_SOCKET)

    {

        printf(" Cannot bild server\n");

        return 1;

    }

    

    peer.sin_family = AF_INET;

    peer.sin_port = htons(port);

    peer.sin_addr.s_addr = htonl(INADDR_ANY);

 

    net = bind(sock,(struct sockaddr *)&peer,sizeof(peer));

 

    if ( net!=0)

    {

        printf(" Cannot bild server with such port\n");

        return 1;

    }

    

    printf(" Server started [port==%d] .....",port);

    

    listen(sock,0);

 

    printf(" waiting for qwery\n");

 

    sock2=accept(sock,(struct sockaddr *) &accp,(int *) &accp_len);

 

    if (sock2==-1)

    {

        printf("\n accept==-1\n");

        return 1;

    }

 

    memset(sbuf,'{text}',sizeof(sbuf));

    memset(Buf,'{text}',sizeof(Buf));

 

    hd=fopen("c:\1.txt","at");

    

    for(net=0,len=0,bodylen=0;net!=SOCKET_ERROR;)

    {

        cout << endl << " recv: ";      

 

        net = recv(sock2,sbuf,sizeof(sbuf),0);

                

        if(net==SOCKET_ERROR)

        {

            printf("\n recv == -1\n");

            return 1;

        }

        

        cout << net << endl << endl;

 

        if (net==0) goto _SEND_;

        

        fwrite(sbuf,1,net,hd);

        strncat(Buf,sbuf,net);

        printf("%s",sbuf);  

 

// \r == 13(OxD) \n == 10(0xA)  

// 13 10 13 10

 

        if(!HEADER)

        {          

            for(int i=0;i<strlen(Buf);i++)      

            {

                if( // Точка границы заголовка и тела ответа

                    

                    Buf[i]   == 10  &&

                    Buf[i-1] == 13  &&

                    Buf[i-2] == 10  &&

                    Buf[i-3] == 13

 

                    ) // Заголовок принят, обрабатываем

                {

                    i++;       // учитываем ноль

                    headlen=i; // Длина заголовка

 

                    if(strstr(Buf,"GET")) goto _SEND_; // Всё приняли, иначе POST

                    

                    if(strstr(Buf,"POST"))

                    {

                        if(Buf[i]!=0) len=strlen(Buf+i); // Сколько приняли байт из тела, если POST

                                                

                        printf("\n bodylen: ");

 

                        pbuf=strstr(Buf,"Content-Length:");

                        if(pbuf)

                        {              

                            sscanf(pbuf,"%s%s",sbuf1,sbuf2);

                                                    

                            bodylen=atol(sbuf2); // Длина тела

                                                    

                            printf("%d\n\n",bodylen);                          

                        }

                    

                    }              

 

                    HEADER=TRUE; // Заголовок обработан

                    break;

                }

            }

        }

 

 

 

        if(HEADER) // Заголовок обработан

        {      

 

            len+=net; // Сколько приняли байт из тела

            if(len>=bodylen) // Приняли всё, посылаем ответ

            {

 

_SEND_:            

                strcpy(answ,"HTTP/1.1 200 OK\r\n");

                strcat(answ,"Server: My\r\n");      

                strcat(answ,"Connection: close\r\n");

                strcat(answ,"Content-Type: text/html\r\n\r\n");

                strcat(answ,"<html><body>\n<script language=\"JavaScript\">\nwindow.status = \"_ok_\";\n</script>\n</body></html>");

 

                for(net=0,k=0,len=strlen(answ);net!=SOCKET_ERROR;)

                {

 

                    cout << endl << endl << "\n\n send: ";

                    

                    net=send(sock2,(char*)(answ+k),len-k,0);

 

                    cout << net << endl << endl;

 

                    memset(Buf,'{text}',sizeof(Buf));

                    strncpy(Buf,answ+k,net);

                    printf("%s",Buf);

 

                    k+=net;                

 

                    if(net==SOCKET_ERROR)

                    {

                        printf(" send == -1\n");

                        return 1;

                    }                                  

 

                    if(k>=len) // Отослали всё

                    {

                        printf("\n\n answer was sending\n");

                        break;

                    }

                }          

                break;

            }

        }      

        

    }  

    

    fclose(hd);

 

    if(sock) closesocket(sock);

    if(sock2) closesocket(sock2);

 

    WSACleanup();

 

    printf("\n\n server closed\n");

 

    

}

    printf(" end\n");

    return 0;

}

setsockopt(sock,SOL_SOCKET,SO_RCVBUF,(char*)&size,sizeof(int));

buf = new char [size]="{text}";

 

    for(k=0,i=0;i!=SOCKET_ERROR;k+=i)

    {

        i=recv(sock,buf,sizeof(buf),0);

        if(i==0) break;

        здесь складываем в большой буфер, например с помощью memmove, или сначала в файл

    }

...

delete [] buf;