Данные от сервера клиенту передаются только один раз

@123456789igor2 · Регистрация: 13.09.2013

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

Я хочу постоянно передавать от сервера клиенту массив байт, но получается передать только 1 раз. Никак не пойму почему.
Сервер:

C#

public ServerSocket(IPAddress ipAddress, int port)
        {
            _clients = new List<ClientModel>();
 
            _server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            _server.Bind(new IPEndPoint(ipAddress, port));
            _server.Listen(20); 
            Accept();
        }
 
        private async void Accept()
        {
            
            for ( int i=0;i<10 ;i++)
            {
                var socket = await Task.Factory.FromAsync<Socket>(_server.BeginAccept, _server.EndAccept, true);
                var newClient = new ClientModel
                {
                    Id = _id++,
                    ClientSocket = socket
                };
                _clients.Add(newClient);
                await Send(1, "hello " + i + "");
            }
        }
public async Task Send(int id, String data)
        {
            var client = _clients.FirstOrDefault(cl => cl.Id == id);
            if(client == null) return;
 
            var byteData = Encoding.UTF8.GetBytes(data);
            await Task.Factory.FromAsync<int>(
              client.ClientSocket.BeginSend(byteData, 0, byteData.Length, SocketFlags.None, null, client.ClientSocket),
              client.ClientSocket.EndSend);
        }

Клиент:

C#

public ClientSocket()
        {
            _client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        }
 
        public bool Connect(IPAddress ipAddress, int port)
        {
            _client.Connect(ipAddress, port);
            if (!_client.Connected)
            {
                return false;
            }
            Receive();
            return true;
        }
 
private async void Receive()
        {
            var buffer = new byte[4096];
            for (; ; )
            {
                try
                {
                    var bytesRead = await Task.Factory.FromAsync<int>(
                            _client.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, null, _client),
                             _client.EndReceive);
                    if (bytesRead <= 0) continue;
 
                    var message = Encoding.UTF8.GetString(buffer, 0, bytesRead);
                    Console.WriteLine(message);
                }
                catch
                {
                    break;
                }
            }

Учитывать надо, что одновременных клиентов может быть несколько. Проблема в том, что на 2ой итерации Сервер ждет на "BeginAccept/EndAccept", а клиент на "BeginReceive/EndReceive". Т.е получается, что клиент готов получать, а сервер не знает об этом. Подскажите как решить проблему.
Интересный факт: Если запустить сервер, затем клиент, то передастся массив 1 раз. Но если(ничего не закрываяя) открыть новый экземпляр клиента и выполнить его, то первый экземпляр пример 2ой раз массив. Если 2ой экземпляр клиента выполнить ещё раз, то первый примет 3ий массив. И так далее

@EVG-1980 · 06.05.2014, 10:27

Сообщение от 123456789igor2

Интересный факт: Если запустить сервер, затем клиент, то передастся массив 1 раз. Но если(ничего не закрываяя) открыть новый экземпляр клиента и выполнить его, то первый экземпляр пример 2ой раз массив. Если 2ой экземпляр клиента выполнить ещё раз, то первый примет 3ий массив. И так далее

C#

 for ( int i=0;i<10 ;i++)
            {
                var socket = await Task.Factory.FromAsync<Socket>(_server.BeginAccept, _server.EndAccept, true);
                var newClient = new ClientModel
                {
                    Id = _id++,
                    ClientSocket = socket
                };
                _clients.Add(newClient);
                await Send(1, "hello " + i + ""); // по кто подключился шлем данные клиенту с ID=1
            }

Добавлено через 6 минут

Сообщение от 123456789igor2

Сервер ждет на "BeginAccept/EndAccept", а клиент на "BeginReceive/EndReceive". Т.е получается, что клиент готов получать, а сервер не знает об этом. Подскажите как решить проблему.

C#

public async Task Send(int id, String data)
        {
            var client = _clients.FirstOrDefault(cl => cl.Id == id);
            if(client == null) return;
 
            var byteData = Encoding.UTF8.GetBytes(data);
            await Task.Factory.FromAsync<int>(
              client.ClientSocket.BeginSend(byteData, 0, byteData.Length, SocketFlags.None, null, client.ClientSocket),
              client.ClientSocket.EndSend);
 
            // попробуй так
            await Send(ID,"hello " + "hello " + i + "");        
           //
}

@123456789igor2 · 06.05.2014, 16:09 **[ТС]**

EVG-1980, Таким образом только 1 клиент может подключиться. Выполнение не выйдет за пределы метода Send. Но 1 клиент может непрерывно получать, таким способом, но только 1

Добавлено через 36 минут
Думаю просто не хватает каких то колбэков что бы снова связать клиент и сервер. Но каких не могу понять

@EVG-1980 · 06.05.2014, 16:31

C#

private async void Accept()
        {
            
            for ( int i=0;i<10 ;i++)
            {
                var socket = await Task.Factory.FromAsync<Socket>(_server.BeginAccept, _server.EndAccept, true);
                var newClient = new ClientModel
                {
                    Id = _id++,
                    ClientSocket = socket
                };
                _clients.Add(newClient);
                await Send(Id, "hello " + i + "");
            }
           await Accept();
        }

@123456789igor2 · 06.05.2014, 16:46 **[ТС]**

Тоже не работает. Перезапуск "Accept" будет работать только если постоянно клиент после каждый итерации будет делать реконнект

@EVG-1980 · 06.05.2014, 16:58

123456789igor2,

Использование ContinueWith для функции обратного вызова

Если требуется доступ к данным файла, в отличие от числа байтов, метода FromAsync недостаточно. Вместо этого используйте Task, свойство которого Result содержит данные файла. Это можно сделать, добавив продолжение в исходную задачу. Продолжение выполняет работу, которая обычно выполняется делегатом AsyncCallback. Оно вызывается по завершении предшествующей задачи, и буфер данных заполняется. (Объект FileStream необходимо закрыть перед возвратом.)

Добавлено через 7 минут
Взято отсюда http://msdn.microsoft.com/ru-r... 10%29.aspx , там пример с файлом но суть не меняется

@123456789igor2 1 / 1 / 0 Регистрация: 13.09.2013 Сообщений: 23
	06.05.2014, 16:09 [ТС]	3
	EVG-1980, Таким образом только 1 клиент может подключиться. Выполнение не выйдет за пределы метода Send. Но 1 клиент может непрерывно получать, таким способом, но только 1 Добавлено через 36 минут Думаю просто не хватает каких то колбэков что бы снова связать клиент и сервер. Но каких не могу понять 0

@123456789igor2 1 / 1 / 0 Регистрация: 13.09.2013 Сообщений: 23
	06.05.2014, 16:46 [ТС]	5
	Тоже не работает. Перезапуск "Accept" будет работать только если постоянно клиент после каждый итерации будет делать реконнект 0

@EVG-1980 192 / 199 / 82 Регистрация: 11.04.2013 Сообщений: 1,086
	06.05.2014, 16:58	6
	123456789igor2, Использование ContinueWith для функции обратного вызова Если требуется доступ к данным файла, в отличие от числа байтов, метода FromAsync недостаточно. Вместо этого используйте Task, свойство которого Result содержит данные файла. Это можно сделать, добавив продолжение в исходную задачу. Продолжение выполняет работу, которая обычно выполняется делегатом AsyncCallback. Оно вызывается по завершении предшествующей задачи, и буфер данных заполняется. (Объект FileStream необходимо закрыть перед возвратом.) Добавлено через 7 минут Взято отсюда http://msdn.microsoft.com/ru-r... 10%29.aspx , там пример с файлом но суть не меняется 0