Клиент-Сервер (асинхронный): некоррено передаётся файл

@Настёна · Регистрация: 08.02.2009

Студворк — интернет-сервис помощи студентам

Добрый день!
Пишу клиент и сервер с передачей текстового файла от клиента серверу. Задачу нужно решить с использованием неблокирующих сокетов. Всё в принципе работает, но файл почему-то передаётся не всегда, кроме того, если запускаю отдельно экзешники (т.е. не из билдера), то файл не передаётся вообще. Вот код клиента и сервера, и ещё приложен архив с проектом. Буду очень благодарна за помощь!

Клиент:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
//---------------------------------------------------------------------------
#include <stdio.h>
#include <winsock2.h>
#include <windows.h>
 
#include <conio.h>
 
#include <vcl.h>
#pragma hdrstop
//---------------------------------------------------------------------------
 
#pragma argsused
 
WSADATA ws;//информация о сокете
 
int main(int argc, char* argv[])
{
 
   int sock;
   struct sockaddr_in addr;
 
   if (FAILED (WSAStartup (MAKEWORD( 1,1 ), &ws)))
   {
       perror("WSAStartup");
       system("pause");
       exit(1);
   }
 
   sock=socket(AF_INET, SOCK_STREAM,0);
 
   if (sock<0)
   {
      perror("socket");
      system("pause");
      exit(2);
   }
 
   addr.sin_family=AF_INET;
   addr.sin_port=htons(666);
   addr.sin_addr.s_addr=htonl(INADDR_LOOPBACK);
   if(connect(sock,(struct sockaddr *)&addr,sizeof(addr))<0)
   {
       perror("connect");
       system("pause");
       exit(3);
   }
 
   FILE *F;
   if (!(F=fopen("1.txt","r")))
   {
      perror("Open File");
      system("pause");
      exit(4);
   };
 
   char s[80];
   char p[80];
 
   while(!feof(F))
   {
      fgets(s,80,F);
      send(sock, s,sizeof(s),0);
      recv(sock,p,sizeof(s),0);
      printf("%s",p);
   };
   printf("\nThe file transfer completed.\n");
   fclose(F);
   delete(F);
   F = NULL;
   closesocket(sock);
   system("pause");
   return 0;
}
//---------------------------------------------------------------------------

Сервер:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
//---------------------------------------------------------------------------
#include <stdio.h>
#include <winsock2.h>
#include <windows.h>
#include <algorithm>
#include <set>
using namespace std;
#include <time.h>
 
#include <conio.h>
#include <vcl.h>
#pragma hdrstop
 
//---------------------------------------------------------------------------
 
