Receive and Send

[Boris2105]

Нужна помощь с исправлением приемом и отправкой пакетов.
Не могу понять в чем проблема , иногда идут левые пакеты.
Пробовал написать так же как и в point blank приемку и отправку пакетов, после 1 пакета ничего в ответ не идет.


Структура пакетов:
Длина = 2 байта
Крипт = 1 байт (0-не закриптован/1-закриптован)
Опкод = 2 байта
Тело = Остальные байты
Для логина и гейм одинаковая структура.

Receive:

Свернуть ↑

 
InHeaderSize = 3;
       private void BeginReceive()
        {
            if (_disconnected)
                return;
 
            _socket.BeginReceive(_receiveBuffer, 0, _receiveBuffer.Length, SocketFlags.None, Receive, null);
        }
 
        private void Receive(IAsyncResult ar)
        {
            var receivedBytes = 0;
 
            try
            {
                receivedBytes = _socket.EndReceive(ar);
            }
            catch (Exception ex)
            {
                Disconnect($"Receive Exception: {ex}");
            }
 
            // Check if the socket was closed.
            if (receivedBytes == 0)
            {
                Disconnect();
                return;
            }
 
            // Check the message header.
            if (receivedBytes < InHeaderSize)
            {
                Disconnect("The received packets header size is incorrect.");
                return;
            }
 
            // TODO Properly Process incomming bytes.
            using (var stream = new MemoryStream(_receiveBuffer, 0, receivedBytes))
            using (var reader = new BinaryReader(stream))
            {
                var size = reader.ReadUInt16();
                var encrypted = reader.ReadByte() == 1;
 
                var body = reader.ReadBytes(size - InHeaderSize);
 
                if (encrypted)
                {
                    body = BDOCrypt.Xor(body, 0, body.Length);
                }
 
                using (var messageStream = new MemoryStream(body))
                using (var message = new BinaryReader(messageStream))
                {
                    var messageId = message.ReadUInt16(); // MessageId
 
                    Console.WriteLine(
                        $"Received(Size:{size}, Encrypted: {encrypted}, MessageId: {messageId}, 0x{messageId:X2})");
                    Console.WriteLine(BufferExtensions.ToHex(body.ToArray()));
 
                    var handler = MessageTable.FindMessageHandler(messageId);
 
                    if (handler != null)
                    {
                        handler.Handle(this, message);
                    }
                    else
                    {
                        Console.WriteLine($"Unknown Message Received: MessageId: {messageId} (0x{messageId:X2})");
                    }
                }
            }
 
            // Start receiving more data.
            BeginReceive();
        }
 
Code: C#

Свернуть ↑Развернуть ↓

Send:

Свернуть ↑

 
OutHeaderSize = 3;
        public void SendBody(ushort opCode, byte[] body, bool encrypted = true)
        {
            byte[] outputBuffer;
 
            using (var memoryStream = new MemoryStream())
            using (var writer = new BinaryWriter(memoryStream))
            {
                writer.Write((ushort)opCode);
                writer.Write(body);
                writer.Flush();
 
                outputBuffer = memoryStream.ToArray();
            }
 
            if (encrypted)
            {
                outputBuffer = BDOCrypt.Xor(outputBuffer);
            }
 
            var messageSize = outputBuffer.Length + OutHeaderSize;
 
            Console.WriteLine($"Send(Size:{body.Length}, Encrypted: {encrypted}, MessageId: {opCode})");
            Console.WriteLine(BufferExtensions.ToHex(body));
 
            using (var memoryStream = new MemoryStream())
            using (var writer = new BinaryWriter(memoryStream))
            {
                writer.Write((ushort)messageSize); // Message size;
                writer.Write((byte)(encrypted ? 1 : 0)); // IsEncrypted -> 0 = false, 1 = true
                writer.Write(outputBuffer);
                writer.Flush();
 
                Send(memoryStream.ToArray());
            }
        }
 
        public void Send(IMessage message)
        {
            var messageData = MessageTable.FindMessageData(message);
 
            if (messageData == null)
                throw new Exception($"Could not find message attribute for {nameof(message)}");
 
            byte[] bodyBuffer;
            var encrypted = messageData.Encrypted;
 
            using (var bodyStream = new MemoryStream())
            using (var bodyWriter = new BinaryWriter(bodyStream))
            {
                bodyWriter.Write((ushort)messageData.MessageId); // MessageId
                message.Serialize(bodyWriter); // Body
                bodyWriter.Flush();
 
                bodyBuffer = bodyStream.ToArray();
            }
 
            var messageId = (ushort)messageData.MessageId;
            Console.WriteLine(
                $"Send(Size:{bodyBuffer.Length}, Encrypted: {encrypted}, MessageId: {messageData.MessageId}, {messageId}, 0x{messageId:X2})");
            Console.WriteLine(BufferExtensions.ToHex(bodyBuffer.ToArray()));
 
            if (encrypted)
            {
                bodyBuffer = BDOCrypt.Xor(bodyBuffer);
            }
 
            using (var sendBuffer = new MemoryStream())
            using (var messageBuilder = new BinaryWriter(sendBuffer))
            {
                // Build the message.
                messageBuilder.Write((ushort)(bodyBuffer.Length + OutHeaderSize));
                messageBuilder.Write((byte)(encrypted ? 1 : 0)); // Encrypted
                messageBuilder.Write(bodyBuffer);
                messageBuilder.Flush();
 
                // Send data
                var messageBuffer = sendBuffer.ToArray();
                Send(messageBuffer);
            }
        }
 
        private void Send(byte[] buffer)
        {
            try
            {
                _socket.BeginSend(buffer, 0, buffer.Length, SocketFlags.None, SendCallback, null);
                Console.WriteLine($"Sent: {buffer.Length} bytes");
            }
            catch (Exception ex)
            {
                Disconnect($"Send Exception: {ex}");
            }
        }
 
        private void SendCallback(IAsyncResult ar)
        {
            try
            {
                _socket.EndSend(ar); // Returns sent bytes.
            }
            catch (Exception ex)
            {
                Disconnect($"Send Exception: {ex}");
            }
        }
 
Code: C#

Свернуть ↑Развернуть ↓

[Boris2105]

Сможет кто то помочь?

[KID]

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

[Boris2105]

Сообщение от KID

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

в теории я понимаю, но на практике ничего не выходит