JT1078Gateway/src/JT1078.DotNetty.Core/Codecs/JT1078UdpDecoder.cs

using DotNetty.Buffers;
using DotNetty.Codecs;
using DotNetty.Transport.Channels;
using System.Collections.Generic;
using DotNetty.Transport.Channels.Sockets;
using JT1078.DotNetty.Core.Metadata;

namespace JT1078.DotNetty.Core.Codecs
{
    public class JT1078UdpDecoder : MessageToMessageDecoder<DatagramPacket>
    {
        protected override void Decode(IChannelHandlerContext context, DatagramPacket message, List<object> output)
        {
            if (!message.Content.IsReadable()) return;
            IByteBuffer byteBuffer = message.Content;
            byte[] buffer = new byte[byteBuffer.ReadableBytes];
            byteBuffer.ReadBytes(buffer);
            output.Add(new JT1078UdpPackage(buffer, message.Sender));
        }
    }
}