0

Добрый день! Делаю, FTP-клиент... Скачиваю файл:

     char buff[65536];
using namespace std;
char sss[512];
struct hostent *host,*host2;
char addr[]="87.224.183.162";//ftp://162.183-224-87.telenet.ru/
fstream stream;
unsigned int file_size;
char file_name[256];
void reverse(char *str)
{
    char temp;
    int len;
    int i;

    len = strlen(str) - 1;

    for (i = 0; i <= len / 2; i++)
    {
        temp = str[i];
        str[i] = str[len - i];
        str[len - i] = temp;
    }

    str[len + 1] = '\0';
}

SOCKET init_data(SOCKET s) {
    SOCKET ds;
    send(s,"PASV\r\n",strlen("PASV\r\n"),0);
    cout<<endl<<"C: PASV";
    recv(s,buff,1024,0);
    cout <<endl<< "S: "<< buff; ////выводим на экран полученную от сервера строку

    int a,b;
    char *tmp_char;
    tmp_char = strtok(buff,"(");
    tmp_char = strtok(NULL,"(");
    tmp_char = strtok(tmp_char, ")");
    int c,d,e,f;
    sscanf(tmp_char, "%d,%d,%d,%d,%d,%d",&c,&d,&e,&f,&a,&b);
    int len;
    sockaddr_in address;
    int result;

    int port = a*256 + b;

    ds = socket(AF_INET, SOCK_STREAM,0);
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = inet_addr(addr);   ///addr - у меня глобальная переменная с адресом сервера
    address.sin_port = htons(port);

    len = sizeof(address);
    result = connect(ds, (sockaddr *)&address, len);
    if (result == -1) {
           perror("oops: client");
        return -1;
    }

    return ds;
}

void sending(char a[],SOCKET ss){
    send(ss,a,strlen(a),0);
    cout<<"\nC: "<<a;
}

void readServ(SOCKET S) {
    for(int i=0;i<1024;i++)
            buff[i]='\0';

    recv(S,buff,1024,0);
        cout << "S: "<<buff;
        Sleep(1000);
        //return 777;
}

int init_sock() {

    WSADATA WSAData;
    if(WSAStartup(MAKEWORD(2,0),&WSAData) != 0)
     {
          cout << "786";
          getch();
          exit(0);
     }

    SOCKET S;
    sockaddr_in address;
    S = socket(AF_INET,SOCK_STREAM,0);
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = inet_addr(addr);// was 77.246.101.195    87.224.183.162    87.224.147.100    134.169.34.11 lin   
    address.sin_port = htons(21);
    if(address.sin_addr.s_addr == INADDR_NONE)
    {
        host = NULL;
        host = gethostbyname(addr);

         if(host == NULL)
        {
//            MessageBox::Show("SERVER CONNECTION ERROR");
            exit(0);
        }
        memcpy(&address.sin_addr, host->h_addr_list[0], host->h_length);
    }

    int len;
    int result;
    len = sizeof(address);
    result = connect(S, (sockaddr *)&address, len);
    if (result == -1) 
    {
        cout << "87698";
        getch();
        exit(0);
    }
    cout << "Connection Estabilished!\n";
    readServ(S);
 return S;

}

char *getdata(SOCKET ds){
    char file[65536];
    for(int i=0; i<65536; i++)
        file[i]='\0';
    recv(ds, file,sizeof(file),0);
    closesocket(ds); 
    return file;
}

int getfile(SOCKET ds){
    char *tmp_char;
        tmp_char = strtok(buff,"\r\n");
    char t[256];
    memset(t,'\0',sizeof(t));
    strcpy(t, tmp_char);
    int i=44, u=0;
    char n[256];
    memset(n,'\0',sizeof(n));
    while(t[i]!='\0'){
        n[u]=t[i];
        i++; u++;
    }
    u-=8; i=0;
    char e[256];
    memset(e,'\0', sizeof(e));
    while(n[u]!='('){
        e[i]=n[u];
        i++; u--;
    }
    reverse(e);
    file_size=atoi(e);
    int n_len=u-1;
    for(int i=0; i<n_len;i++)
            file_name[i]=n[i];

    stream.open(file_name,ios::out | ios::binary | ios::trunc);
    if(!stream){
        cout<<"Error open\n";
        getch();
        return 0;
    }

    char file[512];
    memset(file,'\0',65536);
    int num=0;
    unsigned int k=0;

    while( num=recv(ds, &file[0], strlen(file),0) || k < file_size){
        if(num<0){
            cout<<"Error";
            printf(" %d\n", WSAGetLastError());
            break;
        }
        k+=strlen(file);
        stream<<file;
        memset(file,'\0',sizeof(file));
        system("cls");
        cout<<"Recieved "<<k<<" bytes\n";
    }

    closesocket(ds);
    return 0;
}

