1

Есть : сервер и клиент. Когда сервер получает сообщение в ветку check_user:

private void ProcessReceive(SocketAsyncEventArgs e)
    {if (e.SocketError == SocketError.Success)
        {getalltables();
            log = new StreamWriter(new FileStream("log.txt", FileMode.Append, FileAccess.Write, FileShare.ReadWrite));
            string str = Encoding.UTF8.GetString(e.Buffer, 0, e.BytesTransferred);
            string[] tmp = str.Split('+');
            Console.WriteLine("{2} msg fr C№{0}({3}): {1}", ClientNumber, str, DateTime.Now.TimeOfDay.ToString().Substring(0,10), (Sock.RemoteEndPoint as IPEndPoint).Address);


            log.Write("\n");
            log.Write("{2} Client msg from Client №{0}({3}): {1}\n", ClientNumber, str, DateTime.Now, (Sock.RemoteEndPoint as IPEndPoint).Address);
            MemoryStream outtabl = new MemoryStream();

            switch (tmp[0].Trim())
            {
                case "check_user":
                    this.resp ="check_user"+"+"+checkUser(tmp[1].Trim().ToString());

                    SendAsync(this.resp);

                    Console.WriteLine("{2} msg to C№{0}({3}): {1}", ClientNumber, "success query " + resp, DateTime.Now.TimeOfDay.ToString().Substring(0, 10), (Sock.RemoteEndPoint as IPEndPoint).Address);
                    log.Write("{2} Message to Client №{0}({3}): {1}", ClientNumber, "success query check_user:", DateTime.Now, (Sock.RemoteEndPoint as IPEndPoint).Address);

как мне разослать строку "resp" все клиентам, которые в сети?(список из ClientConnection) Если попытаться в

foreach(user in onlineusers)
{
user.sock.SendAsync(this.resp);
}

Выкидывает ошибку :

An asynchronous socket operation is already in progress using this SocketAsyncEventArgs instance

2 ответа 2

1

Несколько шагов: 1. Каждому клиенту необходимо иметь свою очередь отправки. Это можно реализовать, например, на ActionBlock'ах. Как только одна отправка завершилась, можно приступать к следующей. Если делать это параллельно, то можно нарваться на исключение (как у вас и получилось). 2. В таком случае вам будет эффективнее всего создать массов байт (то, что отправляем) и распихать в очередь всем клиентам. Они уже независимо друг от друга будут отсылать данные.

Кстати, SocketAsyncEventArgs не может работать параллельно с двумя сокетами.

0

На шарпе уже давно не писал, но с неблокирующими сокетами штука такая, как только клиент начнёт читать из сокета, так на обработчик придёт соответствующее событие и в этот момент (в это самом обработчике) можно будет писать в сокет.

Все клиенты заблокируются на чтении последовательно вызовутся колбеки на сервере и вы сможете написать для каждого сообщение, вроде так последний раз я делал в (java.noi).

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

Ваш ответ

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

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