#pragma argsused
//---------------------------------------------------------------------------
int Number;
WSADATA ws;//информация о сокете
int main(int argc, char* argv[])
{
 
    // Шаг 1 - инициализация библиотеки Winsock
    if (FAILED (WSAStartup (MAKEWORD( 1,1 ), &ws)))
    {
       perror("WSAStartup");
       system("pause");
       exit(1);
    }
 
    // Шаг 2 - создание сокета
    SOCKET sock, listener;
 
    struct sockaddr_in addr;
    char buf[1024];
    int bytes_read;
 
    listener = socket(AF_INET, SOCK_STREAM, 0);
    if(listener < 0)
    {
        perror("socket");
        system("pause");
        exit(2);
    }
    ULONG ulBlock;
    ulBlock = 1;
    //аналог fcntl
    if (ioctlsocket(listener, FIONBIO, &ulBlock) == SOCKET_ERROR)
    {
        perror("ioctlsocket_listener");
        system("pause");
        exit(3);
    }
 
    // Шаг 3 - установка соединения
    // заполнение структуры sockaddr_in
    // указание адреса и порта сервера
    addr.sin_family = AF_INET;
    addr.sin_port = htons(666);
    addr.sin_addr.s_addr = INADDR_ANY;
    if(bind(listener, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        system("pause");
        exit(4);
    }
 
    listen(listener, 1);
 
    Number = 0;
 
    FD_SET ReadSet;
    int ReadySock;
 
    set<int> clients;
    clients.clear();
 
    // цикл извлечения запросов на подключение из
    // очереди
    while(1)
    {
       // Заполняем множество сокетов
       FD_ZERO(&ReadSet);
       FD_SET(listener, &ReadSet);
 
       for(set<int>::iterator it = clients.begin(); it != clients.end(); it++)
            FD_SET(*it, &ReadSet);
 
       // Задаём таймаут
       timeval timeout;
       timeout.tv_sec = 15;
       timeout.tv_usec = 0;
 
       // Ждём события в одном из сокетов
       int mx = max(listener, *max_element(clients.begin(), clients.end()));
 
       if ((ReadySock = select(mx+1, &ReadSet, NULL, NULL, &timeout)) ==
        SOCKET_ERROR)
       {
          perror("Select");
          system("pause");
          exit(6);
       }
 
       if (FD_ISSET(listener, &ReadSet))
       {
          sock = accept(listener, NULL, NULL);
      if (sock == INVALID_SOCKET)
      {
         perror("accept");
                break;
          }
 
          if (ioctlsocket(sock, FIONBIO, &ulBlock) == SOCKET_ERROR)
          {
              perror("ioctlsocket_sock");
              break;
          }
 
          //добавили в список
          clients.insert(sock);
       }
 
       for(set<int>::iterator it = clients.begin(); it != clients.end(); it++)
       {
          if(FD_ISSET(*it, &ReadSet))
          {
             Number++;   // увеличиваем счетчик
                   // подключившихся клиентов
             AnsiString filename;
             filename = "Res"+IntToStr(Number)+".txt";
 
             FILE *F;
             if (!(F = fopen(filename.c_str(),"w")))
             {
                 perror("Create File");
                 break;
             };
 
             while( (bytes_read = recv(*it, buf, 1024, 0))>0 )
             {
                fprintf(F,buf);
                printf(buf);
                // Отправляем данные обратно клиенту
                send(*it, buf, bytes_read, 0);
             }
 
             fprintf(F,"\0");
             fclose(F);
             delete(F);
             F = NULL;
             closesocket(*it);
             clients.erase(*it);
          }
 
          printf("\nReceiving the file %d is complete.\n",Number);
       }
 
 
    }
 
     closesocket(sock);
     closesocket(listener);
    _exit(0);
 
    return 0;
}
//---------------------------------------------------------------------------

@QVO · 15.08.2011, 22:28

запусти с правами администратора.

@Настёна · 16.08.2011, 23:09 **[ТС]**

Проблема решена.
Видимо, так как сокеты асинхронные, сервер открывает для клиента сокет и принимает данные до тех пор, пока не выполнится какое-то условие. То есть на каждом шаге бесконечного цикла могут поступить данные от любого из клиентов. Поэтому внутренний цикл, во время которого у меня сервер должен был обслуживать конкретного клиента (после чего закрывать сокет), не нужен - вместо него на каждом шаге внешнего цикла принимаются порция данных уже "открытого" клиента.

Вот работающий код сервера.

Code
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
//---------------------------------------------------------------------------
#include <stdio.h>
#include <winsock2.h>
#include <windows.h>
#include <algorithm>
//#include <set>
#include <map>
using namespace std;
#include <time.h>
 
#include <conio.h>
#include <vcl.h>
#pragma hdrstop
 
//---------------------------------------------------------------------------
 
#pragma argsused
//---------------------------------------------------------------------------
int Number;
WSADATA ws;//информация о сокете
int main(int argc, char* argv[])
{
 
    // Шаг 1 - инициализация библиотеки Winsock
    if (FAILED (WSAStartup (MAKEWORD( 1,1 ), &ws)))
    {
       perror("WSAStartup");
       system("pause");
       exit(1);
    }
 
    // Шаг 2 - создание сокета
    SOCKET sock, listener;
 
    struct sockaddr_in addr;
    char buf[1024];
    int bytes_read;
 
    listener = socket(AF_INET, SOCK_STREAM, 0);
    if(listener < 0)
    {
        perror("socket");
        system("pause");
        exit(2);
    }
    ULONG ulBlock;
    ulBlock = 1;
    //аналог fcntl
    if (ioctlsocket(listener, FIONBIO, &ulBlock) == SOCKET_ERROR)
    {
        perror("ioctlsocket_listener");
        system("pause");
        exit(3);
    }
 
    // Шаг 3 - установка соединения
    // заполнение структуры sockaddr_in
    // указание адреса и порта сервера
    addr.sin_family = AF_INET;
    addr.sin_port = htons(666);
    addr.sin_addr.s_addr = INADDR_ANY;
    if(bind(listener, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        system("pause");
        exit(4);
    }
 
    listen(listener, 1);
 
    Number = 0;
 
    FD_SET ReadSet;
    int ReadySock;
 
    map <int,AnsiString> clients;
    clients.clear();
 
    //typedef:
    typedef map<int,AnsiString>::value_type valType;
 
    // цикл извлечения запросов на подключение из
    // очереди
    while(1)
    {
 
       /*DWORD dwExitCode;
       HANDLE hThreatf = _beglntnread(...);
       GetExitCodeThread(hThread &dwExitCode);
       CloseHandle(hThread);
 
       _beginthread( void (__cdecl *stait_address)(void *), unsigned stack_size, void *arglist);
       */
 
       // Заполняем множество сокетов
       FD_ZERO(&ReadSet);
       FD_SET(listener, &ReadSet);
 
       //for(set<int>::iterator it = clients.begin(); it != clients.end(); it++)
       for(map<int,AnsiString>::iterator it = clients.begin(); it != clients.end(); it++)
            FD_SET((*it).first , &ReadSet);
 
       // Задаём таймаут
       timeval timeout;
       timeout.tv_sec = 15;
       timeout.tv_usec = 0;
 
       int mx = listener;
       for(map<int,AnsiString>::iterator it = clients.begin(); it != clients.end(); it++)
       {
          if ((*it).first > listener)
             mx = (*it).first;
       };
 
       // Ждём события в одном из сокетов
 
       if ((ReadySock = select(mx+1, &ReadSet, NULL, NULL, &timeout)) ==
        SOCKET_ERROR)
       {
          perror("Select");
          system("pause");
          exit(6);
       }
 
       if (FD_ISSET(listener, &ReadSet))
       {
          sock = accept(listener, NULL, NULL);
      if (sock == INVALID_SOCKET)
      {
         perror("accept");
             //system("pause");
             break;
          }
 
          if (ioctlsocket(sock, FIONBIO, &ulBlock) == SOCKET_ERROR)
          {
              perror("ioctlsocket_sock");
              //system("pause");
              break;
          }
 
          //добавили в список
          Number++;   // увеличиваем счетчик
                   // подключившихся клиентов
          clients.insert( valType(sock,"Res"+IntToStr(Number)+".txt"));//  .insert()  (sock,"Res"+IntToStr(Number)+".txt");
 
          AnsiString filename;
          filename = "Res"+IntToStr(Number)+".txt";
 
          FILE *F;
          if (!(F = fopen(filename.c_str(),"w")))
          {
              perror("Create File");
              //system("pause");
              //exit();
              break;
          };
          fclose(F);
       }
 
       for(map<int,AnsiString>::iterator it = clients.begin(); it != clients.end(); it++)
 
       {
          if(FD_ISSET((*it).first, &ReadSet))
          {
             FILE *F;
             if (!(F = fopen((*it).second.c_str() ,"a")))
             {
                 perror("Create File");
                 //system("pause");
                 //exit();
                 break;
             };
 
 
             bytes_read = recv((*it).first, buf, 1024, 0);
             if(bytes_read <= 0)
             {
                 // Соединение разорвано, удаляем сокет из множества
                 closesocket((*it).first);
                 clients.erase((*it).first);
                 continue;
             }
             //записали данные в файл
             fwrite(buf, sizeof(char), strlen(buf), F);
 
             // Отправляем данные обратно клиенту
             send((*it).first, buf, bytes_read, 0);
 
             fclose(F);
             delete(F);
             F = NULL;
          }
          printf("\nReceiving the part of file %d is complete.\n",Number);
       }      
    }
 
    closesocket(sock);
    closesocket(listener);
    //printf("Receiving the file is complete.\n");
    //system("pause");
    _exit(0);
 
    return 0;
}

@zheleznyak_oleg · 06.12.2011, 21:34

А подскажи где про асинхронные сокеты читал?

Новые блоги и статьи Все статьи Все блоги /
Знаешь почему 90% людей редко бывают счастливыми? kumehtar 14.04.2026 Потому что они ждут. Ждут выходных, ждут отпуска, ждут удачного момента. . . а удачный момент так и не приходит.	Фиксация колонок в отчете СКД Maks 14.04.2026 Фиксация колонок в СКД отчета типа Таблица. Задача: зафиксировать три левых колонки в отчете. Процедура ПриКомпоновкеРезультата(ДокументРезультат, ДанныеРасшифровки, СтандартнаяОбработка) / / . . .	Настройки VS Code Loafer 13.04.2026 { "cmake. configureOnOpen": false, "diffEditor. ignoreTrimWhitespace": true, "editor. guides. bracketPairs": "active", "extensions. ignoreRecommendations": true, . . .	Оптимизация кода на разграничение прав доступа к элементам формы Maks 13.04.2026 Алгоритм из решения ниже реализован на нетиповом документе, разработанного в конфигурации КА2. Задачи, как таковой, поставлено не было, проделанное ниже исключительно моя инициатива. Было так:. . .
Контроль заполнения и очистка дат в зависимости от значения перечислений Maks 12.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: реализовать контроль корректности заполнения дат назначения. . .	Архитектура слоя интернета для сервера-слоя. Hrethgir 11.04.2026 В продолжение https:/ / www. cyberforum. ru/ blogs/ 223907/ 10860. html Знаешь что я подумал? Раз мы все источники пишем в голове ветки, то ничего не мешает добавить в голову такой источник, который сам. . .	Подстановка значения реквизита справочника в табличную часть документа Maks 10.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: при выборе сотрудника (справочник Сотрудники) в ТЧ документа. . .	Очистка реквизитов документа при копировании Maks 09.04.2026 Алгоритм из решения ниже применим как для типовых, так и для нетиповых документов на самых различных конфигурациях. Задача: при копировании документа очищать определенные реквизиты и табличную. . .

@QVO 652 / 462 / 80 Регистрация: 26.10.2010 Сообщений: 1,263 Записей в блоге: 4
	15.08.2011, 22:28
	запусти с правами администратора. 0

@zheleznyak_oleg 14 / 14 / 2 Регистрация: 03.01.2011 Сообщений: 77
	06.12.2011, 21:34
	А подскажи где про асинхронные сокеты читал? 0