int main() {
    setlocale(0,"");

    SOCKET DATA;
    SOCKET S;
    S = init_sock();

    /*char str1[512];
    sprintf(str1,"QUIT\r\n");

    sending(str1,S);
    readServ(S);*/

    char name[64] = "anonymous";
    char str[512];
    sprintf(str,"USER %s\r\n",name);

    sending(str,S);
    readServ(S);

    char pass[64] = "anonymous";
    sprintf(str,"PASS %s\r\n",pass);

    sending(str,S);
    readServ(S);

    DATA=init_data(S);

    strcpy(pass,"/");
    sending("LIST\r\n",S);
    Sleep(2000);
    readServ(S);//Ответ

    char file[65536];
    strcpy(file, getdata(DATA));//Список
    cout<<file<<endl;//Ответ -список

    sending("TYPE I\r\n",S);
    readServ(S);
    sending("CWD ! ! Новинки КИНО\r\n",S);
    readServ(S);
    sending("CWD Шеф (комедия) [2012]\r\n",S);
    readServ(S);
    Sleep(2000);

    DATA=init_data(S);
    sending("LIST\r\n",S);
    Sleep(2000);
    readServ(S);
    strcpy(file, getdata(DATA));//Список
    cout<<file<<endl;//Ответ -список
    //-------------------------------------------------Файл!!!

    DATA=init_data(S);
    sending("RETR Обложка.jpg\r\n",S);
    readServ(S);
    Sleep(2000);
    getfile(DATA);

    closesocket(S);  ///закрытие соединения
    WSACleanup();

    stream.close();
    getch();

    return 0;
}

Файлы приходят не полностью... Иногда полностью... Маленькие приходят, (относительно маленькие 65 байт, 111 байт). Большие как-то странно приходят(кусками, спрева кусок начала, затем через сколько-то байт, а потом вообще ничего не приходит...). Будто сервер шлет Огромный кусок, а мой клиент вырывает из этого куска сколько влазит в переменную... Может размер отправляемого куска можно как-то установить? У меня FTP pasv...

