AxibugEmuOnline/AxibugEmuOnline.Client/Assets/Script/AppMain/Common/ProtoBufHelper.cs

using AxibugEmuOnline.Client.Network;
using Google.Protobuf;
using HaoYueNet.ClientNetwork;
using System;

namespace AxibugEmuOnline.Client.Common
{
    public static class ProtoBufHelper
    {
        private static ProtobufferMsgPool _msgPool = new ProtobufferMsgPool();
        static CodedInputStream codedInputStream = new CodedInputStream();

        public static void RentSerizlizeData(IMessage msg, out byte[] data, out int usedlength)
        {
            usedlength = msg.CalculateSize();
            data = BytesArrayPool.RentBuffer(usedlength);
            msg.WriteTo(data.AsSpan(0, usedlength));
        }
        public static void ReturnSerizlizeData(byte[] data)
        {
            BytesArrayPool.ReturnBuffer(data);
        }

        public static byte[] Serizlize(IMessage msg)
        {
            return msg.ToByteArray();
        }
        public static T DeSerizlizeFromPool<T>(byte[] bytes)
        {
            var msgType = typeof(T);
            object msg = _msgPool.Get(msgType);
            //((IMessage)msg).MergeFrom(bytes);
            ((IMessage)msg).MergeFromEx(codedInputStream, bytes, 0, bytes.Length);
            return (T)msg;
        }

        public static IMessage DeSerizlizeFromPool(byte[] bytes, Type protoType)
        {
            var msgType = protoType;
            object msg = _msgPool.Get(msgType);
            //((IMessage)msg).MergeFrom(bytes);
            ((IMessage)msg).MergeFromEx(codedInputStream, bytes, 0, bytes.Length);
            return (IMessage)msg;
        }
        public static void ReleaseToPool(IMessage msg)
        {
            _msgPool.Release(msg);
        }
    }
}