1

Всем привет! Есть

Сервер:

TcpClient tcpclient = tcpListener.AcceptTcpClient();
 NetworkStream nstream = tcpclient.GetStream();
 StreamWriter writer = new StreamWriter(nstream, Encoding.UTF8) { AutoFlush = true };
 StreamReader reader = new StreamReader(nstream, Encoding.UTF8);

 while (true)
 {
     string inputline = "";
     while (inputline != null)
     {
         inputline = reader.ReadLine();
         Console.WriteLine("Клиент написал: " + inputline);
     }

и Клиент:

TcpClient client = new TcpClient("localhost", port);
        NetworkStream stream = client.GetStream();
        Console.WriteLine("Подключено");
        StreamReader reader = new StreamReader(stream);
        StreamWriter writer = new StreamWriter(stream) { AutoFlush = true };

        while (true)
        {
            Console.WriteLine("Введите сообщение: ");
            string lineToSend = Console.ReadLine();
            writer.WriteLine(lineToSend);
        }

Как можно с сервера отправить клиенту ответное сообщение, если при старте сервера (даже если принимаем клиента в новом потоке) полностью блокируется ввод сообщения в консоли сервера? Т.е. мы можем только отправлять сообщения на сервер, а ответ с сервера клиенту писать не можем.

15
  • Можно либо делать чтение и запись в разных потоках, либо использовать асинхронное чтение, не блокирующее поток.
    – Regent
    13 июн 2015 в 9:17
  • Что значит «отправить»? Вы хотите отправить ответ автоматически, или ввести его с клавиатуры? Если автоматически, так просто посылайте его после приёма. Да, и клиент, разумеется, должен слушать ответ.
    – VladD
    13 июн 2015 в 9:46
  • Отправлять с консоли сервера, ответ клиенту автоматически я сделал.
    – Malcolm
    13 июн 2015 в 9:50
  • 1
    Ну, после inputline = reader.ReadLine(); дописываете writer.WriteLine("answer");. А вообще, лучше делать асинхронно, как здесь.
    – VladD
    13 июн 2015 в 9:56
  • 1
    @Regent если у вас есть ответ - оформляйте его как ответ с кодом. а не как коммент со ссылкой в fiddle.
    – user177221
    13 июн 2015 в 10:11

2 ответа 2

2

Сервер (2 потока, один для обработки запросов от клиента, другой для обработки запросов с консоли):

static void Main(string[] args)
{
    TcpListener tcpListener = new TcpListener(IPAddress.Any, 4000);
    tcpListener.Start();
    Console.WriteLine("Сервер запущен");
    TcpClient tcpclient = tcpListener.AcceptTcpClient();
    NetworkStream nstream = tcpclient.GetStream();
    Console.WriteLine("Клиент подключен");
    StreamWriter writer = new StreamWriter(nstream, Encoding.UTF8) { AutoFlush = true };
    StreamReader reader = new StreamReader(nstream, Encoding.UTF8);
    new Thread(() =>
    {
        while (true)
        {
            string inputline = reader.ReadLine();
            Console.WriteLine("Клиент написал: " + inputline);
            writer.WriteLine(inputline.Length);
        }
    }).Start();
    new Thread(() =>
    {
        while (true)
        {
            string lineToSend = Console.ReadLine();
            writer.WriteLine("Инфо: " + lineToSend);
        }
    }).Start();
}

Клиент (2 потока, один для обработки консоли и отправки данных серверу, другой для обработки полученных от сервера данных):

static void Main(string[] args)
{
    Console.WriteLine("Подключение к серверу...");
    int port = 4000;
    TcpClient client = new TcpClient("localhost", port);
    NetworkStream stream = client.GetStream();
    Console.WriteLine("Подключено");
    StreamReader reader = new StreamReader(stream);
    StreamWriter writer = new StreamWriter(stream) { AutoFlush = true };

    new Thread(() =>
    {
        while (true)
        {
            Console.Write("Введите сообщение: ");
            string lineToSend = Console.ReadLine();
            writer.WriteLine(lineToSend);
            Console.WriteLine("Сообщение отправлено");
        }
    }).Start();

    new Thread(() =>
    {
        while (true)
        {
            string inputline = reader.ReadLine();
            Console.ForegroundColor = ConsoleColor.Green;
            Console.WriteLine(inputline);
            Console.ForegroundColor = ConsoleColor.Gray;
        }
    }).Start();
}
16
  • Единственное что хочу попросить, проверьте клиента, по такой схеме он запускается подключается и сразу закрывается, не пойму почему вот реализация
    – Malcolm
    13 июн 2015 в 11:43
  • Нашел причину Console.ReadLine(); в конец всего кода, вот только если зациклить, то опять клиент несет какаю то чушь, т.е. становится синхронным.
    – Malcolm
    13 июн 2015 в 12:04
  • 1
    @Malcolm вообще говоря, это уже тянет на отдельный вопрос, но да ладно. Доработанный код сервера находится тут. Идея в том, что .AcceptTcpClient() находится в бесконечном цикле, и каждому клиенту выделяются свои потоки со своими StreamWriter и StreamReader. Сообщение из консоли рассылается всем клиентам из списка. Код по-прежнему сделан без обработки ошибок и прочего - просто как наглядный пример идеи.
    – Regent
    13 июн 2015 в 15:45
  • 1
    @Malcolm достаточно обернуть всю работу с клиентом в try - catch. По-хорошему, в catch стоит закрывать и StreamReader, и StreamWriter, чтобы память не утекала. Я сделал пример, в котором закрывается только writer. Код тут. А зачем со мной связываться?
    – Regent
    13 июн 2015 в 16:30
  • 1
    @Malcolm проблем я вижу две: 1. В readers ничего не добавляется. 2. foreach в foreach - неправильный подход. Цикл должен быть только по writers, а в случае ошибки и закрытия должны браться текущий writer и соответствующий ему reader. Чтобы взять соответствующий reader, нужно либо надеяться, что он расположен в readers на том же месте, что и writer в writers, либо сделать reader и writer полями одного объекта (нового класса с условным именем MyClient) и использовать везде уже List<MyClient> clients
    – Regent
    14 июн 2015 в 3:02
1

пусть сервер распределяет сообщения между клиентами. Тогда у сервера не будет консоли, и соответственно проблемы тоже.
Если сервер обязан вести лог, то тогда нужен объект синхронизации lock.
https://msdn.microsoft.com/ru-ru/library/c5kehkcz.aspx

4
  • Нет лог мне не нужен, просто желательно сделать как сказано выше, чтение и запись в отдельных потоках, вот только как я не знаю.
    – Malcolm
    13 июн 2015 в 9:54
  • Ну сделай после Console.WriteLine("Клиент написал: " + inputline); сразу Console.ReadLine() и отправь клиенту. А у клиента reader.readLine() 13 июн 2015 в 10:11
  • Вроде работает только вот одно но, если с сервера отправить клиенту сообщение, то сервер ждет ответа от клиента и не дает написать следующее, и наоборот
    – Malcolm
    13 июн 2015 в 11:06
  • Мотомучто приложение синхронное. Вам нужно использовать асинхронную реализацию. А главном потоке крутить ввод/вывод консоли, а в других потоках получение сообщений с сокета 13 июн 2015 в 11:11

Ваш ответ

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

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