Приостановление stream.Read

@Gnoooooooooom · Регистрация: 27.06.2019

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

С Рождеством!
Уже месяц бьюсь над проблемой. Вопрос такой, у меня чат-сервер. При подключении проблем нет, но когда наступает время самого чата. То клиент не может ничего написать, так как NetworkStream занят чтением (ожиданием отклика от сервера, ну, во всяком случае я так думаю, другие сотни вариантов перебрал). Помогите, если можете, код класса подключения и передачи ниже. Заранее спасибо!

C#

    public class Connection
    {
        StreamWriter writer;
        StreamReader reader;
        NetworkStream stream;
        byte[] buf;
        byte[] receiveBuffer;
        int dataBufferSize = 2048;
 
        public Connection(TcpClient tcpClient)
        {
            stream = tcpClient.GetStream();
            writer = new StreamWriter(stream);
            reader = new StreamReader(stream);
        }
 
        [MethodImpl(MethodImplOptions.Synchronized)]
        public void send(Message message)
        {
            writer.WriteLine(message.getXml());
            writer.Flush();
        }
 
        [MethodImpl(MethodImplOptions.Synchronized)]
        public Message receive()
        {
            Message message;
 
            string s = reader.ReadLine();
            var serializer = new XmlSerializer(typeof(Message));
            using (var xmlStream = new StringReader(s))
            {
                message = (Message)serializer.Deserialize(xmlStream);
            }
            return message;
        }
 
        public void close()
        {
            stream.Close();
        }
    }

@nicolas2008 · 08.01.2021, 12:23

Gnoooooooooom, нужен код самого чата. synchronized лишнее

@Gnoooooooooom · 08.01.2021, 14:45 **[ТС]**

Ну, у меня код сервера на Java, проблема вообще-то не в сервере, как я думаю. Клиент встает на этапе отправки сообщения (то есть на методе send). Я сделал костыль, специально остановил поток отправки в моей программе, и только тогда сообщение отправилось, но я думаю, что нужно как-то по-другому сделать.

@nicolas2008 · 08.01.2021, 14:55

Gnoooooooooom, код клиента конечно.

@Gnoooooooooom · 08.01.2021, 17:13 **[ТС]**

Это как обычная строка передается серверу.

C#

protected void sendTextMessage(string text)
    {
        try
        {
            stopMain();
            connection.send(new Message(MessageType.TEXT, text));
            startMain();
        }
        catch (Exception)
        {
            ConsoleHelper.writeMessage("Ошибка отправки");
            clientConnected = false;
        }
    }
private void startMain()
    {
        checkThread = new Thread(clientMainLoop);
        checkThread.Start();
    }
 
    private void stopMain()
    {
        checkThread.Abort();
    }

C#

public class Connection
    {
        StreamWriter writer;
        StreamReader reader;
        NetworkStream stream;
        byte[] buf;
        byte[] receiveBuffer;
        int dataBufferSize = 2048;
 
        public Connection(TcpClient tcpClient)
        {
            stream = tcpClient.GetStream();
            writer = new StreamWriter(stream);
            reader = new StreamReader(stream);
        }
 
        [MethodImpl(MethodImplOptions.Synchronized)]
        public void send(Message message)
        {
            writer.WriteLine(message.getXml());
            writer.Flush();
        }
 
        [MethodImpl(MethodImplOptions.Synchronized)]
        public Message receive()
        {
            Message message;
 
            try
            {
                string s = reader.ReadLine();
                if(s == null)
                {
                    return null;
                }
                var serializer = new XmlSerializer(typeof(Message));
                using (var xmlStream = new StringReader(s))
                {
                    message = (Message)serializer.Deserialize(xmlStream);
                }
            }
            catch (ArgumentNullException)
            {
                return null;
            }
            return message;
        }
 
        public void close()
        {
            stream.Close();
        }
    }

@nicolas2008 1142 / 851 / 262 Регистрация: 30.04.2009 Сообщений: 3,580
	08.01.2021, 12:23	2
	Gnoooooooooom, нужен код самого чата. synchronized лишнее 0

@Gnoooooooooom 0 / 0 / 0 Регистрация: 27.06.2019 Сообщений: 23
	08.01.2021, 14:45 [ТС]	3
	Ну, у меня код сервера на Java, проблема вообще-то не в сервере, как я думаю. Клиент встает на этапе отправки сообщения (то есть на методе send). Я сделал костыль, специально остановил поток отправки в моей программе, и только тогда сообщение отправилось, но я думаю, что нужно как-то по-другому сделать. 0

@nicolas2008 1142 / 851 / 262 Регистрация: 30.04.2009 Сообщений: 3,580
	08.01.2021, 14:55	4
	Gnoooooooooom, код клиента конечно. 0

	08.01.2021, 17:13

Опции темы