Yuebon.EventBus.Kafka/ProtobufTransfer.cs

微信扫码关注公众号，代码整理好后第一时间通知你。

namespace Yuebon.EventBus.Kafka;

public class Protobuf
{
	/// <summary>
	/// Protobuf 反序列化
	/// </summary>
	public static T Deserialize<T>(ReadOnlySpan<byte> data)
	{
		Stream stream = new MemoryStream(data.ToArray());
		var info = ProtoBuf.Serializer.Deserialize<T>(stream);
		return info;
	}
	/// <summary>
	/// 通过Protobuf 转字节
	/// </summary>
	public static byte[] Serialize<T>(T data)
	{
		byte[] datas;
		using (var stream = new MemoryStream())
		{
			ProtoBuf.Serializer.Serialize(stream, data);
			datas = stream.ToArray();
		}
		return datas;


	}
}