Как реализовать прием-передачу текста через сокет не закрывая и не открывая его каждый раз заново?

Question

[OwDafuq]

Доброе утро.

Есть примерно такой код:

public string Send(string Text, bool Read, Form uForm)
        {
            try
            {
                Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                sock.Connect("localhost", 10000);
                sock.Send(Encoding.UTF8.GetBytes(Text));

                if (Read)
                {
                    byte[] bytes = new byte[2048];
                    int bytesRec = sock.Receive(bytes);
                    sock.Dispose();
                    return Encoding.UTF8.GetString(bytes, 0, bytesRec);
                }
                else
                {
                    sock.Dispose();
                    return null;
                }
            }
            catch
            {
                AlertMessage.Show(uForm, "Серверная часть не доступна.");
                return null;
            }
        }

И как понятно ответ от сервера я могу читать только когда отправляю ему что либо, хочется поддерживать постоянное подключение к нему, а так же обрабатывать ответы.
Может кто, что-то подсказать как такое реализовать?

Comments

[VZVZ]

TcpListener. И гугл: c# listen tcp

Answer 1

[Vindicar]

Погоди, сначала разберемся в логике работы соединения. Есть как минимум два варианта работы:
А) Односторонний запрос-ответ, или ведущий-ведомый (то, что реализовано в приведенном коде). Т.е. клиент(ведущий) шлет запрос, получает ответ от ведомого, и либо закрывает соединение, либо шлёт еще запрос. Так работает HTTP, к примеру.
Б) произвольный порядок. И клиент, и сервер могут послать сообщение другой стороне в произвольный момент, но другая сторона не обязана отвечать немедленно. Так обычно работают IM-системы.

Для второго варианта работы логика будет примерно такой:
1. Установить соединение
2. Ждать, пока не появятся принятые данные, не поступят сообщения для отправки или не будет получен сигнал об остановке.
3. Если получен сигнал остановки, см. п. 11.
4. Проверить, есть ли принятые данные, если нет, см. п. 7.
5. Принять данные и разобрать их формат, преобразовав их в сообщения.
6. Обработать принятые сообщения, например сгенерировать событие.
7. Проверить, есть ли сообщения на отправку, если нет, см. п. 10.
8. Сформировать данные для отправки.
9. Отправить данные.
10. См. п. 2
11. Закрыть соединение.

При этом данные - это та строка байт, которая отправляется через сокет, а сообщение - это те структуры данных, которыми оперирует твоя программа. В простейшем случае это будет одно и то же.

Реализовать такую логику можно следующим образом: создаешь отдельный поток обработки соединения, который в цикле выполняет шаги 2-10. Этот поток должен предоставлять метод для постановки сообщения в очередь на отправку, и событие для реакции на принятые сообщения*.
В этом случае твоя основаная программа стартует этот поток, подписывается на его события, и дергает его метод отправки по мере надобности. Таким образом можно разделить код работы с сетью и GUI.

* Еще пригодится служебная мелочь, вроде команды на остановку потока и закрытие соединения, проверку наличия ошибок и тд. В простейшей программе без этого можно обойтись.

Comments

[OwDafuq]

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

[Vindicar]

Писать код за тебя я, прямо скажем, не стану. Но подсказать могу.
Посмотри метод Socket.Poll() - он позволит тебе определить, пришли ли в сокет новые данные, не выполняя собственно чтение. Ему нужно только два параметра: первый - время ожидания в мс, второй - что проверяем. Тебя интересует проверка чтения и ошибки (режимы SelectRead и SelectError, читай документацию).
Проверку на необходимость завершения потока можно сделать простой булевой переменной (признак останова). True - останавливаемся, False - продолжаем.
Исходящие сообщения удобно хранить в ConcurrentQueue. Т.е. каждый элемент этой коллекции - сообщение, которое надо отправить. В простейшем случае это просто строка.
Тогда логика будет такая (я исхожу из того, что ты понял логику работы в моем ответе):
1. Делаем Poll() на ошибку с нулевым таймаутом, если есть ошибка - прерываем цикл.
2. Проверяем признак останова, если True - прерываем цикл.
3. Проверяем очередь на запись. Пока она не пуста, вытаскиваем одно сообщение и отправляем.
4. Делаем Poll() на чтение, с таймаутом порядка 100 миллисекунд, если сообщит что есть данные - делаем Read(), забираем полученную строку, генерируем событие. Как создавать свои события - много раз уже описано.
И так далее в цикле. Как я уже писал, это стоит делать в отдельном потоке - можно даже запускать по потоку на каждого присоединившегося клиента, так будет проще.

Этот рабочий цикл, в общем-то, пригоден и для клиента, и для сервера. Разница будет лишь в том, что клиент будет коннектиться к серверу и запускать рабочий поток, а сервер - занимать порт, ждать коннекта, и запускать рабочий поток для каждого коннекта.

[OwDafuq]

Vindicar: эх, ладно, спасибо, попробую разобраться.

Answer 2

[Konstantin Malyarov]

Не знаю как на C#, но в Java есть разделение по потокам. Я так догадываюсь Read - это входящий поток, и его надо зациклить на while(true), а точнее whileRead != 0).