Помогите... Работа с файлами в сети -> Форум на Исходниках.Ру

	Наши проекты: Журнал · Discuz!ML · Wiki · DRKB · Помощь проекту

Здравствуйте, Гость ! [18.97.14.86]

Правила раздела по сетевому программированию

Помогите... Работа с файлами в сети

Lyrik	Сообщ. #1 , 14.01.03, 19:24
Profi Профиль · PM Рейтинг (т): 21	Кто-нибудь знает как отослать\принять файл по сети (TCP/IP) с использованием WinSock. Желательно поподробнее :-[

Lavrik

Сообщ. #2 , 15.01.03, 06:27

Profi

Профиль · PM

Рейтинг (т): 22

сервак:

// server.cpp : Defines the entry point for the application. #include "stdafx.h" #include <ras.h> #include <winsock2.h> #include <windows.h> #include <stdio.h> #include <stdlib.h> #include <conio.h> #include <crtdbg.h> #define PORT 28912 //порт char* ReceiveFile(char* name,int size,SOCKET s); //получение файла int scksend(char* data,SOCKET s); //посылка сокетом данных int receive(char* buff,int num,SOCKET s); //прием сокетом данных int parser(char* str); void commands(char** list); SOCKET client; //клиент SOCKET server; //сервер //--------------------------------------------------------------------------- // MAIN (BODY) PROGRAM //--------------------------------------------------------------------------- int APIENTRY WinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, LPSTR lpCmdLine, int nCmdShow) { int i; bool end; char getchar[2]; char* argument=(char *)calloc(1024,sizeof(char)); //инициализируем процесс библиотеки wsock32.dll WSADATA WsaData; int err = WSAStartup (0x0101, &WsaData); if (err == SOCKET_ERROR) goto EXIT; //теперь объявляем переменную типа SOCKET server = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP); //задаем параметры для сокета (сервера) if(server==INVALID_SOCKET) goto EXIT; SOCKADDR_IN sin; sin.sin_family = AF_INET; sin.sin_port = htons(PORT); sin.sin_addr.s_addr = INADDR_ANY; //подключаем socket к коммуникационной среде err = bind( server, (LPSOCKADDR)&sin, sizeof(sin) ); if(err==-1) goto EXIT; //создаем очереть для ожедания вызовов от клиентов err = listen( server, SOMAXCONN); if(err==-1) goto EXIT; //вечный цикл для многократного обслушивания запросов от клиентов while(true) { //принемаем запрос от программ-клиента на установление связи SOCKADDR_IN from; int fromlen=sizeof(from); client = accept(server,(struct sockaddr*)&from, &fromlen); while(true) { argument[0]= '\0'; getchar[0] = '\0'; end=false,i=0; while(!end||i>50) { receive(getchar,1,client); getchar[0]=*getchar; if(getchar[0]=='\0') goto EXIT; if(getchar[0]!='\n') { argument[i]=getchar[0]; i++; } else end=true; } argument[i]='\0'; if(!parser(argument)) //вход в разбор полученной команды goto EXIT; } } EXIT: free(argument); if (client!=INVALID_SOCKET) // Если клиент еще не слетел, то closesocket(client); // аккурат закрываем closesocket(server); // close server socket WSACleanup(); // free winsock return 0; } //--------------------------------------------------------------------------- // Функция отсылки данных клиенту //--------------------------------------------------------------------------- int scksend(char* data,SOCKET s) { // data - строка для отправки int sendchar, // Количество отправленных символов currchar=0, // Точка останова отправки ndata; // Длина того, что отправляем ndata=strlen(data); while(currchar<ndata) { sendchar=send(s,(char*)(data + currchar),ndata-currchar,NULL); if(sendchar==SOCKET_ERROR) return 0; currchar+=sendchar; } return 1; }; //--------------------------------------------------------------------------- // Функция получения данных от клиента //--------------------------------------------------------------------------- int receive(char* buff,int num,SOCKET s) // массив куда получить и кол-во сколько { // надо получить от сервера int recvchar; // Длина того, что получили recvchar=recv(client,buff,num,NULL); if (recvchar==SOCKET_ERROR) return 0;//goto EXIT;// SERROR(); buff[recvchar]='\0'; return recvchar; }; //--------------------------------------------------------------------------- // Функция разбиения строки на команды //--------------------------------------------------------------------------- int parser(char* str) { int j,st=0,count=0;bool sp=true;; char **s=(char **)calloc(3,sizeof(char*)); for(j=0;j<3;j++) s[j]=(char *)calloc(1024,sizeof(char)); for(int i=0;i<strlen(str);i++){ if (str[i] == '$'){ if (!sp){ count=0; st++; } sp = true; } else{ sp = false; s[st][count]=str[i]; count++; } } commands(s); //выполнение соответсвующей команды for(j=0;j<Number;j++){ s[j]='\0'; delete[]s[j]; } return 0; } //--------------------------------------------------------------------------- // Функция выбора команды и выполнение ее //--------------------------------------------------------------------------- void commands(char** list) { if(strcmp(list[0],"FILE")==0) scksend(ReceiveFile(list[1],atoi(list[2]),client),client); } //--------------------------------------------------------------------------- // Подпрограмммы получения файла //--------------------------------------------------------------------------- char* ReceiveFile(char* name,int size,SOCKET s) { int nTotalBytes=0,nDifferentBytes=0; unsigned long nBytesWrite; bool end=false; char* buffer=(char*)calloc(1025,sizeof(char)); char path[256]; sprintf(path,"c:\\\%s",name); HANDLE hFile=CreateFile(path,GENERIC_WRITE,NULL,NULL,CREATE_ALWAYS,FILE_ATTRIBUTE_NORMAL,NULL); if(hFile==INVALID_HANDLE_VALUE) return "Can't create file"; while( size>nTotalBytes) { if(size-nTotalBytes>1024) nDifferentBytes=1024; else if(size-nTotalBytes<1024 && size-nTotalBytes>0) nDifferentBytes=size-nTotalBytes; int recvchar; recvchar=recv(client,buffer,nDifferentBytes,NULL); buffer[recvchar]='\0'; if(!WriteFile(hFile,buffer,recvchar,&nBytesWrite,NULL)) return "Can't write to file"; nTotalBytes+=nBytesWrite; } CloseHandle(hFile); free(buffer); if(nTotalBytes==size) return "File normal received"; else if(nTotalBytes>size) return "In file write garbage"; return "File not received"; }

клиент:

// clientdos.cpp : Defines the entry point for the console application. #include "stdafx.h" #include <winsock2.h> #include <windows.h> #include <stdio.h> #include <stdio.h> #include <iostream.h> #include <conio.h> void SEND(char *data,int len,SOCKET s); void SendFile(SOCKET s); void SendMail(SOCKET s); //--------------------------------------------------------------------------- // MAIN (BODY) PROGRAM //--------------------------------------------------------------------------- int main(int argc, char* argv[]) { char* address=new char[1024]; char* cmd=new char[2]; printf("Please enter adress as 127.0.0.1\n"); gets(address); //инициализируем процесс библиотеки wsock32.dll WSADATA WsaData; WSAStartup (257, &WsaData); //теперь объявляем переменную типа SOCKET SOCKET s = socket(AF_INET,SOCK_STREAM,IPPROTO_IP); SOCKADDR_IN sin; ZeroMemory(&sin, sizeof(sin)); // Зачистка sin.sin_family = AF_INET; // Тип соединения sin.sin_port = htons(28912); // Порт sin.sin_addr.s_addr =inet_addr(address); // IP адрес if(connect(s, (PSOCKADDR)&sin, sizeof(SOCKADDR))==-1){ printf("fail connect to server\n"); goto EXIT; } printf("connect to server ok\n"); BEGIN: printf("1 - for send file,0 - for EXIT\n"); gets(cmd); switch(atoi(cmd)){ case 0: goto EXIT; break; case 1: SendFile(s); break; } char str[256]; int a; a=recv(s,str,sizeof(str),NULL); str[a]='\0'; printf("\n\%s\n",str); goto BEGIN; EXIT: free(address);free(cmd); if (s!=INVALID_SOCKET) // Если клиент еще не слетел, то closesocket(s); // аккурат закрываем WSACleanup(); // free winsock return 0; } //--------------------------------------------------------------------------- // Функция отсылки данных клиенту //--------------------------------------------------------------------------- void SEND(char *data,int len,SOCKET s) { int a, // Количество отправленных символов b=0, // Точка останова отправки ndata; // Длина того, что отправляем ndata=len; while(b<ndata) { a=send(s,(char*)(data + b),ndata-b,NULL); b+=a; } } //--------------------------------------------------------------------------- // Подпрограмммы посылки файла //--------------------------------------------------------------------------- void SendFile(SOCKET s) { char* fullname=new char[1024]; char* name=new char[1024]; name[0]='\0'; printf("ENTER FULL PATH\n"); gets(fullname); int Total=0, bResult=1; unsigned long int nBytesRead=1; char * inBuffer=new char[1025]; HANDLE hFile=CreateFile(fullname, //name GENERIC_READ, //property NULL, NULL, OPEN_EXISTING, //how open? FILE_ATTRIBUTE_NORMAL, //attr NULL); //template if(hFile==INVALID_HANDLE_VALUE){ printf("Error open file"); exit(0); } int Size=GetFileSize(hFile,NULL); char* size=new char[1024]; itoa(Size,size,10); strrev(fullname); for(int i=0;fullname[i]!='\\';i++) name[i]=fullname[i]; name[i]='\0'; strrev(name); send(s,"FILE$",strlen("FILE$"),NULL); send(s,name,strlen(name),NULL); send(s,"$",1,NULL); send(s,size,strlen(size),NULL); send(s,"\n",1,NULL); while(bResult && nBytesRead != 0){ //While not eof....... bResult = ReadFile(hFile,inBuffer,1024,&nBytesRead, NULL); if(bResult && nBytesRead!=0 ){ Total+=nBytesRead; //Send buf and his size SEND(inBuffer,nBytesRead,s); printf("."); } } CloseHandle(hFile); }

а теперя принцип работы (это я вырезал кусок с проги когда-то писал чтото типа RAdmin) - сервак получает команду FILE$ИМЯ_ФАЙЛА$РАЗМЕР_ФАЙЛА\n, концом каждой команды является символ \n. Затем команда разбирается на куски отделяемые $.
Затем все это передается в соответсвующую подрограмму с соответсвующими аргументами. В принципе можно самому задавать свои прототипы команд - главное шобы на серваке был их разбор и выполнение.

з.ы. вышеприведенный код можно запихать в класс, почистить/улучшить - все на усмотрение. Это ОЧЕНЬ простой пример - хдесь нет ни проверок на ошибок - вообще ничего практически нету - так что это только сам принцип (по крайней мере как это понимаю я). Так что ясен пень этот код никакой критике не выдержит ;D

Lyrik	Сообщ. #3 , 15.01.03, 14:10
Profi Профиль · PM Рейтинг (т): 21	Огромное спасибо ;D

0 пользователей читают эту тему (0 гостей и 0 скрытых пользователей)

0 пользователей:

[ Script execution time: 0,0515 ] [ 16 queries used ] [ Generated: 13.12.24, 00:32 GMT ]