Sry.Framework.Web/Message.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

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

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Sry.Framework.Web
{
    public class Message : IBinaryParse
    {
        public int Length { get; set; }
        public long CRC { get; set; }
        public string AppKey { get; set; }
        public string Recret { get; set; }
        public string SessionKey { get; set; }
        public string Callback { get; set; }
        public bool IsAsync { get; set; }
        public bool MustResponse { get; set; }
        public int ByteTotal { get; set; }
        public byte[] Bytes { get; set; }
        public int Count { get; set; }
        public List<MessageBody> Items { get; set; }


        public void Read(System.IO.BinaryReader reader)
        {
            this.AppKey = reader.ReadString();
            this.Recret = reader.ReadString();
            this.SessionKey = reader.ReadString();
            this.Callback = reader.ReadString();
            this.IsAsync = reader.ReadBoolean();
            this.MustResponse = reader.ReadBoolean();
            this.Count = reader.ReadInt32();
            this.ByteTotal = reader.ReadInt32();
            this.Bytes = reader.ReadBytes(this.ByteTotal);
            
        }

        public void Write(System.IO.BinaryWriter writer)
        {
            writer.Write(this.AppKey ?? "");
            writer.Write(this.Recret ?? "");
            writer.Write(this.SessionKey ?? "");
            writer.Write(this.Callback ?? "");
            writer.Write(this.IsAsync);
            writer.Write(this.MustResponse);
            
            if (Items != null && Items.Count > 0)
            {
                using (var stream = new MemoryStream())
                {
                    using (var bodyWriter = new BinaryWriter(stream))
                    {
                        foreach (MessageBody body in Items)
                        {
                            body.Write(bodyWriter);
                        }
                        this.ByteTotal = (int)stream.Length;
                        this.Bytes = stream.ToArray();