Асинхронный сервер

@DeKaN · Регистрация: 10.02.2010

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

всем привет. У меня есть асинхронный сервер, который получает данные следующим образом:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
private void OnRecieved(IAsyncResult ar)
{
   Socket sock = (Socket)ar.AsyncState;
   byte[] aryRet = GetRecievedData(ar);
   if (aryRet.Length < 1)
   {
      this.OnDisconnected();
      this.Disconnect();
   }
   else
   {
      // Обрабатываю запрос //
 
      sock.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None, new AsyncCallback(OnRecieved), m_sock);
   }
}

Когда от клиента посылаются 2 запроса подряд, и если сервер не успел обработаться 1-ый запрос, то 2-ой просто пропадёт. Как сделать так, чтоб запрос вставал в очередь, и после обработке 1-го запроса началась обрабтка 2-го?

Пробовал так:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
private void OnRecieved(IAsyncResult ar)
{
   Socket sock = (Socket)ar.AsyncState;
   byte[] aryRet = GetRecievedData(ar);
   if (aryRet.Length < 1)
   {
      this.OnDisconnected();
      this.Disconnect();
   }
   else
   {
      sock.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None, new AsyncCallback(OnRecieved), m_sock);
 
      // Обрабатываю запрос //
   }
}

Всёравно....

Можно сделать так конечно:

C#
1
2
for(int i=0;i<N;i++)
   sock.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None, new AsyncCallback(OnRecieved), m_sock);

Но тогда создаются N потоков для прослушки....а если клиентов много, то это не вариант...

@Serg_1986 · 01.07.2011, 12:19

никуда запрос не должен пропадать. Они становятся в очередь, если очередь меньше чем полученные сообщения то могут быть потери. Можно увидеть описание GetRecievedData(ar); EndRecive вызывается?

@DeKaN · 01.07.2011, 14:22 **[ТС]**

никуда запрос не должен пропадать

Странно, у меня пропадает((

можно увидеть описание GetRecievedData(ar); EndRecive вызывается?

да конечно:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
private byte[] GetRecievedData(IAsyncResult ar)
        {
            int nBytesRec = 0;
            try
            {
                nBytesRec = Sock.EndReceive(ar);
            }
            catch (SocketException exc)
            {
                //Ошибка
            }
            catch (Exception exc)
            {
                //Ошибка
            }
            byte[] byReturn = new byte[nBytesRec];
            Array.Copy(byteData, byReturn, nBytesRec);
            return byReturn;
        }

@Serg_1986 · 01.07.2011, 14:45

А что за параметр m_sock в sock.BeginReceive? Может должен быть sock. Посмотри http://msdn.microsoft.com/en-us/library/fx6588te, рабочий пример. Но мне кажется дело в m_sock.

@DeKaN · 01.07.2011, 16:28 **[ТС]**

А что за параметр m_sock в sock.BeginReceive? Может должен быть sock.

m_sock это сокет клиента....т.е. после того как клиент подключается, мы этот сокет получаем:

C#
1
 Socket m_sock = (Socket)Sock.EndAccept(ar);

где Sock - сокет сервера.

Добавлено через 34 минуты
ни туда посмотрел, и не о том написал))
исправил на

C#
1
sock.BeginReceive(byteData, 0, byteData.Length, SocketFlags.None, new AsyncCallback(OnRecieved), sock)

Теперь принимает 2 запроса...посылаю 4, принимает 2...посылаю 8, принимает 2))

@Serg_1986 · 01.07.2011, 16:35

Ты смотрел ссылку на MSDn. Размер принимающего буфера достаточный для приема сообщения? Какой формат сообщения, может в одном сообщении приходит сразу несколько(нужно это тоже учитывать и разделять их тогда), проверь в отладчике что приходет от клиента. Проверь сам клиент))

@DeKaN · 01.07.2011, 16:42 **[ТС]**

я уже увидел в чем проблема))
дело в том, что размер буфера то нормальный....но несколько запросов принимаются за 1...получается что я отправляю 3 запроса длиной по 100 байт каждый, а получаю я 2 раза: первый 110, второй 290...

Добавлено через 51 секунду
спс...буду разделять

Новые блоги и статьи Все статьи Все блоги /
Символьное дифференцирование igorrr37 13.02.2026 / * Логарифм записывается как: (x-2)log(x^2+2) - означает логарифм (x^2+2) по основанию (x-2). Унарный минус обозначается как ! в-строка - входное арифметическое выражение в инфиксной(обычной). . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .	И ясному Солнцу zbw 12.02.2026 И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.	«Знание-Сила» zbw 12.02.2026 «Знание-Сила» «Время-Деньги» «Деньги -Пуля»
SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 12.02.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .	SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 11.02.2026 Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .	SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL3_image 8Observer8 10.02.2026 Содержание блога Библиотека SDL3_image содержит инструменты для расширенной работы с изображениями. Пошагово создадим проект для загрузки изображения формата PNG с альфа-каналом (с прозрачным. . .	Установка Qt-версии Lazarus IDE в Debian Trixie Xfce volvo 10.02.2026 В общем, достали меня глюки IDE Лазаруса, собранной с использованием набора виджетов Gtk2 (конкретно: если набирать текст в редакторе и вызвать подсказку через Ctrl+Space, то после закрытия окошка. . .

@Serg_1986 10 / 10 / 4 Регистрация: 27.04.2010 Сообщений: 122
	01.07.2011, 12:19
	никуда запрос не должен пропадать. Они становятся в очередь, если очередь меньше чем полученные сообщения то могут быть потери. Можно увидеть описание GetRecievedData(ar); EndRecive вызывается? 1

@Serg_1986 10 / 10 / 4 Регистрация: 27.04.2010 Сообщений: 122
	01.07.2011, 14:45
	А что за параметр m_sock в sock.BeginReceive? Может должен быть sock. Посмотри http://msdn.microsoft.com/en-us/library/fx6588te, рабочий пример. Но мне кажется дело в m_sock. 0

@Serg_1986 10 / 10 / 4 Регистрация: 27.04.2010 Сообщений: 122
	01.07.2011, 16:35
	Ты смотрел ссылку на MSDn. Размер принимающего буфера достаточный для приема сообщения? Какой формат сообщения, может в одном сообщении приходит сразу несколько(нужно это тоже учитывать и разделять их тогда), проверь в отладчике что приходет от клиента. Проверь сам клиент)) 1

@DeKaN 36 / 36 / 8 Регистрация: 10.02.2010 Сообщений: 184
	01.07.2011, 16:42 [ТС]
	я уже увидел в чем проблема)) дело в том, что размер буфера то нормальный....но несколько запросов принимаются за 1...получается что я отправляю 3 запроса длиной по 100 байт каждый, а получаю я 2 раза: первый 110, второй 290... Добавлено через 51 секунду спс...буду разделять 0