13
  • 1
    @Alerr, вот тут while(num=recv(ds, &file[0], sizeof(file),0)!=-1){ num=recv(ds, &file[0], sizeof(file),0) надо в скобочки заключить.
    – avp
    19 апр 2013 в 11:58
  • while((num=recv(ds, &file[0], sizeof(file),0))!=-1) сделал, всё равно ничего не изменилось...
    – Alerr
    19 апр 2013 в 12:12
  • @alexlz, приём 0 байт означает только приём 0 байт, а конец файла это только в том случае, если общее количество принятого равно длине файла (это как раз из тех вещей, которые я имел в виду говоря про read() когда-то, и любой сокетовед обязан это знать, несмотря на то, что написано в man recv(2))
    – user6550
    19 апр 2013 в 12:26
  • @Alerr, ну, понятно же, что на самом деле надо писать while(num=recv(ds, file, sizeof(file),0) { if(num<0){ cout<<"Error"; .... если file - это массив размещенный в функции (или статический). Вы бы значимые куски кода (объявление переменных, отведение памяти) тоже привели, тогда понятней было бы, что Вы думаете, а что делаете. -- Кстати, передача файла по сокету ds завершается закрытие сокета со стороны передатчика? Или конец передачи определяется как-то по другому? Что RFC по FTP говорит на этот счет? Просто читать лень.
    – avp
    19 апр 2013 в 12:36
  • @klopp что ещё за приём 0 байт при блокирующем чтении? @Alerr запустите wireshark и посмотрите, что идёт по портам 20 (ftp-data) и 21. У Вашей программы и у браузера.
    – alexlz
    19 апр 2013 в 12:48

1 ответ 1

1

Если бы внимательно слушали, то всё получилось бы. alt text

Код у вас рабочий. Только запись принятых данных выполняется неправильно.


Вот код

#include <stdio.h>
#include <tchar.h>
#ifndef _WINSOCKAPI_ 
#include <winsock2.h>
#endif
#include <iostream>
#include <string>
#include <fstream>
#pragma comment(lib, "ws2_32.lib")




char buff[65536];
using namespace std;
char sss[512];
struct hostent *host,*host2;
char addr[]="87.224.183.162";//ftp://162.183-224-87.telenet.ru/
std::fstream stream;
unsigned int file_size;
char file_name[256];
void reverse(char *str)
{
    char temp;
    int len;
    int i;

    len = strlen(str) - 1;

    for (i = 0; i <= len / 2; i++)
    {
        temp = str[i];
        str[i] = str[len - i];
        str[len - i] = temp;
    }

    str[len + 1] = '\0';
}

SOCKET init_data(SOCKET s) {
    SOCKET ds;
    send(s,"PASV\r\n",strlen("PASV\r\n"),0);
    cout<<endl<<"C: PASV";
    recv(s,buff,1024,0);
    cout <<endl<< "S: "<< buff; ////выводим на экран полученную от сервера строку

    int a,b;
    char *tmp_char;
    tmp_char = strtok(buff,"(");
    tmp_char = strtok(NULL,"(");
    tmp_char = strtok(tmp_char, ")");
    int c,d,e,f;
    sscanf(tmp_char, "%d,%d,%d,%d,%d,%d",&c,&d,&e,&f,&a,&b);
    int len;
    sockaddr_in address;
    int result;

    int port = a*256 + b;

    ds = socket(AF_INET, SOCK_STREAM,0);
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = inet_addr(addr);   ///addr - у меня глобальная переменная с адресом сервера
    address.sin_port = htons(port);

    len = sizeof(address);
    result = connect(ds, (sockaddr *)&address, len);
    if (result == -1) {
           perror("oops: client");
        return -1;
    }

    return ds;
}

void sending(char a[],SOCKET ss){
    send(ss,a,strlen(a),0);
    cout<<"\nC: "<<a;
}

void readServ(SOCKET S) {
    for(int i=0;i<1024;i++)
            buff[i]='\0';

    recv(S,buff,1024,0);
        cout << "S: "<<buff;
        Sleep(1000);
        //return 777;
}

int init_sock() {

    WSADATA WSAData;
    if(WSAStartup(MAKEWORD(2,0),&WSAData) != 0)
     {
          cout << "786";
         // getch();
         // exit(0);
     }

    SOCKET S;
    sockaddr_in address;
    S = socket(AF_INET,SOCK_STREAM,0);
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = inet_addr(addr);// was 77.246.101.195    87.224.183.162    87.224.147.100    134.169.34.11 lin   
    address.sin_port = htons(21);
    if(address.sin_addr.s_addr == INADDR_NONE)
    {
        host = NULL;
        host = gethostbyname(addr);

         if(host == NULL)
        {
//            MessageBox::Show("SERVER CONNECTION ERROR");
            exit(0);
        }
        memcpy(&address.sin_addr, host->h_addr_list[0], host->h_length);
    }

    int len;
    int result;
    len = sizeof(address);
    result = connect(S, (sockaddr *)&address, len);
    if (result == -1) 
    {
        cout << "87698";
//        getch();
        exit(0);
    }
    cout << "Connection Estabilished!\n";
    readServ(S);
 return S;

}

char *getdata(SOCKET ds){
    char file[65536];
    for(int i=0; i<65536; i++)
        file[i]='\0';
    recv(ds, file,sizeof(file),0);
    closesocket(ds); 
    return file;
}

int getfile(SOCKET ds){
    char *tmp_char;
        tmp_char = strtok(buff,"\r\n");
    char t[256];
    memset(t,'\0',sizeof(t));
    strcpy(t, tmp_char);
    int i=44, u=0;
    char n[256];
    memset(n,'\0',sizeof(n));
    while(t[i]!='\0'){
        n[u]=t[i];
        i++; u++;
    }
    u-=8; i=0;
    char e[256];
    memset(e,'\0', sizeof(e));
    while(n[u]!='('){
        e[i]=n[u];
        i++; u--;
    }
    reverse(e);
    file_size=atoi(e);
    int n_len=u-1;
    for(int i=0; i<n_len;i++)
            file_name[i]=n[i];

    stream.open(file_name,ios::out | ios::binary | ios::trunc);
    if(!stream){
        cout<<"Error open\n";
//        getch();
        return 0;
    }

    char file[4096];
    int num=0;
    unsigned int k=0;
int размер_файла=0;
    while( num=recv(ds, file, 4096,0)){
        if(num<0){
            cout<<"Error";
            printf(" %d\n", WSAGetLastError());
            break;
        }

// записывается сразу в файл
stream.write(file,num);
  размер_файла+=num;
cout<<"Recieved "<< num <<" bytes\n";
Sleep(5);
}

std::cout<<"\nRecieved байт"<< размер_файла;
closesocket(ds);
return 1;
}

int main() {
    setlocale(0,"");

    SOCKET DATA;
    SOCKET S;
    S = init_sock();

    /*char str1[512];
    sprintf(str1,"QUIT\r\n");

    sending(str1,S);
    readServ(S);*/

    char name[64] = "anonymous";
    char str[512];
    sprintf(str,"USER %s\r\n",name);

    sending(str,S);
    readServ(S);

    char pass[64] = "anonymous";
    sprintf(str,"PASS %s\r\n",pass);

    sending(str,S);
    readServ(S);

    DATA=init_data(S);

    strcpy(pass,"/");
    sending("LIST\r\n",S);
    Sleep(444);
    readServ(S);//Ответ

    char file[65536];
    strcpy(file, getdata(DATA));//Список
    cout<<file<<endl;//Ответ -список

    sending("TYPE I\r\n",S);
    readServ(S);
    sending("CWD ! ! Новинки КИНО\r\n",S);
    readServ(S);
    sending("CWD Шеф (комедия) [2012]\r\n",S);
    readServ(S);
    Sleep(444);

    DATA=init_data(S);
    sending("LIST\r\n",S);
    Sleep(444);
    readServ(S);
    strcpy(file, getdata(DATA));//Список
    cout<<file<<endl;//Ответ -список
    //-------------------------------------------------Файл!!!

    DATA=init_data(S);
    sending("RETR Обложка.jpg\r\n",S);
    readServ(S);
    Sleep(444);
    getfile(DATA);

    closesocket(S);  ///закрытие соединения
    WSACleanup();

    stream.close();
//    getch();


std::system("pause");
    return 0;
}
13
  • вывел ошибка recv 0.
    – Alerr
    19 апр 2013 в 14:38
  • 1
    gracefully -- изящно, элегантно. Это нормальное закрытие соединения.
    – alexlz
    19 апр 2013 в 15:03
  • 1
    @Alerr Вы в функцию recv() передаете размер буфера равный 0. strlen(file) считает размер файла до первого нулевого символа. А так как вы массив 'file' полностью заполняете тер-нулями, то strlen возвращает 0, и recv() возвращает ошибку. Затем вы помещаете бинарный массив 'file' в поток stream, без указания размера этого массива. Проще использовать std::string заполняя его методом append(массив,'размер'). Где 'размер' это то что возвращает recv(). Затем уже готовую строку std::string наполненую бинарными данными(изображением) можно записать в файл.
    – manking
    19 апр 2013 в 15:57
  • 1
    А вот это-то memset(file,'\0',4096); зачем ??? Можно ведь file[num] = 0; // num это количество прочитанных байт после проверки if(num<0){ cout<<"Error"; printf(" %d\n", WSAGetLastError()); break; } Идея же с хранением получаемого файла в string на мой взгляд не слишком хорошая.
    – avp
    19 апр 2013 в 17:13
  • 1
    @manking, да просто файл может быть большой, лучше его по мере поступления в файл записывать. Даже если потом весь его надо вернуть, как string. Просто каждый append (куска большего, чем разница между str.size() и str.capacity()) будет на самом деле делать копию str и в конце чтения память, занимаемая данными вообще удвоится. Лучше записать в файл (все равно в памяти (файловом кэше) осядет), а потом уже, зная размер, прочесть этот файл в string достаточного размера. Это если решились использовать string, но на мой вкус тут больше подойдет тривиальный char * и malloc (или new).
    – avp
    19 апр 2013 в 18:09

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.