Форум программистов, компьютерный форум, киберфорум
C# .NET
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
17 / 5 / 3
Регистрация: 22.03.2011
Сообщений: 329

Ошибка в асинхронном клиенте при получении информации от сервера

31.01.2013, 19:04. Показов 969. Ответов 0
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Привет всем. Проблема возникает при принятии сообщения от сервера, если поступает много сообщений. То есть я открываю 5 клиентов, например, в каждом клиенте есть функция отправки, которая отправляет данные на сервер каждые 250 миллисекунд. А сервер отправляет пришедшее сообщение всем остальным клиентам. Так вот появляется исключение которое называется -
An asynchronous socket operation is already in progress using this socketasynceventargs instance
Я-то вроде понимаю, что оно мне говорит - Асинхронный сокет уже использует этот socketasynceventargs instance.
Но не знаю, как это исправить. Если кто-то знает, то, пожалуйста, поясните, как искоренить эту ошибку. И расскажите поподробней про саму ошибку и почему она возникает. Заранее спасибо.
Код клиента:
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
169
170
171
172
173
174
175
176
177
178
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
 
namespace test_client
{
    class Program
    {
        private static Socket socket;
        private static SocketAsyncEventArgs SockAsyncEventArgs; // объект для асинхронной операции на сокете
 
        private static byte[] buff; // буфер обмена
 
        private static void Init()
        {
 
 
            socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            buff = new byte[256];
            SockAsyncEventArgs = new SocketAsyncEventArgs();
            // подписываемся на завершение асинхронного соединения
            SockAsyncEventArgs.Completed += SockAsyncArgs_Completed;
        }
        private static void res()
        {
            try
            {
                while (true)
                {
                    if (socket.Available > 0) //если пришли данные
                    {
 
                        //Thread.Sleep(500);
                        ProcessSend(SockAsyncEventArgs); // получаем их
                    }
                }
            }
            catch (Exception e)
            {
                Console.WriteLine("res: " + e.Message);
            }
        }
 
        private static void SockAsyncArgs_Completed(object sender, SocketAsyncEventArgs e)
        {
            switch (e.LastOperation)
            {
                case SocketAsyncOperation.Connect:
                    ProcessConnect(e);
                    break;
                case SocketAsyncOperation.Receive:
                    ProcessReceive(e);
                    break;
            }
        }
 
        private static void Start_Connect(string address, int port)
        {
            SockAsyncEventArgs.RemoteEndPoint = new IPEndPoint(IPAddress.Parse(address), port);
            ConnectAsync(SockAsyncEventArgs);
        }
 
        private static void ConnectAsync(SocketAsyncEventArgs e)
        {
            bool willRaiseEvent = socket.ConnectAsync(e);
            if (!willRaiseEvent)
                ProcessConnect(e);
        }
 
        private static void ProcessConnect(SocketAsyncEventArgs e)
        {
            if (e.SocketError == SocketError.Success)
            {
                SockAsyncEventArgs.SetBuffer(buff, 0, buff.Length);
                res();
            }
            else
                Console.WriteLine("Lost connection with " + e.RemoteEndPoint.ToString());
 
        }
 
        private static void SendAsync(byte[] data)
        {
            if (socket.Connected && data.Length > 0)
            {
                SocketAsyncEventArgs e = new SocketAsyncEventArgs();
                e.SetBuffer(data, 0, data.Length);
                e.Completed += SockAsyncArgs_Completed;
                bool willRaiseEvent = socket.SendAsync(e);
                // Console.WriteLine("bytes sent: "+data.Length);
            }
        }
 
        private static void ProcessSend(SocketAsyncEventArgs e)
        {
            try
            {
                if (e.SocketError == SocketError.Success)
                {
                    ReceiveAsync(SockAsyncEventArgs);
                }
                else
                {
                    Console.WriteLine("Not sended");
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("ProcessSend: " + ex.Message);
            }
        }
 
        private static void ReceiveAsync(SocketAsyncEventArgs e)
        {
            try
            {
                bool willRaiseEvent = socket.ReceiveAsync(e);
                if (!willRaiseEvent)
                    ProcessReceive(e);
            }
            catch (Exception ex)
            {
                Console.WriteLine("ReceiveAsync: " + ex.Message);
            }
        }
 
        private static void ProcessReceive(SocketAsyncEventArgs e)
        {
 
            if (e.SocketError == SocketError.Success)
            {
                try
                {
                    string s = Encoding.UTF8.GetString(e.Buffer, 0, e.BytesTransferred); //получаем идентификатор команды
                    Console.WriteLine(s);
                    //Console.WriteLine("receive bytes: "+e.BytesTransferred);
                }
                catch (Exception ex)
                {
                    Console.WriteLine("ProcessReceive: " + ex.Message);
                }
 
            }
 
        }
        static int Main(string[] args)
        {
            Init(); //подготовка соединения  с сервером
            Start_Connect("127.0.0.1", 9095); //соединяемся с сервером
            string s = "";
            Console.ReadKey();
            for (int i = 0; i < 20; i++)
            {
                if (i % 2 > 0)
                {
                    s = "приветики " + i;
                    SendAsync(Encoding.UTF8.GetBytes(s));
                }
                else
                {
                    s = "ку " + i;
                    SendAsync(Encoding.UTF8.GetBytes(s));
                }
 
                Thread.Sleep(250);
            }
            Console.ReadLine();
            return 0;
        }
 
    }
 
}
Само исключение возникает в методе
C#
1
private static void ReceiveAsync(SocketAsyncEventArgs e)
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
31.01.2013, 19:04
Ответы с готовыми решениями:

Ошибка при получении информации из ярлыка
Подскажите где ошибка, при указании файла lnk не в корне диска из файла lnk не читается информация.

Ошибка на транспортном уровне при получении результатов с сервера.
Пишу курсач по базам данных сервер MS SQL, добавил роли в приложение и стала вылетать такая ошибка

Зависание клиента при получении сообщения от сервера
Отсылаю сообщение серверу и хочу вывести результат выполнения команды на сервере в клиенте. Клиент напрочь зависает. Где ошибка в коде? ...

0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
31.01.2013, 19:04
Помогаю со студенческими работами здесь

Перезагрузка страницы при получении данных с сервера fetch запросом
Всем добрый день! Столкнулся с такой небольшой проблемой. На странице существует форма отправки изображений, события в которой...

Добавить в try ошибку на транспортном уровне при получении результатов с сервера
Данная ошибка выходит, когда есть проблемы с сетью. Как добавить эту ошибку в try?

Получить один элемент из многомерного массива при получении ответа от сервера
Получаю от сервера данные в формате JSON: data_xml = XML(event.target.data); trace(data_xml); Результат: Вопрос: как...

Чат. При активации функции Send на клиенте, сообщение должно попасть в функцию Receive сервера
привет всем. у меня есть проект чат,который срочно нужно сделать. передача сообщений идет посредством NetworkStrem и BinaryFormatter....

Ошибка при получении данных из БД при использовании MVC framework 4.0
// HomeControlers.cs using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.Mvc; ...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
1
Ответ Создать тему
Новые блоги и статьи
PhpStorm 2025.3: WSL Terminal всегда стартует в ~
and_y87 14.12.2025
PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .
Access
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru